Package io.deephaven.engine.table.impl.select.analyzers

Class RedirectionLayer

java.lang.Object

io.deephaven.engine.table.impl.select.analyzers.SelectAndViewAnalyzer

io.deephaven.engine.table.impl.select.analyzers.RedirectionLayer

All Implemented Interfaces:

LogOutputAppendable

public final class RedirectionLayer
extends SelectAndViewAnalyzer

A layer that maintains the row redirection for future SelectColumnLayers.

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 Type	Method	Description
boolean	allowCrossColumnParallelization()	Can all of our columns permit parallel updates?
LogOutput	append(LogOutput logOutput)
void	applyUpdate(TableUpdate upstream, RowSet toClear, SelectAndViewAnalyzer.UpdateHelper helper, JobScheduler jobScheduler, @Nullable LivenessNode liveResultOwner, SelectAndViewAnalyzer.SelectLayerCompletionHandler onCompletion)	Apply this update to this SelectAndViewAnalyzer.
Map<String,Set<String>>	calcDependsOnRecurse(boolean forcePublishAllResources)
Map<String,ColumnSource<?>>	getColumnSourcesRecurse(io.deephaven.engine.table.impl.select.analyzers.SelectAndViewAnalyzer.GetMode mode)
SelectAndViewAnalyzer	getInner()
void	populateModifiedColumnSetRecurse(ModifiedColumnSet mcsBuilder, Set<String> remainingDepsToSatisfy)
void	startTrackingPrev()
void	updateColumnDefinitionsFromTopLayer(Map<String,ColumnDefinition<?>> columnDefinitions)

Methods inherited from class io.deephaven.engine.table.impl.select.analyzers.SelectAndViewAnalyzer

alreadyFlattenedSources, calcEffects, create, create, flattenedResult, futureCompletionHandler, getAllColumnSources, getNewColumnSources, getPublishedColumnSources, initializeSelectColumns, setAllNewColumns, toString

Methods inherited from class java.lang.Object

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

Method Details

populateModifiedColumnSetRecurse

public void populateModifiedColumnSetRecurse(ModifiedColumnSet mcsBuilder,
 Set<String> remainingDepsToSatisfy)

getColumnSourcesRecurse

public Map<String,ColumnSource<?>> getColumnSourcesRecurse(io.deephaven.engine.table.impl.select.analyzers.SelectAndViewAnalyzer.GetMode mode)

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 class SelectAndViewAnalyzer

Parameters:

upstream - the upstream update

toClear - rows that used to exist and no longer exist

helper - convenience class that memoizes reusable calculations for this update

jobScheduler - scheduler for parallel sub-tasks

liveResultOwner - node to be used to manage/unmanage results that happen to be liveness referents

onCompletion - Called when an inner column is complete. The outer layer should pass the onCompletion

calcDependsOnRecurse

public Map<String,Set<String>> calcDependsOnRecurse(boolean forcePublishAllResources)

getInner

public SelectAndViewAnalyzer getInner()

Specified by:

getInner in class SelectAndViewAnalyzer

updateColumnDefinitionsFromTopLayer

public void updateColumnDefinitionsFromTopLayer(Map<String,ColumnDefinition<?>> columnDefinitions)

Specified by:

updateColumnDefinitionsFromTopLayer in class SelectAndViewAnalyzer

startTrackingPrev

public void startTrackingPrev()

Specified by:

startTrackingPrev in class SelectAndViewAnalyzer

append

public LogOutput append(LogOutput logOutput)

allowCrossColumnParallelization

public boolean allowCrossColumnParallelization()

Description copied from class: SelectAndViewAnalyzer

Can all of our columns permit parallel updates?

Specified by:

allowCrossColumnParallelization in class SelectAndViewAnalyzer