test_class.declarator: log = LoggerFactory.getLogger(GoogleMonitoringIngesterTest.class)
test_class.modifier: private static final
test_class.original_string: private static final Logger log = LoggerFactory.getLogger(GoogleMonitoringIngesterTest.class);
test_class.type: Logger
test_class.var_name: log
test_class.declarator: conf
test_class.modifier: private
test_class.original_string: private MacroBaseConf conf;
test_class.type: MacroBaseConf
test_class.var_name: conf
test_class.file: contrib/src/test/java/macrobase/ingest/GoogleMonitoringIngesterTest.java
test_class.identifier: GoogleMonitoringIngesterTest
test_case.body: @Test(expected = NullPointerException.class)
      public void testProcessRecordMissingMetric() throws Exception {
          Record record = new Record();
          record.attributes = new TreeMap<>();
          record.attributes.put("attr1", "foo");
          record.attributes.put("attr2", "bar");
          record.values = new HashMap<>();
  
          GoogleMonitoringIngester ingester = new GoogleMonitoringIngester(conf);
          ingester.processRecord(record);
      }
test_case.class_method_signature: GoogleMonitoringIngesterTest.testProcessRecordMissingMetric()
test_case.full_signature: @Test(expected = NullPointerException.class) public void testProcessRecordMissingMetric()
test_case.identifier: testProcessRecordMissingMetric
test_case.invocations: put put processRecord
test_case.modifiers: @Test(expected = NullPointerException.class) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testProcessRecordMissingMetric()
focal_class.declarator: log = LoggerFactory.getLogger(GoogleMonitoringIngester.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger log = LoggerFactory.getLogger(GoogleMonitoringIngester.class);
focal_class.type: Logger
focal_class.var_name: log
focal_class.declarator: GOOGLE_MONITORING_QUERIES = "macrobase.loader.googlemonitoring.queries"
focal_class.modifier: public static final
focal_class.original_string: public static final String GOOGLE_MONITORING_QUERIES = "macrobase.loader.googlemonitoring.queries";
focal_class.type: String
focal_class.var_name: GOOGLE_MONITORING_QUERIES
focal_class.declarator: GOOGLE_MONITORING_START_TIME = "macrobase.loader.googlemonitoring.startTime"
focal_class.modifier: public static final
focal_class.original_string: public static final String GOOGLE_MONITORING_START_TIME = "macrobase.loader.googlemonitoring.startTime";
focal_class.type: String
focal_class.var_name: GOOGLE_MONITORING_START_TIME
focal_class.declarator: GOOGLE_MONITORING_END_TIME = "macrobase.loader.googlemonitoring.endTime"
focal_class.modifier: public static final
focal_class.original_string: public static final String GOOGLE_MONITORING_END_TIME = "macrobase.loader.googlemonitoring.endTime";
focal_class.type: String
focal_class.var_name: GOOGLE_MONITORING_END_TIME
focal_class.declarator: dataStream
focal_class.modifier: private
focal_class.original_string: private MBStream<Datum> dataStream;
focal_class.type: MBStream<Datum>
focal_class.var_name: dataStream
focal_class.declarator: loaded = false
focal_class.modifier: private
focal_class.original_string: private boolean loaded = false;
focal_class.type: boolean
focal_class.var_name: loaded
focal_class.declarator: pointsAdded = 0
focal_class.modifier: private
focal_class.original_string: private int pointsAdded = 0;
focal_class.type: int
focal_class.var_name: pointsAdded
focal_class.declarator: skippedTimeSeries = 0
focal_class.modifier: private
focal_class.original_string: private int skippedTimeSeries = 0;
focal_class.type: int
focal_class.var_name: skippedTimeSeries
focal_class.declarator: skippedPoints = 0
focal_class.modifier: private
focal_class.original_string: private int skippedPoints = 0;
focal_class.type: int
focal_class.var_name: skippedPoints
focal_class.file: contrib/src/main/java/macrobase/ingest/GoogleMonitoringIngester.java
focal_class.identifier: GoogleMonitoringIngester
focal_class.class_method_signature: GoogleMonitoringIngester.GoogleMonitoringIngester(MacroBaseConf conf)
focal_class.full_signature: public  GoogleMonitoringIngester(MacroBaseConf conf)
focal_class.identifier: GoogleMonitoringIngester
focal_class.modifiers: public
focal_class.parameters: (MacroBaseConf conf)
focal_class.signature:  GoogleMonitoringIngester(MacroBaseConf conf)
focal_class.class_method_signature: GoogleMonitoringIngester.getStream()
focal_class.full_signature: @Override public MBStream<Datum> getStream()
focal_class.identifier: getStream
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: MBStream<Datum>
focal_class.signature: MBStream<Datum> getStream()
focal_class.class_method_signature: GoogleMonitoringIngester.getQueries(String queryJson)
focal_class.full_signature:  QueryConf getQueries(String queryJson)
focal_class.identifier: getQueries
focal_class.parameters: (String queryJson)
focal_class.return: QueryConf
focal_class.signature: QueryConf getQueries(String queryJson)
focal_class.class_method_signature: GoogleMonitoringIngester.processResponse(ListTimeSeriesResponse response, List<String> allMetrics,
                           Map<String, Map<String, Record>> byTime)
focal_class.full_signature:  void processResponse(ListTimeSeriesResponse response, List<String> allMetrics,
                           Map<String, Map<String, Record>> byTime)
focal_class.identifier: processResponse
focal_class.parameters: (ListTimeSeriesResponse response, List<String> allMetrics,
                           Map<String, Map<String, Record>> byTime)
focal_class.return: void
focal_class.signature: void processResponse(ListTimeSeriesResponse response, List<String> allMetrics,
                           Map<String, Map<String, Record>> byTime)
focal_class.class_method_signature: GoogleMonitoringIngester.processRecord(Record rec)
focal_class.full_signature:  Datum processRecord(Record rec)
focal_class.identifier: processRecord
focal_class.parameters: (Record rec)
focal_class.return: Datum
focal_class.signature: Datum processRecord(Record rec)
focal_class.class_method_signature: GoogleMonitoringIngester.convertToStream(Map<String, Map<String, Record>> byTime)
focal_class.full_signature:  MBStream<Datum> convertToStream(Map<String, Map<String, Record>> byTime)
focal_class.identifier: convertToStream
focal_class.parameters: (Map<String, Map<String, Record>> byTime)
focal_class.return: MBStream<Datum>
focal_class.signature: MBStream<Datum> convertToStream(Map<String, Map<String, Record>> byTime)
focal_class.class_method_signature: GoogleMonitoringIngester.buildClient()
focal_class.full_signature: private Monitoring buildClient()
focal_class.identifier: buildClient
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: Monitoring
focal_class.signature: Monitoring buildClient()
focal_class.superclass: extends DataIngester
focal_method.body: Datum processRecord(Record rec) throws Exception {
          int idx = 0;
          RealVector metricVec = new ArrayRealVector(metrics.size());
          for (String metric : metrics) {
              metricVec.setEntry(idx, rec.values.get(metric));
              ++idx;
          }
  
          idx = 1;
          List<Integer> attrList = new ArrayList<>(attributes.size());
          for (String attr : attributes) {
              attrList.add(conf.getEncoder().getIntegerEncoding(idx, rec.attributes.get(attr)));
              ++idx;
          }
  
          return new Datum(attrList, metricVec);
      }
focal_method.class_method_signature: GoogleMonitoringIngester.processRecord(Record rec)
focal_method.full_signature:  Datum processRecord(Record rec)
focal_method.identifier: processRecord
focal_method.invocations: size setEntry get size add getIntegerEncoding getEncoder get
focal_method.parameters: (Record rec)
focal_method.return: Datum
focal_method.signature: Datum processRecord(Record rec)