ATEST-316
This commit is contained in:
@ -35,7 +35,7 @@ import ch.psi.daq.domain.cassandra.query.TimeRangeQuery;
|
|||||||
import ch.psi.daq.domain.cassandra.querying.ChannelEventQuery;
|
import ch.psi.daq.domain.cassandra.querying.ChannelEventQuery;
|
||||||
import ch.psi.daq.domain.cassandra.querying.EventQuery;
|
import ch.psi.daq.domain.cassandra.querying.EventQuery;
|
||||||
import ch.psi.daq.domain.cassandra.querying.MetaChannelEvent;
|
import ch.psi.daq.domain.cassandra.querying.MetaChannelEvent;
|
||||||
import ch.psi.daq.domain.cassandra.utils.TablePropertiesUtils;
|
import ch.psi.daq.domain.cassandra.utils.PropertiesUtils;
|
||||||
import ch.psi.daq.domain.reader.Backend;
|
import ch.psi.daq.domain.reader.Backend;
|
||||||
|
|
||||||
public class DummyCassandraReader implements CassandraReader {
|
public class DummyCassandraReader implements CassandraReader {
|
||||||
@ -158,14 +158,14 @@ public class DummyCassandraReader implements CassandraReader {
|
|||||||
BigDecimal iocTime =
|
BigDecimal iocTime =
|
||||||
(columns == null || columns.length == 0 || ArrayUtils.contains(columns,
|
(columns == null || columns.length == 0 || ArrayUtils.contains(columns,
|
||||||
FieldNames.FIELD_IOC_TIME)) ? TimeUtils.getTimeFromMillis(i * 10, 0)
|
FieldNames.FIELD_IOC_TIME)) ? TimeUtils.getTimeFromMillis(i * 10, 0)
|
||||||
: TablePropertiesUtils.DEFAULT_VALUE_DECIMAL;
|
: PropertiesUtils.DEFAULT_VALUE_DECIMAL;
|
||||||
BigDecimal globalTime =
|
BigDecimal globalTime =
|
||||||
(columns == null || columns.length == 0 || ArrayUtils.contains(columns,
|
(columns == null || columns.length == 0 || ArrayUtils.contains(columns,
|
||||||
FieldNames.FIELD_GLOBAL_TIME)) ? TimeUtils.getTimeFromMillis(i * 10, 0)
|
FieldNames.FIELD_GLOBAL_TIME)) ? TimeUtils.getTimeFromMillis(i * 10, 0)
|
||||||
: TablePropertiesUtils.DEFAULT_VALUE_DECIMAL;
|
: PropertiesUtils.DEFAULT_VALUE_DECIMAL;
|
||||||
long pulseId =
|
long pulseId =
|
||||||
(columns == null || columns.length == 0 || ArrayUtils.contains(columns,
|
(columns == null || columns.length == 0 || ArrayUtils.contains(columns,
|
||||||
FieldNames.FIELD_PULSE_ID)) ? i : TablePropertiesUtils.DEFAULT_VALUE_BIGINT_PRIMITIVE;
|
FieldNames.FIELD_PULSE_ID)) ? i : PropertiesUtils.DEFAULT_VALUE_BIGINT_PRIMITIVE;
|
||||||
|
|
||||||
if (channelLower.contains("waveform")) {
|
if (channelLower.contains("waveform")) {
|
||||||
long[] value = random.longs(2048).toArray();
|
long[] value = random.longs(2048).toArray();
|
||||||
|
Reference in New Issue
Block a user