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

Class EmbeddedTranslator

java.lang.Object

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

public class EmbeddedTranslator
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
EmbeddedTranslator(StatefulFunctionsConfig config, FeedbackKey<Message> feedbackKey)

Method Summary

Modifier and Type	Method and Description
<T extends StatefulFunctionProvider & java.io.Serializable> java.util.Map<EgressIdentifier<?>,org.apache.flink.streaming.api.datastream.DataStream<?>>	translate(java.util.List<org.apache.flink.streaming.api.datastream.DataStream<RoutableMessage>> ingresses, java.lang.Iterable<EgressIdentifier<?>> egressesIds, java.util.Map<FunctionType,T> functions)

Methods inherited from class java.lang.Object

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

Constructor Detail

EmbeddedTranslator

public EmbeddedTranslator(StatefulFunctionsConfig config,
                          FeedbackKey<Message> feedbackKey)

Method Detail

translate

public <T extends StatefulFunctionProvider & java.io.Serializable> java.util.Map<EgressIdentifier<?>,org.apache.flink.streaming.api.datastream.DataStream<?>> translate(java.util.List<org.apache.flink.streaming.api.datastream.DataStream<RoutableMessage>> ingresses,
                                                                                                                                                                        java.lang.Iterable<EgressIdentifier<?>> egressesIds,
                                                                                                                                                                        java.util.Map<FunctionType,T> functions)