org.apache.flink.statefun.flink.core

Class StatefulFunctionsJob

java.lang.Object

org.apache.flink.statefun.flink.core.StatefulFunctionsJob

public class StatefulFunctionsJob
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
StatefulFunctionsJob()

Method Summary

Modifier and Type	Method and Description
static void	main(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, StatefulFunctionsConfig stateFunConfig) The main entry point for executing a stateful functions application.
static void	main(java.lang.String... args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StatefulFunctionsJob

public StatefulFunctionsJob()

Method Detail

main

public static void main(java.lang.String... args)
                 throws java.lang.Exception

Throws:

java.lang.Exception

main

public static void main(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
                        StatefulFunctionsConfig stateFunConfig)
                 throws java.lang.Exception

The main entry point for executing a stateful functions application.

Parameters:

env - The StreamExecutionEnvironment under which the application will be bound.

stateFunConfig - The stateful function specific configurations for the deployment.

Throws:

java.lang.Exception