Constructor and Description |
---|
StreamExecutor(StreamExecutionEnvironment executionEnvironment) |
Modifier and Type | Method and Description |
---|---|
void |
apply(List<Transformation<?>> transformations)
Applies all given transformations.
|
JobExecutionResult |
execute(String jobName)
Executes all the previously applied transformations via
Executor.apply(List) . |
StreamExecutionEnvironment |
getExecutionEnvironment() |
@VisibleForTesting public StreamExecutor(StreamExecutionEnvironment executionEnvironment)
public void apply(List<Transformation<?>> transformations)
Executor
Executor.execute(String)
public JobExecutionResult execute(String jobName) throws Exception
Executor
Executor.apply(List)
.public StreamExecutionEnvironment getExecutionEnvironment()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.