class DefaultStreamExecutionEnvPreparer extends StreamExecutionEnvPreparer with LazyLogging
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- DefaultStreamExecutionEnvPreparer
- LazyLogging
- StreamExecutionEnvPreparer
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new DefaultStreamExecutionEnvPreparer(jobConfig: FlinkJobConfig, executionConfigPreparer: ExecutionConfigPreparer)
Value Members
-
def
flinkClassLoaderSimulation: ClassLoader
- Definition Classes
- DefaultStreamExecutionEnvPreparer → StreamExecutionEnvPreparer
-
def
postRegistration(env: StreamExecutionEnvironment, compilerData: FlinkProcessCompilerData, deploymentData: DeploymentData): Unit
- Definition Classes
- DefaultStreamExecutionEnvPreparer → StreamExecutionEnvPreparer
-
def
preRegistration(env: StreamExecutionEnvironment, compilerData: FlinkProcessCompilerData, deploymentData: DeploymentData): Unit
- Definition Classes
- DefaultStreamExecutionEnvPreparer → StreamExecutionEnvPreparer
- Annotations
- @silent( "deprecated" )
-
def
sideOutputGetter[T](singleOutputStreamOperator: SingleOutputStreamOperator[_], outputTag: OutputTag[T]): DataStream[T]
- Definition Classes
- DefaultStreamExecutionEnvPreparer → StreamExecutionEnvPreparer