diff --git a/src/test/java/ch/psi/daq/test/queryrest/query/DummyCassandraReader.java b/src/test/java/ch/psi/daq/test/queryrest/query/DummyCassandraReader.java index 2eba817..7966d29 100644 --- a/src/test/java/ch/psi/daq/test/queryrest/query/DummyCassandraReader.java +++ b/src/test/java/ch/psi/daq/test/queryrest/query/DummyCassandraReader.java @@ -20,10 +20,10 @@ import ch.psi.daq.domain.DataEvent; import ch.psi.daq.domain.cassandra.ChannelEvent; import ch.psi.daq.domain.cassandra.MetaPulseId; import ch.psi.daq.domain.cassandra.MetaTime; -import ch.psi.daq.domain.cassandra.ValueForm; import ch.psi.daq.domain.cassandra.querying.ChannelEventQuery; import ch.psi.daq.domain.cassandra.querying.ChannelEventQueryInfo; import ch.psi.daq.domain.cassandra.querying.EventQuery; +import ch.psi.data.converters.ConverterProvider; import com.google.common.collect.Lists; @@ -205,7 +205,8 @@ public class DummyCassandraReader implements CassandraReader { return dataGen.generateMetaPulseId( KEYSPACE, - ValueForm.scalar, + ConverterProvider.TYPE_INT32, + null, query.getStartPulseId(), (query.getEndPulseId() - query.getStartPulseId() + 1), i -> i, @@ -223,7 +224,8 @@ public class DummyCassandraReader implements CassandraReader { return dataGen.generateMetaTime( KEYSPACE, - ValueForm.scalar, + ConverterProvider.TYPE_INT32, + null, query.getStartMillis(), (query.getEndMillis() - query.getStartMillis() + 1), i -> i,