Class SelectAndViewAnalyzer
java.lang.Object
io.deephaven.engine.table.impl.select.analyzers.SelectAndViewAnalyzer
- All Implemented Interfaces:
LogOutputAppendable
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic final class
static enum
static enum
static class
-
Method Summary
Modifier and TypeMethodDescriptionboolean
Can all of our columns permit parallel updates?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.createContext
(QueryTable parentTable, SelectAndViewAnalyzer.Mode mode, boolean publishParentSources, boolean useShiftedColumns, SelectColumn... selectColumns) boolean
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
toString()
-
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 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
onSuccess
- called when the update completed successfullyonError
- called when the update failed
-
startTrackingPrev
public void startTrackingPrev() -
flatResult
public boolean flatResult()Is the result of this select/view flat? -
allowCrossColumnParallelization
public boolean allowCrossColumnParallelization()Can all of our columns permit parallel updates? -
append
- Specified by:
append
in interfaceLogOutputAppendable
-
toString
-