org.apache.flink.statefun.flink.core.httpfn

Class DefaultHttpRequestReplyClientFactory

java.lang.Object

org.apache.flink.statefun.flink.core.httpfn.DefaultHttpRequestReplyClientFactory

All Implemented Interfaces:

RequestReplyClientFactory

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

Field Summary

Fields

Modifier and Type	Field and Description
static DefaultHttpRequestReplyClientFactory	INSTANCE

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 DefaultHttpRequestReplyClientFactory INSTANCE

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