statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsJob.java
public static void main(StreamExecutionEnvironment env, StatefulFunctionsConfig stateFunConfig)
      throws Exception {
    Objects.requireNonNull(env);
    Objects.requireNonNull(stateFunConfig);

    setDefaultContextClassLoaderIfAbsent();
    configureExecutionEnvironment(env, stateFunConfig);

    env.getConfig().enableObjectReuse();

    final StatefulFunctionsUniverse statefulFunctionsUniverse =
        StatefulFunctionsUniverses.get(
            Thread.currentThread().getContextClassLoader(), stateFunConfig);

    final StatefulFunctionsUniverseValidator statefulFunctionsUniverseValidator =
        new StatefulFunctionsUniverseValidator();
    statefulFunctionsUniverseValidator.validate(statefulFunctionsUniverse);

    FlinkUniverse flinkUniverse = new FlinkUniverse(statefulFunctionsUniverse, stateFunConfig);
    flinkUniverse.configure(env);

    env.execute(stateFunConfig.getFlinkJobName());
  }
/**
   * The main entry point for executing a stateful functions application.
   *
   * @param env The StreamExecutionEnvironment under which the application will be bound.
   * @param stateFunConfig The stateful function specific configurations for the deployment.
   */
The main entry point for executing a stateful functions application.
@param env The StreamExecutionEnvironment under which the application will be bound.
@param stateFunConfig The stateful function specific configurations for the deployment.
The main entry point for executing a stateful functions application . @param env The StreamExecutionEnvironment under which the application will be bound . @param stateFunConfig The stateful function specific configurations for the deployment .
public static void main(StreamExecutionEnvironment env, StatefulFunctionsConfig stateFunConfig)
      throws Exception {
    Objects.requireNonNull(env);
    Objects.requireNonNull(stateFunConfig);
    setDefaultContextClassLoaderIfAbsent();
    configureExecutionEnvironment(env, stateFunConfig);
    env.getConfig().enableObjectReuse();
    final StatefulFunctionsUniverse statefulFunctionsUniverse =
        StatefulFunctionsUniverses.get(
            Thread.currentThread().getContextClassLoader(), stateFunConfig);
    final StatefulFunctionsUniverseValidator statefulFunctionsUniverseValidator =
        new StatefulFunctionsUniverseValidator();
    statefulFunctionsUniverseValidator.validate(statefulFunctionsUniverse);
    FlinkUniverse flinkUniverse = new FlinkUniverse(statefulFunctionsUniverse, stateFunConfig);
    flinkUniverse.configure(env);
    env.execute(stateFunConfig.getFlinkJobName());
  }
public static void main ( StreamExecutionEnvironment env , StatefulFunctionsConfig stateFunConfig ) throws Exception { Objects . requireNonNull ( env ) ; Objects . requireNonNull ( stateFunConfig ) ; setDefaultContextClassLoaderIfAbsent ( ) ; configureExecutionEnvironment ( env , stateFunConfig ) ; env . getConfig ( ) . enableObjectReuse ( ) ; final StatefulFunctionsUniverse statefulFunctionsUniverse = StatefulFunctionsUniverses . get ( Thread . currentThread ( ) . getContextClassLoader ( ) , stateFunConfig ) ; final StatefulFunctionsUniverseValidator statefulFunctionsUniverseValidator = new StatefulFunctionsUniverseValidator ( ) ; statefulFunctionsUniverseValidator . validate ( statefulFunctionsUniverse ) ; FlinkUniverse flinkUniverse = new FlinkUniverse ( statefulFunctionsUniverse , stateFunConfig ) ; flinkUniverse . configure ( env ) ; env . execute ( stateFunConfig . getFlinkJobName ( ) ) ; }
The main entry point for executing a stateful functions application.
The main entry point for executing a stateful functions application .