Package org.apache.flink.client.program

Class StreamPlanEnvironment

  • All Implemented Interfaces:
    AutoCloseable
    @PublicEvolving
public class StreamPlanEnvironment
extends org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
    A special StreamExecutionEnvironment that is used in the web frontend when generating a user-inspectable graph of a streaming job.

    • Field Summary

      • Fields inherited from class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

        cacheFile, checkpointCfg, config, configuration, DEFAULT_JOB_NAME, transformations

    • Constructor Summary

      Constructors 
      Constructor Description
      StreamPlanEnvironment​(org.apache.flink.configuration.Configuration configuration, ClassLoader userClassLoader, int parallelism)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.flink.core.execution.JobClient executeAsync​(org.apache.flink.streaming.api.graph.StreamGraph streamGraph)  
      org.apache.flink.api.dag.Pipeline getPipeline()  
      void setAsContext()  
      void unsetAsContext()  

      • Methods inherited from class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

        addDefaultKryoSerializer, addDefaultKryoSerializer, addOperator, addSource, addSource, addSource, addSource, areExplicitEnvironmentsAllowed, clean, clearJobListeners, close, configure, configure, createInput, createInput, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createLocalEnvironmentWithWebUI, createRemoteEnvironment, createRemoteEnvironment, createRemoteEnvironment, disableOperatorChaining, enableChangelogStateBackend, enableCheckpointing, enableCheckpointing, enableCheckpointing, enableCheckpointing, enableCheckpointing, execute, execute, execute, executeAsync, executeAsync, fromCollection, fromCollection, fromCollection, fromCollection, fromData, fromData, fromData, fromData, fromData, fromElements, fromElements, fromParallelCollection, fromParallelCollection, fromSequence, fromSource, fromSource, generateSequence, generateStreamGraph, getBufferTimeout, getCachedFiles, getCheckpointConfig, getCheckpointingConsistencyMode, getCheckpointingMode, getCheckpointInterval, getConfig, getConfiguration, getDefaultLocalParallelism, getDefaultSavepointDirectory, getExecutionEnvironment, getExecutionEnvironment, getExecutionPlan, getJobListeners, getMaxParallelism, getNumberOfExecutionRetries, getParallelism, getRestartStrategy, getStateBackend, getStreamGraph, getStreamGraph, getStreamTimeCharacteristic, getTransformations, getUserClassloader, initializeContextEnvironment, invalidateClusterDataset, isChainingEnabled, isChainingOfOperatorsWithDifferentMaxParallelismEnabled, isChangelogStateBackendEnabled, isForceCheckpointing, isForceUnalignedCheckpoints, isUnalignedCheckpointsEnabled, listCompletedClusterDatasets, readFile, readFile, readFile, readFile, readFileStream, readTextFile, readTextFile, registerCachedFile, registerCachedFile, registerCacheTransformation, registerCollectIterator, registerJobListener, registerSlotSharingGroup, registerType, registerTypeWithKryoSerializer, registerTypeWithKryoSerializer, resetContextEnvironment, setBufferTimeout, setDefaultLocalParallelism, setDefaultSavepointDirectory, setDefaultSavepointDirectory, setDefaultSavepointDirectory, setMaxParallelism, setNumberOfExecutionRetries, setParallelism, setRestartStrategy, setRuntimeMode, setStateBackend, setStreamTimeCharacteristic, socketTextStream, socketTextStream, socketTextStream, socketTextStream, socketTextStream

    • Constructor Detail

      • StreamPlanEnvironment

        public StreamPlanEnvironment​(org.apache.flink.configuration.Configuration configuration,
                             ClassLoader userClassLoader,
                             int parallelism)

    • Method Detail

      • getPipeline

        public org.apache.flink.api.dag.Pipeline getPipeline()

      • executeAsync

        public org.apache.flink.core.execution.JobClient executeAsync​(org.apache.flink.streaming.api.graph.StreamGraph streamGraph)
        Overrides:
        executeAsync in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

      • setAsContext

        public void setAsContext()

      • unsetAsContext

        public void unsetAsContext()