org.apache.flink.statefun.flink.core.translation

Class FlinkUniverse

java.lang.Object

org.apache.flink.statefun.flink.core.translation.FlinkUniverse

public final class FlinkUniverse
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
FlinkUniverse(FeedbackKey<Message> feedbackKey, StatefulFunctionsConfig configuration, StatefulFunctionsUniverse universe)

Method Summary

Modifier and Type	Method and Description
void	configure(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkUniverse

public FlinkUniverse(FeedbackKey<Message> feedbackKey,
                     StatefulFunctionsConfig configuration,
                     StatefulFunctionsUniverse universe)

Method Detail

configure

public void configure(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)