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

Class SelectAndViewAnalyzer

java.lang.Object

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

All Implemented Interfaces:

LogOutputAppendable

public class SelectAndViewAnalyzer
extends Object
implements LogOutputAppendable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	SelectAndViewAnalyzer.AnalyzerContext
static enum	SelectAndViewAnalyzer.Mode
static enum	SelectAndViewAnalyzer.UpdateFlavor
static class	SelectAndViewAnalyzer.UpdateHelper

Method Summary

Modifier and Type	Method	Description
boolean	anyParallelColumns()	Are any of our columns parallel? If so, then we should use the parallel job scheduler (but individual columns may be evaluated all at once).
LogOutput	append(LogOutput logOutput)
void	applyUpdate(TableUpdate upstream, RowSet toClear, SelectAndViewAnalyzer.UpdateHelper helper, JobScheduler jobScheduler, @Nullable LivenessNode liveResultOwner, Runnable onSuccess, Consumer<Exception> onError)	Apply this update to this SelectAndViewAnalyzer.
static SelectAndViewAnalyzer.AnalyzerContext	createContext(QueryTable parentTable, SelectAndViewAnalyzer.Mode mode, boolean publishParentSources, boolean useShiftedColumns, SelectColumn... selectColumns)
boolean	flatResult()	Is the result of this select/view flat?
static void	initializeSelectColumns(Map<String,ColumnDefinition<?>> parentColumnMap, SelectColumn[] selectColumns)
static void	initializeSelectColumns(Map<String,ColumnDefinition<?>> parentColumnMap, SelectColumn[] selectColumns, QueryCompilerRequestProcessor compilationProcessor)
void	startTrackingPrev()
String	toString()

Methods inherited from class java.lang.Object

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

Method Details

initializeSelectColumns

public static void initializeSelectColumns(Map<String,ColumnDefinition<?>> parentColumnMap,
 SelectColumn[] selectColumns)

initializeSelectColumns

public static void initializeSelectColumns(Map<String,ColumnDefinition<?>> parentColumnMap,
 SelectColumn[] selectColumns,
 QueryCompilerRequestProcessor compilationProcessor)

createContext

public static SelectAndViewAnalyzer.AnalyzerContext createContext(QueryTable parentTable,
 SelectAndViewAnalyzer.Mode mode,
 boolean publishParentSources,
 boolean useShiftedColumns,
 SelectColumn... selectColumns)

applyUpdate

public void applyUpdate(TableUpdate upstream,
 RowSet toClear,
 SelectAndViewAnalyzer.UpdateHelper helper,
 JobScheduler jobScheduler,
 @Nullable
 @Nullable LivenessNode liveResultOwner,
 Runnable onSuccess,
 Consumer<Exception> onError)

Apply this update to this 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

onSuccess - called when the update completed successfully

onError - called when the update failed

startTrackingPrev

public void startTrackingPrev()

flatResult

public boolean flatResult()

Is the result of this select/view flat?

anyParallelColumns

public boolean anyParallelColumns()

Are any of our columns parallel? If so, then we should use the parallel job scheduler (but individual columns may be evaluated all at once).

append

public LogOutput append(LogOutput logOutput)

Specified by:

append in interface LogOutputAppendable

toString

public String toString()

Overrides:

toString in class Object