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
      public void testGetQueriesUsesDefaults() throws Exception {
          GoogleMonitoringIngester ingester = new GoogleMonitoringIngester(conf);
          QueryConf queryConf = ingester.getQueries(
              "{`queries`: [{`project`: `some-project`, `filter`: `metric.type=\\`custom.googleapis.com/test\\``}]}".replace('`', '"'));
  
          assertEquals(1, queryConf.getQueries().size());
  
          QueryConf.Query query = queryConf.getQueries().get(0);
          assertEquals("some-project", query.getProject());
          assertEquals("metric.type=\"custom.googleapis.com/test\"", query.getFilter());
          assertEquals("", query.getAlignmentPeriod());
          assertEquals("ALIGN_NONE", query.getPerSeriesAligner());
          assertEquals("REDUCE_NONE", query.getCrossSeriesReducer());
          assertEquals(0, query.getGroupByFields().size());
      }
test_case.class_method_signature: GoogleMonitoringIngesterTest.testGetQueriesUsesDefaults()
test_case.full_signature: @Test public void testGetQueriesUsesDefaults()
test_case.identifier: testGetQueriesUsesDefaults
test_case.invocations: getQueries replace assertEquals size getQueries get getQueries assertEquals getProject assertEquals getFilter assertEquals getAlignmentPeriod assertEquals getPerSeriesAligner assertEquals getCrossSeriesReducer assertEquals size getGroupByFields
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testGetQueriesUsesDefaults()
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: QueryConf getQueries(String queryJson) throws IOException {
          ObjectMapper mapper = Jackson.newObjectMapper();
          return mapper.readValue(queryJson, QueryConf.class);
      }
focal_method.class_method_signature: GoogleMonitoringIngester.getQueries(String queryJson)
focal_method.full_signature:  QueryConf getQueries(String queryJson)
focal_method.identifier: getQueries
focal_method.invocations: newObjectMapper readValue
focal_method.parameters: (String queryJson)
focal_method.return: QueryConf
focal_method.signature: QueryConf getQueries(String queryJson)