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

Class BaseLayer

java.lang.Object

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

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

All Implemented Interfaces:

LogOutputAppendable

public class BaseLayer
extends SelectAndViewAnalyzer

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.
SelectAndViewAnalyzer	getInner()
void	setAllNewColumns(BitSet bitset)	Set the bits in bitset that represent all the new columns.
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, toString

Methods inherited from class java.lang.Object

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

Method Details

setAllNewColumns

public void setAllNewColumns(BitSet bitset)

Description copied from class: SelectAndViewAnalyzer

Set the bits in bitset that represent all the new columns. This is used to identify when the select or update operation is complete.

Overrides:

setAllNewColumns in class SelectAndViewAnalyzer

Parameters:

bitset - the bitset to manipulate.

updateColumnDefinitionsFromTopLayer

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

Specified by:

updateColumnDefinitionsFromTopLayer in class SelectAndViewAnalyzer

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

getInner

public SelectAndViewAnalyzer getInner()

Specified by:

getInner 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