@Internal public abstract class AbstractStreamTableEnvironmentImpl extends TableEnvironmentImpl
StreamTableEnvironment
.Modifier and Type | Field and Description |
---|---|
protected StreamExecutionEnvironment |
executionEnvironment |
execEnv, functionCatalog, planner, resourceManager, tableConfig
Constructor and Description |
---|
AbstractStreamTableEnvironmentImpl(CatalogManager catalogManager,
ModuleManager moduleManager,
ResourceManager resourceManager,
TableConfig tableConfig,
Executor executor,
FunctionCatalog functionCatalog,
Planner planner,
boolean isStreamingMode,
StreamExecutionEnvironment executionEnvironment) |
Modifier and Type | Method and Description |
---|---|
protected <T> DataStreamQueryOperation<T> |
asQueryOperation(DataStream<T> dataStream,
Optional<List<Expression>> fields) |
void |
attachAsDataStream(List<ModifyOperation> modifyOperations) |
StreamExecutionEnvironment |
execEnv()
This is a temporary workaround for Python API.
|
protected <T> TypeInformation<T> |
extractTypeInformation(Table table,
Class<T> clazz) |
protected <T> Table |
fromStreamInternal(DataStream<T> dataStream,
Schema schema,
String viewPath,
ChangelogMode changelogMode) |
static Executor |
lookupExecutor(ClassLoader classLoader,
StreamExecutionEnvironment executionEnvironment) |
protected QueryOperation |
qualifyQueryOperation(ObjectIdentifier identifier,
QueryOperation queryOperation)
Subclasses can override this method to transform the given QueryOperation to a new one with
the qualified object identifier.
|
protected <T> DataStream<T> |
toStreamInternal(Table table,
ModifyOperation modifyOperation) |
protected <T> DataStream<T> |
toStreamInternal(Table table,
SchemaTranslator.ProducingResult schemaTranslationResult,
ChangelogMode changelogMode) |
protected void |
validateTimeCharacteristic(boolean isRowtimeDefined) |
protected <T> DataType |
wrapWithChangeFlag(TypeInformation<T> outputType) |
compilePlan, compilePlanSql, create, create, createFunction, createFunction, createFunction, createFunction, createStatementSet, createTable, createTable, createTemporaryFunction, createTemporaryFunction, createTemporaryFunction, createTemporarySystemFunction, createTemporarySystemFunction, createTemporarySystemFunction, createTemporaryTable, createTemporaryView, dropFunction, dropTemporaryFunction, dropTemporarySystemFunction, dropTemporaryTable, dropTemporaryView, executeInternal, executeInternal, executePlan, executeSql, explainInternal, explainPlan, explainSql, from, from, fromTableSource, fromValues, fromValues, fromValues, fromValues, fromValues, fromValues, getCatalog, getCatalogManager, getCompletionHints, getConfig, getCurrentCatalog, getCurrentDatabase, getExtendedOperationExecutor, getOperationTreeBuilder, getParser, getPlanner, listCatalogs, listDatabases, listFullModules, listFunctions, listModules, listTables, listTables, listTemporaryTables, listTemporaryViews, listUserDefinedFunctions, listViews, loadModule, loadPlan, registerCatalog, registerFunction, registerTable, registerTableSinkInternal, registerTableSourceInternal, scan, sqlQuery, translate, unloadModule, useCatalog, useDatabase, useModules, validateTableSource
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
explainInternal
executePlan, explainSql
protected final StreamExecutionEnvironment executionEnvironment
public AbstractStreamTableEnvironmentImpl(CatalogManager catalogManager, ModuleManager moduleManager, ResourceManager resourceManager, TableConfig tableConfig, Executor executor, FunctionCatalog functionCatalog, Planner planner, boolean isStreamingMode, StreamExecutionEnvironment executionEnvironment)
public static Executor lookupExecutor(ClassLoader classLoader, StreamExecutionEnvironment executionEnvironment)
protected <T> Table fromStreamInternal(DataStream<T> dataStream, @Nullable Schema schema, @Nullable String viewPath, ChangelogMode changelogMode)
protected <T> DataStream<T> toStreamInternal(Table table, SchemaTranslator.ProducingResult schemaTranslationResult, @Nullable ChangelogMode changelogMode)
protected <T> DataStream<T> toStreamInternal(Table table, ModifyOperation modifyOperation)
@Internal public StreamExecutionEnvironment execEnv()
protected <T> TypeInformation<T> extractTypeInformation(Table table, Class<T> clazz)
protected <T> DataType wrapWithChangeFlag(TypeInformation<T> outputType)
protected <T> DataStreamQueryOperation<T> asQueryOperation(DataStream<T> dataStream, Optional<List<Expression>> fields)
protected void validateTimeCharacteristic(boolean isRowtimeDefined)
protected QueryOperation qualifyQueryOperation(ObjectIdentifier identifier, QueryOperation queryOperation)
TableEnvironmentImpl
fromDataStream(DataStream)
. But the identifier is required when converting this
QueryOperation to RelNode.qualifyQueryOperation
in class TableEnvironmentImpl
public void attachAsDataStream(List<ModifyOperation> modifyOperations)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.