Class ImmutableConstantNanosBasedTimeSource<TIME_TYPE>
java.lang.Object
io.deephaven.engine.table.impl.AbstractColumnSource<TIME_TYPE>
io.deephaven.engine.table.impl.sources.immutable.ImmutableConstantNanosBasedTimeSource<TIME_TYPE>
- All Implemented Interfaces:
ChunkSource<Values>
,ChunkSource.WithPrev<Values>
,ColumnSource<TIME_TYPE>
,ElementSource<TIME_TYPE>
,FillContextMaker
,GetContextMaker
,DefaultChunkSource<Values>
,DefaultChunkSource.WithPrev<Values>
,ConvertibleTimeSource
,FillUnordered<Values>
,InMemoryColumnSource
,RowKeyAgnosticChunkSource<Values>
,Releasable
,TupleExporter<TIME_TYPE>
,TupleSource<TIME_TYPE>
- Direct Known Subclasses:
ImmutableConstantInstantSource
,ImmutableConstantZonedDateTimeSource
public abstract class ImmutableConstantNanosBasedTimeSource<TIME_TYPE>
extends AbstractColumnSource<TIME_TYPE>
implements InMemoryColumnSource, RowKeyAgnosticChunkSource<Values>, ConvertibleTimeSource
-
Nested Class Summary
Nested classes/interfaces inherited from class io.deephaven.engine.table.impl.AbstractColumnSource
AbstractColumnSource.DefaultedImmutable<DATA_TYPE>, AbstractColumnSource.DefaultedMutable<DATA_TYPE>
Nested classes/interfaces inherited from interface io.deephaven.engine.table.ChunkSource
ChunkSource.FillContext, ChunkSource.GetContext, ChunkSource.WithPrev<ATTR extends Any>
Nested classes/interfaces inherited from interface io.deephaven.engine.table.impl.sources.ConvertibleTimeSource
ConvertibleTimeSource.Zoned
Nested classes/interfaces inherited from interface io.deephaven.engine.table.impl.DefaultChunkSource
DefaultChunkSource.SupportsContiguousGet<ATTR extends Any>, DefaultChunkSource.WithPrev<ATTR extends Any>
Nested classes/interfaces inherited from interface io.deephaven.engine.table.TupleExporter
TupleExporter.ExportElementFunction<TUPLE_TYPE>
-
Field Summary
Fields inherited from class io.deephaven.engine.table.impl.AbstractColumnSource
componentType, type, updateGraph, USE_RANGES_AVERAGE_RUN_LENGTH
Fields inherited from interface io.deephaven.engine.table.ChunkSource
DEFAULT_FILL_INSTANCE, ZERO_LENGTH_CHUNK_SOURCE_ARRAY
Fields inherited from interface io.deephaven.engine.table.ChunkSource.WithPrev
ZERO_LENGTH_CHUNK_SOURCE_WITH_PREV_ARRAY
Fields inherited from interface io.deephaven.engine.table.ColumnSource
ZERO_LENGTH_COLUMN_SOURCE_ARRAY
Fields inherited from interface io.deephaven.engine.table.impl.sources.InMemoryColumnSource
TWO_DIMENSIONAL_COLUMN_SOURCE_THRESHOLD
-
Constructor Summary
ConstructorDescriptionImmutableConstantNanosBasedTimeSource
(@NotNull Class<TIME_TYPE> type, ImmutableConstantLongSource nanoSource) -
Method Summary
Modifier and TypeMethodDescription<ALTERNATE_DATA_TYPE>
booleanallowsReinterpret
(@NotNull Class<ALTERNATE_DATA_TYPE> alternateDataType) Test if a reinterpret call will succeed.protected <ALTERNATE_DATA_TYPE>
ColumnSource<ALTERNATE_DATA_TYPE>doReinterpret
(@NotNull Class<ALTERNATE_DATA_TYPE> alternateDataType) Supply allowed reinterpret results.final void
fillChunk
(@NotNull ChunkSource.FillContext context, @NotNull WritableChunk<? super Values> destination, @NotNull RowSequence rowSequence) Populates the given destination chunk with data corresponding to the keys from the givenRowSequence
.void
fillChunkUnordered
(@NotNull ChunkSource.FillContext context, @NotNull WritableChunk<? super Values> dest, @NotNull LongChunk<? extends RowKeys> keys) Populates a contiguous portion of the given destination chunk with data corresponding to the keys from the givenLongChunk
.final void
fillPrevChunk
(@NotNull ChunkSource.FillContext context, @NotNull WritableChunk<? super Values> destination, @NotNull RowSequence rowSequence) Populates the given destination chunk with data corresponding to the keys from the givenRowSequence
.void
fillPrevChunkUnordered
(@NotNull ChunkSource.FillContext context, @NotNull WritableChunk<? super Values> dest, @NotNull LongChunk<? extends RowKeys> keys) Populates a contiguous portion of the given destination chunk with prev data corresponding to the keys from the givenLongChunk
.get
(long rowKey) Get the value from the source.long
getLong
(long rowKey) Get the value at the rowKey as a long.getPrev
(long rowKey) Get the previous value at the rowKey.long
getPrevLong
(long rowKey) Get the previous value at the rowKey as a long.protected abstract TIME_TYPE
makeValue
(long nanos) boolean
Returns true if this column source can efficiently provide an unordered fill.boolean
Check if this class supports time conversion.Convert this source to along
source of nanoseconds of epoch.Convert this source to anInstant
source.toLocalDate
(@NotNull ZoneId zone) toLocalTime
(@NotNull ZoneId zone) protected abstract long
toZonedDateTime
(@NotNull ZoneId zone) Convert this source to aZonedDateTime
source at the specifiedzone
.Methods inherited from class io.deephaven.engine.table.impl.AbstractColumnSource
defaultFillChunk, defaultFillPrevChunk, getComponentType, getPrevSource, getType, match, reinterpret
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.deephaven.engine.table.ColumnSource
cast, cast, cast, cast, createPreviousTuple, createTuple, createTupleFromValues, exportAllTo, exportElement, exportElement, getChunkType, isImmutable, isStateless, releaseCachedResources, startTrackingPrevValues, tupleLength
Methods inherited from interface io.deephaven.engine.table.impl.DefaultChunkSource
getChunk, getChunk, getChunkByFilling, makeFillContext, makeGetContext
Methods inherited from interface io.deephaven.engine.table.impl.DefaultChunkSource.WithPrev
getPrevChunk, getPrevChunk, getPrevChunkByFilling
Methods inherited from interface io.deephaven.engine.table.ElementSource
getBoolean, getByte, getChar, getDouble, getFloat, getInt, getPrevBoolean, getPrevByte, getPrevChar, getPrevDouble, getPrevFloat, getPrevInt, getPrevShort, getShort
Methods inherited from interface io.deephaven.engine.table.FillContextMaker
makeFillContext
Methods inherited from interface io.deephaven.engine.table.GetContextMaker
makeGetContext
Methods inherited from interface io.deephaven.engine.table.impl.sources.InMemoryColumnSource
isInMemory
Methods inherited from interface io.deephaven.engine.table.TupleExporter
exportAllReinterpretedTo, exportAllReinterpretedTo, exportAllTo, exportElementReinterpreted
Methods inherited from interface io.deephaven.engine.table.TupleSource
createTupleFromReinterpretedValues
-
Field Details
-
nanoSource
-
-
Constructor Details
-
ImmutableConstantNanosBasedTimeSource
public ImmutableConstantNanosBasedTimeSource(@NotNull @NotNull Class<TIME_TYPE> type, ImmutableConstantLongSource nanoSource)
-
-
Method Details
-
makeValue
-
toNanos
-
get
Description copied from interface:ElementSource
Get the value from the source. This may return boxed values for basic types. RowKeys that are not present are undefined.- Specified by:
get
in interfaceElementSource<TIME_TYPE>
- Parameters:
rowKey
- the location in key space to get the value from.- Returns:
- the value at the rowKey, potentially null.
-
getPrev
Description copied from interface:ElementSource
Get the previous value at the rowKey. Previous values are used during anUG
update
cycle to process changes in data. Duringnormal
operation previous values will be identical tocurrent
values. RowKeys that were not present are undefined.- Specified by:
getPrev
in interfaceElementSource<TIME_TYPE>
- Parameters:
rowKey
- the location in key space to get the value from.- Returns:
- the previous value at the rowKey, potentially null.
-
getLong
public long getLong(long rowKey) Description copied from interface:ElementSource
Get the value at the rowKey as a long. RowKeys that are not present are undefined.- Specified by:
getLong
in interfaceElementSource<TIME_TYPE>
- Parameters:
rowKey
- the location in key space to get the value from.- Returns:
- the long at the rowKey, null values are represented by
QueryConstants.NULL_LONG
-
getPrevLong
public long getPrevLong(long rowKey) Description copied from interface:ElementSource
Get the previous value at the rowKey as a long. SeeElementSource.getPrev(long)
for more details.- Specified by:
getPrevLong
in interfaceElementSource<TIME_TYPE>
- Parameters:
rowKey
- the location in key space to get the previous value from.- Returns:
- the previous long at the rowKey, null values are represented by
QueryConstants.NULL_LONG
-
fillChunk
public final void fillChunk(@NotNull @NotNull ChunkSource.FillContext context, @NotNull @NotNull WritableChunk<? super Values> destination, @NotNull @NotNull RowSequence rowSequence) Description copied from interface:ChunkSource
Populates the given destination chunk with data corresponding to the keys from the givenRowSequence
.- Specified by:
fillChunk
in interfaceChunkSource<TIME_TYPE>
- Overrides:
fillChunk
in classAbstractColumnSource<TIME_TYPE>
- Parameters:
context
- A context containing all mutable/state related data used in retrieving the Chunk.destination
- The chunk to be populated according torowSequence
. No assumptions shall be made about the size of the chunk shall be made. The chunk will be populated from position [0,rowSequence.size()).rowSequence
- AnRowSequence
representing the keys to be fetched
-
fillPrevChunk
public final void fillPrevChunk(@NotNull @NotNull ChunkSource.FillContext context, @NotNull @NotNull WritableChunk<? super Values> destination, @NotNull @NotNull RowSequence rowSequence) Description copied from interface:ChunkSource.WithPrev
Populates the given destination chunk with data corresponding to the keys from the givenRowSequence
.- Specified by:
fillPrevChunk
in interfaceChunkSource.WithPrev<TIME_TYPE>
- Overrides:
fillPrevChunk
in classAbstractColumnSource<TIME_TYPE>
- Parameters:
context
- A context containing all mutable/state related data used in retrieving the Chunk.destination
- The chunk to be populated according torowSequence
. No assumptions shall be made about the size of the chunk shall be made. The chunk will be populated from position [0,rowSequence.size()).rowSequence
- AnRowSequence
representing the keys to be fetched
-
fillChunkUnordered
public void fillChunkUnordered(@NotNull @NotNull ChunkSource.FillContext context, @NotNull @NotNull WritableChunk<? super Values> dest, @NotNull @NotNull LongChunk<? extends RowKeys> keys) Description copied from interface:FillUnordered
Populates a contiguous portion of the given destination chunk with data corresponding to the keys from the givenLongChunk
.It behaves as if the following code were executed:
destination.setSize(keys.size()); for (int ii = 0; ii < keys.size(); ++ii) { destination.set(ii, get(keys.get(ii))); }
- Specified by:
fillChunkUnordered
in interfaceFillUnordered<TIME_TYPE>
- Parameters:
context
- A context containing all mutable/state related data used in retrieving the Chunk.dest
- The chunk to be populated according tokeys
keys
- A chunk of individual, not assumed to be ordered keys to be fetched
-
fillPrevChunkUnordered
public void fillPrevChunkUnordered(@NotNull @NotNull ChunkSource.FillContext context, @NotNull @NotNull WritableChunk<? super Values> dest, @NotNull @NotNull LongChunk<? extends RowKeys> keys) Description copied from interface:FillUnordered
Populates a contiguous portion of the given destination chunk with prev data corresponding to the keys from the givenLongChunk
.It behaves as if the following code were executed:
destination.setSize(keys.size()); for (int ii = 0; ii < keys.size(); ++ii) { destination.set(ii, getPrev(keys.get(ii))); }
- Specified by:
fillPrevChunkUnordered
in interfaceFillUnordered<TIME_TYPE>
- Parameters:
context
- A context containing all mutable/state related data used in retrieving the Chunk.dest
- The chunk to be populated according tokeys
keys
- A chunk of individual, not assumed to be ordered keys to be fetched
-
providesFillUnordered
public boolean providesFillUnordered()Description copied from interface:FillUnordered
Returns true if this column source can efficiently provide an unordered fill. If this method returns false, then fillChunkUnordered and fillPrevChunkUnordered may throw an UnsupportedOperationException.- Specified by:
providesFillUnordered
in interfaceFillUnordered<TIME_TYPE>
- Returns:
- if this column source can provide an unordered fill
-
allowsReinterpret
public <ALTERNATE_DATA_TYPE> boolean allowsReinterpret(@NotNull @NotNull Class<ALTERNATE_DATA_TYPE> alternateDataType) Description copied from interface:ColumnSource
Test if a reinterpret call will succeed.- Specified by:
allowsReinterpret
in interfaceColumnSource<TIME_TYPE>
- Overrides:
allowsReinterpret
in classAbstractColumnSource<TIME_TYPE>
- Parameters:
alternateDataType
- The alternative type to consider- Returns:
- If a reinterpret on this column source with the supplied alternateDataType will succeed.
-
doReinterpret
protected <ALTERNATE_DATA_TYPE> ColumnSource<ALTERNATE_DATA_TYPE> doReinterpret(@NotNull @NotNull Class<ALTERNATE_DATA_TYPE> alternateDataType) Description copied from class:AbstractColumnSource
Supply allowed reinterpret results. The default implementation handles the most common case to avoid code duplication.- Overrides:
doReinterpret
in classAbstractColumnSource<TIME_TYPE>
- Parameters:
alternateDataType
- The alternate data type- Returns:
- The resulting
ColumnSource
-
supportsTimeConversion
public boolean supportsTimeConversion()Description copied from interface:ConvertibleTimeSource
Check if this class supports time conversion. If false, all other methods will fail.- Specified by:
supportsTimeConversion
in interfaceConvertibleTimeSource
- Returns:
- true if time conversion is supported.
-
toZonedDateTime
Description copied from interface:ConvertibleTimeSource
Convert this source to aZonedDateTime
source at the specifiedzone
.- Specified by:
toZonedDateTime
in interfaceConvertibleTimeSource
- Parameters:
zone
- the time zone- Returns:
- a view of this source as a
ZonedDateTime
-
toLocalDate
Description copied from interface:ConvertibleTimeSource
- Specified by:
toLocalDate
in interfaceConvertibleTimeSource
- Parameters:
zone
- the time zone- Returns:
- a view of this source as a
LocalDate
-
toLocalTime
Description copied from interface:ConvertibleTimeSource
- Specified by:
toLocalTime
in interfaceConvertibleTimeSource
- Parameters:
zone
- the time zone- Returns:
- a view of this source as a
LocalTime
-
toInstant
Description copied from interface:ConvertibleTimeSource
Convert this source to anInstant
source.- Specified by:
toInstant
in interfaceConvertibleTimeSource
- Returns:
- a view of this source asan
Instant
-
toEpochNano
Description copied from interface:ConvertibleTimeSource
Convert this source to along
source of nanoseconds of epoch.- Specified by:
toEpochNano
in interfaceConvertibleTimeSource
- Returns:
- a view of this source as a
ZonedDateTime
-