test_class.file: core/src/test/java/edu/stanford/futuredata/macrobase/pipeline/BasicBatchPipelineTest.java
test_class.identifier: BasicBatchPipelineTest
test_case.body: @Test
      public void testDemoQuery() throws Exception {
          PipelineConfig conf = PipelineConfig.fromYamlFile(
                  "src/test/resources/tiny_conf.yaml"
          );
          BasicBatchPipeline p = new BasicBatchPipeline(conf);
          Explanation e = p.results();
          assertEquals(3.0, e.numTotal(), 1e-10);
      }
test_case.class_method_signature: BasicBatchPipelineTest.testDemoQuery()
test_case.full_signature: @Test public void testDemoQuery()
test_case.identifier: testDemoQuery
test_case.invocations: fromYamlFile results assertEquals numTotal
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testDemoQuery()
focal_class.declarator: log = LoggerFactory.getLogger(Pipeline.class)
focal_class.original_string: Logger log = LoggerFactory.getLogger(Pipeline.class);
focal_class.type: Logger
focal_class.var_name: log
focal_class.declarator: inputURI = null
focal_class.modifier: private
focal_class.original_string: private String inputURI = null;
focal_class.type: String
focal_class.var_name: inputURI
focal_class.declarator: classifierType
focal_class.modifier: private
focal_class.original_string: private String classifierType;
focal_class.type: String
focal_class.var_name: classifierType
focal_class.declarator: metric
focal_class.modifier: private
focal_class.original_string: private String metric;
focal_class.type: String
focal_class.var_name: metric
focal_class.declarator: cutoff
focal_class.modifier: private
focal_class.original_string: private double cutoff;
focal_class.type: double
focal_class.var_name: cutoff
focal_class.declarator: meanColumn
focal_class.modifier: private
focal_class.original_string: private Optional<String> meanColumn;
focal_class.type: Optional<String>
focal_class.var_name: meanColumn
focal_class.declarator: strCutoff
focal_class.modifier: private
focal_class.original_string: private String strCutoff;
focal_class.type: String
focal_class.var_name: strCutoff
focal_class.declarator: isStrPredicate
focal_class.modifier: private
focal_class.original_string: private boolean isStrPredicate;
focal_class.type: boolean
focal_class.var_name: isStrPredicate
focal_class.declarator: pctileHigh
focal_class.modifier: private
focal_class.original_string: private boolean pctileHigh;
focal_class.type: boolean
focal_class.var_name: pctileHigh
focal_class.declarator: pctileLow
focal_class.modifier: private
focal_class.original_string: private boolean pctileLow;
focal_class.type: boolean
focal_class.var_name: pctileLow
focal_class.declarator: predicateStr
focal_class.modifier: private
focal_class.original_string: private String predicateStr;
focal_class.type: String
focal_class.var_name: predicateStr
focal_class.declarator: numThreads
focal_class.modifier: private
focal_class.original_string: private int numThreads;
focal_class.type: int
focal_class.var_name: numThreads
focal_class.declarator: bitmapRatioThreshold
focal_class.modifier: private
focal_class.original_string: private int bitmapRatioThreshold;
focal_class.type: int
focal_class.var_name: bitmapRatioThreshold
focal_class.declarator: summarizerType
focal_class.modifier: private
focal_class.original_string: private String summarizerType;
focal_class.type: String
focal_class.var_name: summarizerType
focal_class.declarator: attributes
focal_class.modifier: private
focal_class.original_string: private List<String> attributes;
focal_class.type: List<String>
focal_class.var_name: attributes
focal_class.declarator: ratioMetric
focal_class.modifier: private
focal_class.original_string: private String ratioMetric;
focal_class.type: String
focal_class.var_name: ratioMetric
focal_class.declarator: minSupport
focal_class.modifier: private
focal_class.original_string: private double minSupport;
focal_class.type: double
focal_class.var_name: minSupport
focal_class.declarator: minRiskRatio
focal_class.modifier: private
focal_class.original_string: private double minRiskRatio;
focal_class.type: double
focal_class.var_name: minRiskRatio
focal_class.declarator: meanShiftRatio
focal_class.modifier: private
focal_class.original_string: private double meanShiftRatio;
focal_class.type: double
focal_class.var_name: meanShiftRatio
focal_class.declarator: useFDs
focal_class.modifier: private
focal_class.original_string: private boolean useFDs;
focal_class.type: boolean
focal_class.var_name: useFDs
focal_class.declarator: functionalDependencies
focal_class.modifier: private
focal_class.original_string: private int[] functionalDependencies;
focal_class.type: int[]
focal_class.var_name: functionalDependencies
focal_class.file: core/src/main/java/edu/stanford/futuredata/macrobase/pipeline/BasicBatchPipeline.java
focal_class.identifier: BasicBatchPipeline
focal_class.interfaces: implements Pipeline
focal_class.class_method_signature: BasicBatchPipeline.BasicBatchPipeline(PipelineConfig conf)
focal_class.full_signature: public  BasicBatchPipeline(PipelineConfig conf)
focal_class.identifier: BasicBatchPipeline
focal_class.modifiers: public
focal_class.parameters: (PipelineConfig conf)
focal_class.signature:  BasicBatchPipeline(PipelineConfig conf)
focal_class.class_method_signature: BasicBatchPipeline.getClassifier()
focal_class.full_signature: public Classifier getClassifier()
focal_class.identifier: getClassifier
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Classifier
focal_class.signature: Classifier getClassifier()
focal_class.class_method_signature: BasicBatchPipeline.getSummarizer(String outlierColumnName)
focal_class.full_signature: public BatchSummarizer getSummarizer(String outlierColumnName)
focal_class.identifier: getSummarizer
focal_class.modifiers: public
focal_class.parameters: (String outlierColumnName)
focal_class.return: BatchSummarizer
focal_class.signature: BatchSummarizer getSummarizer(String outlierColumnName)
focal_class.class_method_signature: BasicBatchPipeline.loadData()
focal_class.full_signature: public DataFrame loadData()
focal_class.identifier: loadData
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: DataFrame
focal_class.signature: DataFrame loadData()
focal_class.class_method_signature: BasicBatchPipeline.results()
focal_class.full_signature: @Override public Explanation results()
focal_class.identifier: results
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Explanation
focal_class.signature: Explanation results()
focal_method.body: @Override
      public Explanation results() throws Exception {
          long startTime = System.currentTimeMillis();
          DataFrame df = loadData();
          long elapsed = System.currentTimeMillis() - startTime;
  
          log.info("Loading time: {} ms", elapsed);
          log.info("{} rows", df.getNumRows());
          log.info("Metric: {}", metric);
          log.info("Attributes: {}", attributes);
  
          Classifier classifier = getClassifier();
          classifier.process(df);
          df = classifier.getResults();
  
          BatchSummarizer summarizer = getSummarizer(classifier.getOutputColumnName());
  
          startTime = System.currentTimeMillis();
          summarizer.process(df);
          elapsed = System.currentTimeMillis() - startTime;
          log.info("Summarization time: {} ms", elapsed);
          Explanation output = summarizer.getResults();
  
          return output;
      }
focal_method.class_method_signature: BasicBatchPipeline.results()
focal_method.full_signature: @Override public Explanation results()
focal_method.identifier: results
focal_method.invocations: currentTimeMillis loadData currentTimeMillis info info getNumRows info info getClassifier process getResults getSummarizer getOutputColumnName currentTimeMillis process currentTimeMillis info getResults
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: Explanation
focal_method.signature: Explanation results()