Class SelectColumnLayer
java.lang.Object
io.deephaven.engine.table.impl.select.analyzers.SelectAndViewAnalyzer
io.deephaven.engine.table.impl.select.analyzers.DependencyLayerBase
io.deephaven.engine.table.impl.select.analyzers.SelectOrViewColumnLayer
io.deephaven.engine.table.impl.select.analyzers.SelectColumnLayer
- All Implemented Interfaces:
LogOutputAppendable
-
Nested Class Summary
Nested classes/interfaces inherited from class io.deephaven.engine.table.impl.select.analyzers.SelectAndViewAnalyzer
SelectAndViewAnalyzer.Mode, SelectAndViewAnalyzer.SelectLayerCompletionHandler, SelectAndViewAnalyzer.UpdateHelper
-
Method Summary
Modifier and TypeMethodDescriptionboolean
Can all of our columns permit parallel updates?boolean
Have the column sources already been flattened? Only the STATIC_SELECT case flattens the result.void
applyUpdate
(TableUpdate upstream, RowSet toClear, SelectAndViewAnalyzer.UpdateHelper helper, JobScheduler jobScheduler, @Nullable LivenessNode liveResultOwner, SelectAndViewAnalyzer.SelectLayerCompletionHandler onCompletion) Apply this update to this SelectAndViewAnalyzer.boolean
Was the result internally flattened? Only the STATIC_SELECT case flattens the result.Methods inherited from class io.deephaven.engine.table.impl.select.analyzers.SelectOrViewColumnLayer
startTrackingPrev
Methods inherited from class io.deephaven.engine.table.impl.select.analyzers.DependencyLayerBase
getInner, updateColumnDefinitionsFromTopLayer
Methods inherited from class io.deephaven.engine.table.impl.select.analyzers.SelectAndViewAnalyzer
calcEffects, create, create, futureCompletionHandler, getAllColumnSources, getNewColumnSources, getPublishedColumnSources, initializeSelectColumns, setAllNewColumns, toString
-
Method Details
-
applyUpdate
public void applyUpdate(TableUpdate upstream, RowSet toClear, SelectAndViewAnalyzer.UpdateHelper helper, JobScheduler jobScheduler, @Nullable @Nullable LivenessNode liveResultOwner, SelectAndViewAnalyzer.SelectLayerCompletionHandler onCompletion) Description copied from class:SelectAndViewAnalyzer
Apply this update to this SelectAndViewAnalyzer.- Specified by:
applyUpdate
in classSelectAndViewAnalyzer
- Parameters:
upstream
- the upstream updatetoClear
- rows that used to exist and no longer existhelper
- convenience class that memoizes reusable calculations for this updatejobScheduler
- scheduler for parallel sub-tasksliveResultOwner
-node
to be used to manage/unmanage results that happen to beliveness referents
onCompletion
- Called when an inner column is complete. The outer layer should pass theonCompletion
-
flattenedResult
public boolean flattenedResult()Description copied from class:SelectAndViewAnalyzer
Was the result internally flattened? Only the STATIC_SELECT case flattens the result. If the result preserves any columns, then flattening is not permitted. Because all the other layers cannot internally flatten, the default implementation returns false.- Overrides:
flattenedResult
in classSelectAndViewAnalyzer
-
alreadyFlattenedSources
public boolean alreadyFlattenedSources()Description copied from class:SelectAndViewAnalyzer
Have the column sources already been flattened? Only the STATIC_SELECT case flattens the result. A static flatten layer is only added if SelectColumn depends on an intermediate result.- Overrides:
alreadyFlattenedSources
in classSelectAndViewAnalyzer
-
append
-
allowCrossColumnParallelization
public boolean allowCrossColumnParallelization()Description copied from class:SelectAndViewAnalyzer
Can all of our columns permit parallel updates?- Specified by:
allowCrossColumnParallelization
in classSelectAndViewAnalyzer
-