ATEST-304 ChannelEvent with Statistics
This commit is contained in:
@ -89,7 +89,7 @@ public class DummyCassandraReader implements CassandraReader {
|
||||
*/
|
||||
@Override
|
||||
public Stream<? extends DataEvent> getEventStream(String channel, long startPulseId, long endPulseId,
|
||||
Ordering ordering, String... columns) {
|
||||
Ordering ordering, boolean aggregateValues, String... columns) {
|
||||
return getDummyEventStream(channel, startPulseId, endPulseId);
|
||||
}
|
||||
|
||||
@ -98,7 +98,7 @@ public class DummyCassandraReader implements CassandraReader {
|
||||
*/
|
||||
@Override
|
||||
public Stream<? extends DataEvent> getEventStream(String channel, long startMillis, long startNanos, long endMillis,
|
||||
long endNanos, Ordering ordering, String... columns) {
|
||||
long endNanos, Ordering ordering, boolean aggregateValues, String... columns) {
|
||||
return getDummyEventStream(channel, startMillis / 10, endMillis / 10);
|
||||
}
|
||||
|
||||
|
@ -35,13 +35,13 @@ public class DummyDataReader implements DataReader {
|
||||
|
||||
@Override
|
||||
public Stream<? extends DataEvent> getEventStream(String channel, long startPulseId, long endPulseId,
|
||||
Ordering ordering, String... columns) {
|
||||
Ordering ordering, boolean aggregateValues, String... columns) {
|
||||
return getElements(channel, startPulseId, endPulseId);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Stream<? extends DataEvent> getEventStream(String channel, long startMillis, long startNanos, long endMillis,
|
||||
long endNanos, Ordering ordering, String... columns) {
|
||||
long endNanos, Ordering ordering, boolean aggregateValues, String... columns) {
|
||||
return getElements(channel, startMillis / 10, endMillis / 10);
|
||||
}
|
||||
|
||||
|
Reference in New Issue
Block a user