Packages

c

pl.touk.nussknacker.engine.process.registrar

DefaultStreamExecutionEnvPreparer

class DefaultStreamExecutionEnvPreparer extends StreamExecutionEnvPreparer with LazyLogging

Linear Supertypes
LazyLogging, StreamExecutionEnvPreparer, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DefaultStreamExecutionEnvPreparer
  2. LazyLogging
  3. StreamExecutionEnvPreparer
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new DefaultStreamExecutionEnvPreparer(jobConfig: FlinkJobConfig, executionConfigPreparer: ExecutionConfigPreparer)

Value Members

  1. def flinkClassLoaderSimulation: ClassLoader
  2. def postRegistration(env: StreamExecutionEnvironment, compilerData: FlinkProcessCompilerData, deploymentData: DeploymentData): Unit
  3. def preRegistration(env: StreamExecutionEnvironment, compilerData: FlinkProcessCompilerData, deploymentData: DeploymentData): Unit
    Definition Classes
    DefaultStreamExecutionEnvPreparerStreamExecutionEnvPreparer
    Annotations
    @silent( "deprecated" )
  4. def sideOutputGetter[T](singleOutputStreamOperator: SingleOutputStreamOperator[_], outputTag: OutputTag[T]): DataStream[T]