@@ -454,15 +454,13 @@ public List<String> getQueryProvidersName(boolean enabled) {
454
454
for (QueryInterface p : plugins ) {
455
455
names .add (p .getName ());
456
456
}
457
- // logger.info("Query Providers: "+Arrays.toString(names.toArray()) );
458
457
return names ;
459
458
}
460
459
461
460
public QueryInterface getQueryProviderByName (String name , boolean onlyEnabled ) {
462
461
Collection <QueryInterface > plugins = getQueryPlugins (onlyEnabled );
463
462
for (QueryInterface p : plugins ) {
464
463
if (p .getName ().equalsIgnoreCase (name )) {
465
- // logger.info("Retrived Query Provider: "+name);
466
464
return p ;
467
465
}
468
466
}
@@ -494,7 +492,6 @@ public IndexerInterface getIndexerByName(String name, boolean onlyEnabled) {
494
492
Collection <IndexerInterface > plugins = getIndexingPlugins (onlyEnabled );
495
493
for (IndexerInterface p : plugins ) {
496
494
if (p .getName ().equalsIgnoreCase (name )) {
497
- // logger.info("Retrived Query Provider: "+name);
498
495
return p ;
499
496
}
500
497
}
@@ -507,7 +504,6 @@ public JettyPluginInterface getServletByName(String name, boolean onlyEnabled) {
507
504
Collection <JettyPluginInterface > plugins = getServletPlugins (onlyEnabled );
508
505
for (JettyPluginInterface p : plugins ) {
509
506
if (p .getName ().equalsIgnoreCase (name )) {
510
- // logger.info("Retrived Query Provider: "+name);
511
507
return p ;
512
508
}
513
509
}
@@ -519,7 +515,6 @@ public StorageInterface getStorageByName(String name, boolean onlyEnabled) {
519
515
Collection <StorageInterface > plugins = getStoragePlugins (onlyEnabled );
520
516
for (StorageInterface p : plugins ) {
521
517
if (p .getName ().equalsIgnoreCase (name )) {
522
- // logger.info("Retrived Query Provider: "+name);
523
518
return p ;
524
519
}
525
520
}
@@ -535,7 +530,6 @@ public JointQueryTask queryAll(JointQueryTask holder, final String query, final
535
530
536
531
public JointQueryTask queryAll (JointQueryTask holder , final String query , final DimLevel level ,
537
532
final Object ... parameters ) {
538
- // logger.info("Querying all providers");
539
533
List <String > providers = this .getQueryProvidersName (true );
540
534
return query (holder , providers , query , level , parameters );
541
535
}
@@ -552,7 +546,6 @@ public Task<Iterable<SearchResult>> query(String querySource, final String query
552
546
final Object ... parameters ) {
553
547
Task <Iterable <SearchResult >> t = getTaskForQueryDim (querySource , query , level , parameters );
554
548
taskManagerQueries .dispatch (t );
555
- // logger.info("Fired Query Task: "+querySource +" QueryString:"+query);
556
549
557
550
return t ;// returns the handler to obtain the computation results
558
551
}
@@ -573,7 +566,6 @@ public JointQueryTask query(JointQueryTask holder, List<String> querySources, fi
573
566
for (Task <?> t : tasks )
574
567
taskManagerQueries .dispatch (t );
575
568
576
- // logger.info("Fired Query Tasks: "+Arrays.toString(querySources.toArray()) +" QueryString:"+query);
577
569
return holder ;// returns the handler to obtain the computation results
578
570
}
579
571
@@ -593,7 +585,6 @@ public JointQueryTask query(JointQueryTask holder, List<String> querySources, fi
593
585
for (Task <?> t : tasks )
594
586
taskManagerQueries .dispatch (t );
595
587
596
- // logger.info("Fired Query Tasks: "+Arrays.toString(querySources.toArray()) +" QueryString:"+query);
597
588
return holder ;// returns the handler to obtain the computation results
598
589
}
599
590
@@ -618,7 +609,6 @@ public Iterable<SearchResult> call() throws Exception {
618
609
619
610
}
620
611
});
621
- // logger.info("Prepared Query Task: QueryString");
622
612
return queryTask ;
623
613
}
624
614
@@ -654,7 +644,6 @@ public Iterable<SearchResult> call() {
654
644
655
645
}
656
646
});
657
- // logger.info("Prepared Query Task: QueryString");
658
647
return queryTask ;
659
648
}
660
649
@@ -687,11 +676,8 @@ public List<Task<Report>> index(URI path) {
687
676
continue ;
688
677
final String taskUniqueID = UUID .randomUUID ().toString ();
689
678
task .setName (String .format ("[%s]index %s" , indexer .getName (), path ));
690
- task .onCompletion (new Runnable () {
691
- @ Override
692
- public void run () {
693
- logger .info ("Task [{}] complete: {} is indexed" , taskUniqueID , pathF );
694
- }
679
+ task .onCompletion (() -> {
680
+ logger .info ("Task [{}] complete on {}" , taskUniqueID , pathF );
695
681
});
696
682
697
683
taskManager .dispatch (task );
@@ -701,7 +687,7 @@ public void run() {
701
687
logger .warn ("Indexer {} failed unexpectedly" , indexer .getName (), ex );
702
688
}
703
689
}
704
- logger .info ("Finished firing all indexing plugins for {}" , path );
690
+ logger .debug ("Finished firing all indexing plugins for {}" , path );
705
691
706
692
return rettasks ;
707
693
}
@@ -728,14 +714,14 @@ public List<Task<Report>> index(String pluginName, URI path) {
728
714
729
715
@ Override
730
716
public void run () {
731
- logger .info ("Task [{}] complete: {} is indexed " , taskUniqueID , pathF );
717
+ logger .info ("Task [{}] complete on {} " , taskUniqueID , pathF );
732
718
}
733
719
});
734
720
735
721
taskManager .dispatch (task );
736
722
737
723
rettasks .add (task );
738
- logger .info ("Fired indexer {} for URI {}" , pluginName , path .toString ());
724
+ logger .debug ("Fired indexer {} for URI {}" , pluginName , path .toString ());
739
725
RunningIndexTasks .getInstance ().addTask (task );
740
726
}
741
727
} catch (RuntimeException ex ) {
0 commit comments