@Internal public abstract class ExecutorBase extends Object implements Executor
Executor
that is backed by a StreamExecutionEnvironment
.Modifier and Type | Field and Description |
---|---|
protected TableConfig |
tableConfig |
Constructor and Description |
---|
ExecutorBase(StreamExecutionEnvironment executionEnvironment) |
Modifier and Type | Method and Description |
---|---|
void |
apply(List<Transformation<?>> transformations)
Applies all given transformations.
|
StreamExecutionEnvironment |
getExecutionEnvironment() |
protected String |
getNonEmptyJobName(String jobName) |
abstract StreamGraph |
getStreamGraph(String jobName)
Translates the transformations applied into this executor to a stream graph.
|
void |
setTableConfig(TableConfig tableConfig) |
protected TableConfig tableConfig
public ExecutorBase(StreamExecutionEnvironment executionEnvironment)
public void setTableConfig(TableConfig tableConfig)
public StreamExecutionEnvironment getExecutionEnvironment()
public void apply(List<Transformation<?>> transformations)
Executor
Executor.execute(String)
public abstract StreamGraph getStreamGraph(String jobName)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.