Modifier and Type | Class and Description |
---|---|
class |
ScalaShellStreamEnvironment
A
StreamExecutionEnvironment for the Scala shell. |
Modifier and Type | Class and Description |
---|---|
class |
StreamContextEnvironment
Special
StreamExecutionEnvironment that will be used in cases where the CLI client or
testing utilities create a StreamExecutionEnvironment that should be used when getExecutionEnvironment() is called. |
class |
StreamPlanEnvironment
A special
StreamExecutionEnvironment that is used in the web frontend when generating a
user-inspectable graph of a streaming job. |
Modifier and Type | Method and Description |
---|---|
DataStream<Row> |
HBaseTableSource.getDataStream(StreamExecutionEnvironment execEnv) |
Modifier and Type | Method and Description |
---|---|
DataStream<Row> |
JdbcTableSource.getDataStream(StreamExecutionEnvironment execEnv) |
Modifier and Type | Method and Description |
---|---|
DataStream<RowData> |
HiveTableSource.getDataStream(StreamExecutionEnvironment execEnv) |
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
MLEnvironment.getStreamExecutionEnvironment()
Get the StreamExecutionEnvironment.
|
Constructor and Description |
---|
MLEnvironment(ExecutionEnvironment batchEnv,
BatchTableEnvironment batchTableEnv,
StreamExecutionEnvironment streamEnv,
StreamTableEnvironment streamTableEnv)
Construct with env given by user.
|
MLEnvironment(StreamExecutionEnvironment streamEnv,
StreamTableEnvironment streamTableEnv)
Construct with the stream environment and the the stream table environment given by user.
|
Modifier and Type | Method and Description |
---|---|
DataStream<Row> |
StreamSQLTestProgram.GeneratorTableSource.getDataStream(StreamExecutionEnvironment execEnv) |
Modifier and Type | Field and Description |
---|---|
protected StreamExecutionEnvironment |
MultipleConnectedStreams.environment |
protected StreamExecutionEnvironment |
ConnectedStreams.environment |
protected StreamExecutionEnvironment |
DataStream.environment |
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
BroadcastStream.getEnvironment() |
StreamExecutionEnvironment |
MultipleConnectedStreams.getExecutionEnvironment() |
StreamExecutionEnvironment |
WindowedStream.getExecutionEnvironment() |
StreamExecutionEnvironment |
AllWindowedStream.getExecutionEnvironment() |
StreamExecutionEnvironment |
ConnectedStreams.getExecutionEnvironment() |
StreamExecutionEnvironment |
DataStream.getExecutionEnvironment()
Returns the
StreamExecutionEnvironment that was used to create this DataStream . |
StreamExecutionEnvironment |
BroadcastConnectedStream.getExecutionEnvironment() |
Modifier and Type | Class and Description |
---|---|
class |
LocalStreamEnvironment
The LocalStreamEnvironment is a StreamExecutionEnvironment that runs the program locally,
multi-threaded, in the JVM where the environment is instantiated.
|
class |
RemoteStreamEnvironment
A
StreamExecutionEnvironment for executing on a cluster. |
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
StreamExecutionEnvironmentFactory.createExecutionEnvironment()
Creates a StreamExecutionEnvironment from this factory.
|
static StreamExecutionEnvironment |
StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(Configuration conf)
Creates a
LocalStreamEnvironment for local program execution that also starts the web
monitoring UI. |
static StreamExecutionEnvironment |
StreamExecutionEnvironment.createRemoteEnvironment(String host,
int port,
Configuration clientConfig,
String... jarFiles)
Creates a
RemoteStreamEnvironment . |
static StreamExecutionEnvironment |
StreamExecutionEnvironment.createRemoteEnvironment(String host,
int port,
int parallelism,
String... jarFiles)
Creates a
RemoteStreamEnvironment . |
static StreamExecutionEnvironment |
StreamExecutionEnvironment.createRemoteEnvironment(String host,
int port,
String... jarFiles)
Creates a
RemoteStreamEnvironment . |
StreamExecutionEnvironment |
StreamExecutionEnvironment.disableOperatorChaining()
Disables operator chaining for streaming operators.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment.enableCheckpointing()
Deprecated.
Use
enableCheckpointing(long) instead. |
StreamExecutionEnvironment |
StreamExecutionEnvironment.enableCheckpointing(long interval)
Enables checkpointing for the streaming job.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment.enableCheckpointing(long interval,
CheckpointingMode mode)
Enables checkpointing for the streaming job.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment.enableCheckpointing(long interval,
CheckpointingMode mode,
boolean force)
Deprecated.
Use
enableCheckpointing(long, CheckpointingMode) instead. Forcing
checkpoints will be removed in the future. |
static StreamExecutionEnvironment |
StreamExecutionEnvironment.getExecutionEnvironment()
Creates an execution environment that represents the context in which the program is
currently executed.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment.setBufferTimeout(long timeoutMillis)
Sets the maximum time frequency (milliseconds) for the flushing of the output buffers.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment.setMaxParallelism(int maxParallelism)
Sets the maximum degree of parallelism defined for the program.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment.setParallelism(int parallelism)
Sets the parallelism for operations executed through this environment.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment.setStateBackend(AbstractStateBackend backend)
Deprecated.
Use
setStateBackend(StateBackend) instead. |
StreamExecutionEnvironment |
StreamExecutionEnvironment.setStateBackend(StateBackend backend)
Sets the state backend that describes how to store and checkpoint operator state.
|
Modifier and Type | Method and Description |
---|---|
DataStream<Row> |
KafkaTableSourceBase.getDataStream(StreamExecutionEnvironment env)
NOTE: This method is for internal use only for defining a TableSource.
|
Modifier and Type | Method and Description |
---|---|
static <T,K> KeyedStream<T,K> |
FlinkKafkaShuffle.readKeyBy(String topic,
StreamExecutionEnvironment env,
TypeInformation<T> typeInformation,
Properties kafkaProperties,
KeySelector<T,K> keySelector)
|
Modifier and Type | Method and Description |
---|---|
static DataStream<Tuple2<String,Integer>> |
WindowJoinSampleData.GradeSource.getSource(StreamExecutionEnvironment env,
long rate) |
static DataStream<Tuple2<String,Integer>> |
WindowJoinSampleData.SalarySource.getSource(StreamExecutionEnvironment env,
long rate) |
Modifier and Type | Method and Description |
---|---|
static StreamExecutionEnvironment |
KafkaExampleUtil.prepareExecutionEnv(ParameterTool parameterTool) |
Modifier and Type | Method and Description |
---|---|
static void |
DataStreamAllroundTestJobFactory.setupEnvironment(StreamExecutionEnvironment env,
ParameterTool pt) |
Modifier and Type | Class and Description |
---|---|
class |
TestStreamEnvironment
A
StreamExecutionEnvironment that executes its jobs on MiniCluster . |
Modifier and Type | Method and Description |
---|---|
static StreamTableEnvironment |
StreamTableEnvironment.create(StreamExecutionEnvironment executionEnvironment)
Creates a table environment that is the entry point and central context for creating Table
and SQL API programs that integrate with the Java-specific
DataStream API. |
static StreamTableEnvironment |
StreamTableEnvironment.create(StreamExecutionEnvironment executionEnvironment,
EnvironmentSettings settings)
Creates a table environment that is the entry point and central context for creating Table
and SQL API programs that integrate with the Java-specific
DataStream API. |
static StreamTableEnvironment |
StreamTableEnvironment.create(StreamExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
Deprecated.
Use
StreamTableEnvironment.create(StreamExecutionEnvironment) and TableEnvironment.getConfig() for
manipulating TableConfig . |
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
StreamTableEnvironmentImpl.execEnv()
This is a temporary workaround for Python API.
|
Modifier and Type | Method and Description |
---|---|
static StreamTableEnvironment |
StreamTableEnvironmentImpl.create(StreamExecutionEnvironment executionEnvironment,
EnvironmentSettings settings,
TableConfig tableConfig) |
Constructor and Description |
---|
StreamTableEnvironmentImpl(CatalogManager catalogManager,
ModuleManager moduleManager,
FunctionCatalog functionCatalog,
TableConfig tableConfig,
StreamExecutionEnvironment executionEnvironment,
Planner planner,
Executor executor,
boolean isStreamingMode,
ClassLoader userClassLoader) |
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
StreamExecutor.getExecutionEnvironment() |
Modifier and Type | Method and Description |
---|---|
Executor |
StreamExecutorFactory.create(Map<String,String> properties,
StreamExecutionEnvironment executionEnvironment)
Creates a corresponding
StreamExecutor . |
Constructor and Description |
---|
StreamExecutor(StreamExecutionEnvironment executionEnvironment) |
Modifier and Type | Method and Description |
---|---|
DataStream<RowData> |
FileSystemTableSource.getDataStream(StreamExecutionEnvironment execEnv) |
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
ExecutorBase.getExecutionEnvironment() |
Modifier and Type | Method and Description |
---|---|
Executor |
BlinkExecutorFactory.create(Map<String,String> properties,
StreamExecutionEnvironment executionEnvironment)
Creates a corresponding
ExecutorBase . |
Constructor and Description |
---|
BatchExecutor(StreamExecutionEnvironment executionEnvironment) |
ExecutorBase(StreamExecutionEnvironment executionEnvironment) |
StreamExecutor(StreamExecutionEnvironment executionEnvironment) |
Modifier and Type | Method and Description |
---|---|
static StreamGraph |
ExecutorUtils.generateStreamGraph(StreamExecutionEnvironment execEnv,
List<Transformation<?>> transformations)
Generate
StreamGraph by StreamGraphGenerator . |
static void |
ExecutorUtils.setBatchProperties(StreamExecutionEnvironment execEnv,
TableConfig tableConfig)
Sets batch properties for
StreamExecutionEnvironment . |
Constructor and Description |
---|
DummyStreamExecutionEnvironment(StreamExecutionEnvironment realExecEnv) |
Modifier and Type | Method and Description |
---|---|
DataStream<RowData> |
ArrowTableSource.getDataStream(StreamExecutionEnvironment execEnv) |
DataStream<Row> |
RowArrowTableSource.getDataStream(StreamExecutionEnvironment execEnv) |
Modifier and Type | Method and Description |
---|---|
DataStream<T> |
StreamTableSource.getDataStream(StreamExecutionEnvironment execEnv)
Returns the data of the table as a
DataStream . |
DataStream<T> |
InputFormatTableSource.getDataStream(StreamExecutionEnvironment execEnv) |
DataStream<Row> |
CsvTableSource.getDataStream(StreamExecutionEnvironment execEnv) |
Modifier and Type | Class and Description |
---|---|
class |
DummyStreamExecutionEnvironment
This is dummy
StreamExecutionEnvironment , which holds a real StreamExecutionEnvironment , shares all configurations of the real environment, and disables all
configuration setting methods. |
Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
DummyStreamExecutionEnvironment.disableOperatorChaining() |
StreamExecutionEnvironment |
DummyStreamExecutionEnvironment.enableCheckpointing() |
StreamExecutionEnvironment |
DummyStreamExecutionEnvironment.enableCheckpointing(long interval) |
StreamExecutionEnvironment |
DummyStreamExecutionEnvironment.enableCheckpointing(long interval,
CheckpointingMode mode) |
StreamExecutionEnvironment |
DummyStreamExecutionEnvironment.enableCheckpointing(long interval,
CheckpointingMode mode,
boolean force) |
StreamExecutionEnvironment |
DummyStreamExecutionEnvironment.setBufferTimeout(long timeoutMillis) |
StreamExecutionEnvironment |
DummyStreamExecutionEnvironment.setMaxParallelism(int maxParallelism) |
StreamExecutionEnvironment |
DummyStreamExecutionEnvironment.setParallelism(int parallelism) |
StreamExecutionEnvironment |
DummyStreamExecutionEnvironment.setStateBackend(AbstractStateBackend backend) |
StreamExecutionEnvironment |
DummyStreamExecutionEnvironment.setStateBackend(StateBackend backend) |
Constructor and Description |
---|
DummyStreamExecutionEnvironment(StreamExecutionEnvironment realExecEnv) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.