Package io.deephaven.engine.table.impl.updateby.hashing

Class UpdateByStateManager

java.lang.Object

io.deephaven.engine.table.impl.updateby.hashing.UpdateByStateManager

Direct Known Subclasses:

UpdateByStateManagerTypedBase

public abstract class UpdateByStateManager
extends Object

The basis for operators that participate in an updateBy operation.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ColumnSource<?>[]	keySourcesForErrorMessages

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	UpdateByStateManager(ColumnSource<?>[] keySourcesForErrorMessages)

Method Summary

Modifier and Type	Method	Description
abstract void	add(boolean initialBuild, SafeCloseable bc, RowSequence orderedKeys, ColumnSource<?>[] sources, MutableInt nextOutputPosition, WritableIntChunk<RowKeys> outputPositions)
protected String	extractKeyStringFromSourceTable(long leftKey)
void	findModifications(@NotNull SafeCloseable pc, @NotNull RowSequence modifiedIndex, @NotNull ColumnSource<?>[] keySources, @NotNull WritableIntChunk<RowKeys> outputPositions)
abstract SafeCloseable	makeUpdateByBuildContext(ColumnSource<?>[] keySources, long updateSize)
SafeCloseable	makeUpdateByProbeContext(ColumnSource<?>[] buildSources, long maxSize)
void	remove(@NotNull SafeCloseable pc, @NotNull RowSequence indexToRemove, @NotNull ColumnSource<?>[] sources, @NotNull WritableIntChunk<RowKeys> outputPositions)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

keySourcesForErrorMessages

protected final ColumnSource<?>[] keySourcesForErrorMessages

Constructor Details

UpdateByStateManager

protected UpdateByStateManager(ColumnSource<?>[] keySourcesForErrorMessages)

Method Details

extractKeyStringFromSourceTable

protected String extractKeyStringFromSourceTable(long leftKey)

add

public abstract void add(boolean initialBuild,
 SafeCloseable bc,
 RowSequence orderedKeys,
 ColumnSource<?>[] sources,
 MutableInt nextOutputPosition,
 WritableIntChunk<RowKeys> outputPositions)

remove

public void remove(@NotNull
 @NotNull SafeCloseable pc,
 @NotNull
 @NotNull RowSequence indexToRemove,
 @NotNull
 @NotNull ColumnSource<?>[] sources,
 @NotNull
 @NotNull WritableIntChunk<RowKeys> outputPositions)

findModifications

public void findModifications(@NotNull
 @NotNull SafeCloseable pc,
 @NotNull
 @NotNull RowSequence modifiedIndex,
 @NotNull
 @NotNull ColumnSource<?>[] keySources,
 @NotNull
 @NotNull WritableIntChunk<RowKeys> outputPositions)

makeUpdateByBuildContext

public abstract SafeCloseable makeUpdateByBuildContext(ColumnSource<?>[] keySources,
 long updateSize)

makeUpdateByProbeContext

public SafeCloseable makeUpdateByProbeContext(ColumnSource<?>[] buildSources,
 long maxSize)