@Test public void streamWithBeginAndEnd() throws Exception { Mockito .when(influxDB.query(Mockito.any(), Mockito.any())) .thenAnswer(keyedQueriesAnswer(STREAM_WITH_BEGIN_AND_END_QUERIES)); assertThat(history.stream(DateTime.parse("2017-09-17T10:00:00.000Z"), DateTime.parse("2017-09-17T14:00:00.000Z")).collect(Collectors.toList()), computeDataMatcher(STREAM_WITH_BEGIN_AND_END_QUERIES, false)); verify(influxDB, times(STREAM_WITH_BEGIN_AND_END_QUERIES.size())).query( Mockito.argThat(Matchers.hasProperty("database", Matchers.equalTo(DATABASE))), Mockito.eq(TimeUnit.MILLISECONDS) ); verifyNoMoreInteractions(influxDB); }
@Override public Stream<TimeSeriesCollection> stream() { return stream(TimeSeriesMetricFilter.ALL_GROUPS); }
InfluxHistory extends InfluxUtil implements CollectHistory, AutoCloseable { @Override public Stream<TimeSeriesCollection> stream() { return stream(TimeSeriesMetricFilter.ALL_GROUPS); } }
InfluxHistory extends InfluxUtil implements CollectHistory, AutoCloseable { @Override public Stream<TimeSeriesCollection> stream() { return stream(TimeSeriesMetricFilter.ALL_GROUPS); } InfluxHistory(InfluxDB influxDB, String database);  InfluxHistory(InfluxDB influxDB, String database, boolean verifyDatabaseConnection); }
InfluxHistory extends InfluxUtil implements CollectHistory, AutoCloseable { @Override public Stream<TimeSeriesCollection> stream() { return stream(TimeSeriesMetricFilter.ALL_GROUPS); } InfluxHistory(InfluxDB influxDB, String database);  InfluxHistory(InfluxDB influxDB, String database, boolean verifyDatabaseConnection); @Override void close(); @Override boolean add(@NonNull TimeSeriesCollection tsdata); @Override boolean addAll(@NonNull Collection<? extends TimeSeriesCollection> c); @Override boolean addAll(@NonNull Iterator<? extends TimeSeriesCollection> i); int getTargetBatchSize(); void setTargetBatchSize(int targetBatchSize); @Override long getFileSize(); @Override DateTime getEnd(); Optional<DateTime> getBegin(); @Override Stream<TimeSeriesCollection> streamReversed(); @Override Stream<TimeSeriesCollection> stream(); Stream<TimeSeriesCollection> stream(@NonNull TimeSeriesMetricFilter filter); Stream<TimeSeriesCollection> stream(@NonNull Duration stepsize, @NonNull TimeSeriesMetricFilter filter); @Override Stream<TimeSeriesCollection> stream(DateTime begin); Stream<TimeSeriesCollection> stream(@NonNull DateTime begin, @NonNull TimeSeriesMetricFilter filter); Stream<TimeSeriesCollection> stream(DateTime begin, Duration stepsize, TimeSeriesMetricFilter filter); @Override Stream<TimeSeriesCollection> stream(DateTime begin, DateTime end); Stream<TimeSeriesCollection> stream(@NonNull DateTime begin, @NonNull DateTime end, @NonNull TimeSeriesMetricFilter filter); Stream<TimeSeriesCollection> stream(DateTime begin, DateTime end, Duration stepsize, TimeSeriesMetricFilter filter); @Override Stream<Context> getContext(Duration stepsize, ExpressionLookBack lookback, TimeSeriesMetricFilter filter); @Override Stream<Context> getContext(DateTime begin, Duration stepsize, ExpressionLookBack lookback, TimeSeriesMetricFilter filter); @Override Stream<Context> getContext(DateTime begin, DateTime end, Duration stepsize, ExpressionLookBack lookback, TimeSeriesMetricFilter filter); }
InfluxHistory extends InfluxUtil implements CollectHistory, AutoCloseable { @Override public Stream<TimeSeriesCollection> stream() { return stream(TimeSeriesMetricFilter.ALL_GROUPS); } InfluxHistory(InfluxDB influxDB, String database);  InfluxHistory(InfluxDB influxDB, String database, boolean verifyDatabaseConnection); @Override void close(); @Override boolean add(@NonNull TimeSeriesCollection tsdata); @Override boolean addAll(@NonNull Collection<? extends TimeSeriesCollection> c); @Override boolean addAll(@NonNull Iterator<? extends TimeSeriesCollection> i); int getTargetBatchSize(); void setTargetBatchSize(int targetBatchSize); @Override long getFileSize(); @Override DateTime getEnd(); Optional<DateTime> getBegin(); @Override Stream<TimeSeriesCollection> streamReversed(); @Override Stream<TimeSeriesCollection> stream(); Stream<TimeSeriesCollection> stream(@NonNull TimeSeriesMetricFilter filter); Stream<TimeSeriesCollection> stream(@NonNull Duration stepsize, @NonNull TimeSeriesMetricFilter filter); @Override Stream<TimeSeriesCollection> stream(DateTime begin); Stream<TimeSeriesCollection> stream(@NonNull DateTime begin, @NonNull TimeSeriesMetricFilter filter); Stream<TimeSeriesCollection> stream(DateTime begin, Duration stepsize, TimeSeriesMetricFilter filter); @Override Stream<TimeSeriesCollection> stream(DateTime begin, DateTime end); Stream<TimeSeriesCollection> stream(@NonNull DateTime begin, @NonNull DateTime end, @NonNull TimeSeriesMetricFilter filter); Stream<TimeSeriesCollection> stream(DateTime begin, DateTime end, Duration stepsize, TimeSeriesMetricFilter filter); @Override Stream<Context> getContext(Duration stepsize, ExpressionLookBack lookback, TimeSeriesMetricFilter filter); @Override Stream<Context> getContext(DateTime begin, Duration stepsize, ExpressionLookBack lookback, TimeSeriesMetricFilter filter); @Override Stream<Context> getContext(DateTime begin, DateTime end, Duration stepsize, ExpressionLookBack lookback, TimeSeriesMetricFilter filter);  }