public static class GreetStatefulFunctionBootstrapExample.GreetingsStateBootstrapDataRouter extends java.lang.Object implements Router<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>>
Router.Downstream<T>
Constructor and Description |
---|
GreetingsStateBootstrapDataRouter() |
Modifier and Type | Method and Description |
---|---|
void |
route(org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer> message,
Router.Downstream<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>> downstream)
Routes a given message to downstream
StatefulFunction s. |
public void route(org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer> message, Router.Downstream<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>> downstream)
Router
StatefulFunction
s. A single message may result in
multiple functions being invoked.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.