@Internal public class ScalaShellStreamEnvironment extends StreamExecutionEnvironment
StreamExecutionEnvironment
for the Scala shell.cacheFile, configuration, DEFAULT_JOB_NAME, isChainingEnabled, transformations
Constructor and Description |
---|
ScalaShellStreamEnvironment(Configuration configuration,
org.apache.flink.api.scala.FlinkILoop flinkILoop,
String... jarFiles) |
Modifier and Type | Method and Description |
---|---|
static void |
disableAllContextAndOtherEnvironments() |
JobClient |
executeAsync(StreamGraph streamGraph)
Triggers the program execution asynchronously.
|
Configuration |
getClientConfiguration() |
static void |
resetContextEnvironments() |
addDefaultKryoSerializer, addDefaultKryoSerializer, addOperator, addSource, addSource, addSource, addSource, clean, clearJobListeners, configure, configure, createInput, createInput, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createLocalEnvironmentWithWebUI, createRemoteEnvironment, createRemoteEnvironment, createRemoteEnvironment, disableOperatorChaining, enableCheckpointing, enableCheckpointing, enableCheckpointing, enableCheckpointing, execute, execute, execute, executeAsync, executeAsync, fromCollection, fromCollection, fromCollection, fromCollection, fromElements, fromElements, fromParallelCollection, fromParallelCollection, fromSequence, fromSource, fromSource, generateSequence, generateStreamGraph, getBufferTimeout, getCachedFiles, getCheckpointConfig, getCheckpointingMode, getCheckpointInterval, getConfig, getConfiguration, getDefaultLocalParallelism, getDefaultSavepointDirectory, getExecutionEnvironment, getExecutionEnvironment, getExecutionPlan, getJobListeners, getMaxParallelism, getNumberOfExecutionRetries, getParallelism, getRestartStrategy, getStateBackend, getStreamGraph, getStreamGraph, getStreamTimeCharacteristic, getUserClassloader, initializeContextEnvironment, isChainingEnabled, isForceCheckpointing, isForceUnalignedCheckpoints, isUnalignedCheckpointsEnabled, readFile, readFile, readFile, readFile, readFileStream, readTextFile, readTextFile, registerCachedFile, registerCachedFile, registerJobListener, registerSlotSharingGroup, registerType, registerTypeWithKryoSerializer, registerTypeWithKryoSerializer, resetContextEnvironment, setBufferTimeout, setDefaultLocalParallelism, setDefaultSavepointDirectory, setDefaultSavepointDirectory, setDefaultSavepointDirectory, setMaxParallelism, setNumberOfExecutionRetries, setParallelism, setRestartStrategy, setRuntimeMode, setStateBackend, setStreamTimeCharacteristic, socketTextStream, socketTextStream, socketTextStream, socketTextStream, socketTextStream
public ScalaShellStreamEnvironment(Configuration configuration, org.apache.flink.api.scala.FlinkILoop flinkILoop, String... jarFiles)
public JobClient executeAsync(StreamGraph streamGraph) throws Exception
StreamExecutionEnvironment
executeAsync
in class StreamExecutionEnvironment
streamGraph
- the stream graph representing the transformationsJobClient
that can be used to communicate with the submitted job, completed
on submission succeeded.Exception
- which occurs during job execution.public Configuration getClientConfiguration()
public static void disableAllContextAndOtherEnvironments()
public static void resetContextEnvironments()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.