org.apache.flink.statefun.flink.datastream

Class StatefulFunctionBuilder

java.lang.Object

org.apache.flink.statefun.flink.datastream.StatefulFunctionBuilder

Direct Known Subclasses:

AsyncRequestReplyFunctionBuilder, RequestReplyFunctionBuilder

public abstract class StatefulFunctionBuilder
extends java.lang.Object

Base class for statefun function builders.

Constructor Summary

Constructors

Constructor and Description
StatefulFunctionBuilder()

Method Summary

Modifier and Type	Method and Description
static AsyncRequestReplyFunctionBuilder	asyncRequestReplyFunctionBuilder(FunctionType functionType, java.net.URI endpoint) Creates a function builder using the asynchronous HTTP protocol.
static RequestReplyFunctionBuilder	requestReplyFunctionBuilder(FunctionType functionType, java.net.URI endpoint) Creates a function builder using the synchronous HTTP protocol.

Methods inherited from class java.lang.Object

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

Constructor Detail

StatefulFunctionBuilder

public StatefulFunctionBuilder()

Method Detail

requestReplyFunctionBuilder

public static RequestReplyFunctionBuilder requestReplyFunctionBuilder(FunctionType functionType,
                                                                      java.net.URI endpoint)

Creates a function builder using the synchronous HTTP protocol.

Parameters:

functionType - the function type that is served remotely.

endpoint - the endpoint that serves that remote function.

Returns:

a builder.

asyncRequestReplyFunctionBuilder

public static AsyncRequestReplyFunctionBuilder asyncRequestReplyFunctionBuilder(FunctionType functionType,
                                                                                java.net.URI endpoint)

Creates a function builder using the asynchronous HTTP protocol.

Parameters:

functionType - the function type that is served remotely.

endpoint - the endpoint that serves that remote function.

Returns:

a builder.