Interface ChunkedUpdateByStateManager
- All Known Implementing Classes:
AddOnlyUpdateByStateManager
,IncrementalUpdateByStateManager
public interface ChunkedUpdateByStateManager
The basis for operators that participate in an updateBy operation.
-
Method Summary
Modifier and Type Method Description void
add(SafeCloseable bc, OrderedKeys orderedKeys, ColumnSource<?>[] sources, org.apache.commons.lang3.mutable.MutableInt nextOutputPosition, WritableIntChunk<Attributes.KeyIndices> outputPositions)
default void
findModifications(SafeCloseable pc, OrderedKeys modifiedIndex, ColumnSource<?>[] keySources, WritableIntChunk<Attributes.KeyIndices> outputPositions)
SafeCloseable
makeUpdateByBuildContext(ColumnSource<?>[] keySources, long updateSize)
default SafeCloseable
makeUpdateByProbeContext(ColumnSource<?>[] buildSources, long maxSize)
default void
remove(SafeCloseable pc, OrderedKeys indexToRemove, ColumnSource<?>[] sources, WritableIntChunk<Attributes.KeyIndices> outputPositions)
-
Method Details
-
add
void add(SafeCloseable bc, OrderedKeys orderedKeys, ColumnSource<?>[] sources, org.apache.commons.lang3.mutable.MutableInt nextOutputPosition, WritableIntChunk<Attributes.KeyIndices> outputPositions) -
remove
default void remove(@NotNull SafeCloseable pc, @NotNull OrderedKeys indexToRemove, @NotNull ColumnSource<?>[] sources, @NotNull WritableIntChunk<Attributes.KeyIndices> outputPositions) -
findModifications
default void findModifications(@NotNull SafeCloseable pc, @NotNull OrderedKeys modifiedIndex, @NotNull ColumnSource<?>[] keySources, @NotNull WritableIntChunk<Attributes.KeyIndices> outputPositions) -
makeUpdateByBuildContext
-
makeUpdateByProbeContext
-