Interface RowKeyAgnosticChunkSource<ATTR extends Any>
- All Superinterfaces:
FillUnordered<ATTR>
- All Known Implementing Classes:
BooleanSingleValueSource,ByteSingleValueSource,CharacterSingleValueSource,DoubleSingleValueSource,FloatSingleValueSource,ImmutableConstantByteSource,ImmutableConstantCharSource,ImmutableConstantDoubleSource,ImmutableConstantFloatSource,ImmutableConstantInstantSource,ImmutableConstantIntSource,ImmutableConstantLongSource,ImmutableConstantNanosBasedTimeSource,ImmutableConstantObjectSource,ImmutableConstantShortSource,ImmutableConstantZonedDateTimeSource,IntegerSingleValueSource,LongSingleValueSource,NullValueColumnSource,ObjectSingleValueSource,ShortSingleValueSource,SingleValueColumnSource
This is a marker interface for chunk sources that are agnostic of the row key when evaluating the value for a given
row key.
-
Method Summary
Static MethodsModifier and TypeMethodDescriptionstatic voidestimatePushdownFilterCostHelper(WhereFilter filter, RowSet selection, boolean usePrev, PushdownFilterContext context, JobScheduler jobScheduler, LongConsumer onComplete, Consumer<Exception> onError) static voidpushdownFilterHelper(ColumnSource<?> columnSource, WhereFilter filter, RowSet selection, boolean usePrev, PushdownFilterContext context, long costCeiling, JobScheduler jobScheduler, Consumer<PushdownResult> onComplete, Consumer<Exception> onError) Methods inherited from interface io.deephaven.engine.table.impl.sources.FillUnordered
fillChunkUnordered, fillPrevChunkUnordered, providesFillUnordered
-
Method Details
-
estimatePushdownFilterCostHelper
static void estimatePushdownFilterCostHelper(WhereFilter filter, RowSet selection, boolean usePrev, PushdownFilterContext context, JobScheduler jobScheduler, LongConsumer onComplete, Consumer<Exception> onError) -
pushdownFilterHelper
static void pushdownFilterHelper(ColumnSource<?> columnSource, WhereFilter filter, RowSet selection, boolean usePrev, PushdownFilterContext context, long costCeiling, JobScheduler jobScheduler, Consumer<PushdownResult> onComplete, Consumer<Exception> onError)
-