class GoogleMonitoringIngester extends DataIngester {

    MBStream<Datum> convertToStream(Map<String, Map<String, Record>> byTime) {
        MBStream<Datum> stream = new MBStream<>();
        for (Entry<String, Map<String, Record>> entry : byTime.entrySet()) {
            for (Record rec : entry.getValue().values()) {
                try {
                    stream.add(processRecord(rec));
                    ++pointsAdded;
                } catch (Exception e) {
                    // The record was incomplete.
                    ++skippedPoints;
                }
            }
        }

        return stream;
    }

    public  GoogleMonitoringIngester(MacroBaseConf conf);

}