org.apache.flink.statefun.flink.core.nettyclient

Class NettyRequestReplyClientFactory

java.lang.Object

org.apache.flink.statefun.flink.core.nettyclient.NettyRequestReplyClientFactory

All Implemented Interfaces:

RequestReplyClientFactory

public final class NettyRequestReplyClientFactory
extends java.lang.Object
implements RequestReplyClientFactory

Field Summary

Fields

Modifier and Type	Field and Description
static NettyRequestReplyClientFactory	INSTANCE

Constructor Summary

Constructors

Constructor and Description
NettyRequestReplyClientFactory()

Method Summary

Modifier and Type	Method and Description
void	cleanup()
RequestReplyClient	createTransportClient(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode transportProperties, java.net.URI endpointUrl)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final NettyRequestReplyClientFactory INSTANCE

Constructor Detail

NettyRequestReplyClientFactory

public NettyRequestReplyClientFactory()

Method Detail

createTransportClient

public RequestReplyClient createTransportClient(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode transportProperties,
                                                java.net.URI endpointUrl)

Specified by:

createTransportClient in interface RequestReplyClientFactory

cleanup

public void cleanup()

Specified by:

cleanup in interface RequestReplyClientFactory