Modifier and Type | Method and Description |
---|---|
void |
InboundDriverRouter.route(InboundDriverMessage message,
Router.Downstream<InboundDriverMessage> downstream) |
void |
InboundPassengerRouter.route(InboundPassengerMessage message,
Router.Downstream<InboundPassengerMessage> downstream) |
Modifier and Type | Method and Description |
---|---|
void |
ProtobufRouter.route(com.google.protobuf.Message message,
Router.Downstream<com.google.protobuf.Message> downstream) |
void |
AutoRoutableProtobufRouter.route(com.google.protobuf.Message message,
Router.Downstream<com.google.protobuf.Message> downstream) |
Modifier and Type | Method and Description |
---|---|
void |
GreetStatefulFunctionBootstrapExample.GreetingsStateBootstrapDataRouter.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) |
Modifier and Type | Method and Description |
---|---|
void |
Router.route(InT message,
Router.Downstream<InT> downstream)
Routes a given message to downstream
StatefulFunction s. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.