org.apache.flink.statefun.flink.io.common

Class AutoRoutableProtobufRouter

java.lang.Object

org.apache.flink.statefun.flink.io.common.AutoRoutableProtobufRouter

All Implemented Interfaces:

Router<com.google.protobuf.Message>

public final class AutoRoutableProtobufRouter
extends java.lang.Object
implements Router<com.google.protobuf.Message>

A Router that recognizes messages of type AutoRoutable.

For each incoming AutoRoutable, this router forwards the wrapped payload to the configured target addresses as a TypedValue message.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.statefun.sdk.io.Router

Router.Downstream<T>

Constructor Summary

Constructors

Constructor and Description
AutoRoutableProtobufRouter()

Method Summary

Modifier and Type	Method and Description
void	route(com.google.protobuf.Message message, Router.Downstream<com.google.protobuf.Message> downstream) Note: while the input and type of this method is both Message, we actually do a conversion here.

Methods inherited from class java.lang.Object

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

Constructor Detail

AutoRoutableProtobufRouter

public AutoRoutableProtobufRouter()

Method Detail

route

public void route(com.google.protobuf.Message message,
                  Router.Downstream<com.google.protobuf.Message> downstream)

Note: while the input and type of this method is both Message, we actually do a conversion here. The input Message is an AutoRoutable, which gets converted to a TypedValue as the output after slicing the target address and actual payload.

Specified by:

route in interface Router<com.google.protobuf.Message>

Parameters:

message - the message to route.

downstream - used to invoke downstream functions.