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

Class HttpFunctionProvider

java.lang.Object

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

All Implemented Interfaces:

ManagingResources, StatefulFunctionProvider

@NotThreadSafe
public final class HttpFunctionProvider
extends java.lang.Object
implements StatefulFunctionProvider, ManagingResources

Constructor Summary

Constructors

Constructor and Description
HttpFunctionProvider(HttpFunctionEndpointSpec endpointSpec, RequestReplyClientFactory requestReplyClientFactory)

Method Summary

Modifier and Type	Method and Description
StatefulFunction	functionOfType(FunctionType functionType) Creates a StatefulFunction instance for the given FunctionType,
void	shutdown() This method would be called by the runtime on shutdown, and indicates that this is the time to free up any resources managed by this class.

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpFunctionProvider

public HttpFunctionProvider(HttpFunctionEndpointSpec endpointSpec,
                            RequestReplyClientFactory requestReplyClientFactory)

Method Detail

functionOfType

public StatefulFunction functionOfType(FunctionType functionType)

Description copied from interface: StatefulFunctionProvider

Creates a StatefulFunction instance for the given FunctionType,

Specified by:

functionOfType in interface StatefulFunctionProvider

Parameters:

functionType - the type of function to create an instance for.

Returns:

an instance of a function for the given type.

shutdown

public void shutdown()

Description copied from interface: ManagingResources

This method would be called by the runtime on shutdown, and indicates that this is the time to free up any resources managed by this class.

Specified by:

shutdown in interface ManagingResources