org.apache.flink.statefun.flink.datastream

Class RequestReplyFunctionBuilder

java.lang.Object

org.apache.flink.statefun.flink.datastream.RequestReplyFunctionBuilder

public class RequestReplyFunctionBuilder
extends java.lang.Object

A Builder for RequestReply remote function type.

Method Summary

Modifier and Type	Method and Description
static RequestReplyFunctionBuilder	requestReplyFunctionBuilder(FunctionType functionType, java.net.URI endpoint) Create a new builder for a remote function with a given type and an endpoint.
RequestReplyFunctionBuilder	withConnectTimeout(java.time.Duration duration) Set a timeout for connecting to function endpoints.
RequestReplyFunctionBuilder	withMaxNumBatchRequests(int maxNumBatchRequests) Sets the max messages to batch together for a specific address.
RequestReplyFunctionBuilder	withMaxRequestDuration(java.time.Duration duration) Set a maximum request duration.
RequestReplyFunctionBuilder	withReadTimeout(java.time.Duration duration) Set a timeout for individual read IO operations during a function invocation request.
RequestReplyFunctionBuilder	withWriteTimeout(java.time.Duration duration) Set a timeout for individual write IO operations during a function invocation request.

Methods inherited from class java.lang.Object

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

Method Detail

requestReplyFunctionBuilder

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

Create a new builder for a remote function with a given type and an endpoint.

Parameters:

functionType - the function type that is served remotely.

endpoint - the endpoint that serves that remote function.

Returns:

a builder.

withMaxRequestDuration

public RequestReplyFunctionBuilder withMaxRequestDuration(java.time.Duration duration)

Set a maximum request duration. This duration spans the complete call, including connecting to the function endpoint, writing the request, function processing, and reading the response.

Parameters:

duration - the duration after which the request is considered failed.

Returns:

this builder.

withConnectTimeout

public RequestReplyFunctionBuilder withConnectTimeout(java.time.Duration duration)

Set a timeout for connecting to function endpoints.

Parameters:

duration - the duration after which a connect attempt is considered failed.

Returns:

this builder.

withReadTimeout

public RequestReplyFunctionBuilder withReadTimeout(java.time.Duration duration)

Set a timeout for individual read IO operations during a function invocation request.

Parameters:

duration - the duration after which a read IO operation is considered failed.

Returns:

this builder.

withWriteTimeout

public RequestReplyFunctionBuilder withWriteTimeout(java.time.Duration duration)

Set a timeout for individual write IO operations during a function invocation request.

Parameters:

duration - the duration after which a write IO operation is considered failed.

Returns:

this builder.

withMaxNumBatchRequests

public RequestReplyFunctionBuilder withMaxNumBatchRequests(int maxNumBatchRequests)

Sets the max messages to batch together for a specific address.

Parameters:

maxNumBatchRequests - the maximum number of requests to batch for an address.

Returns:

this builder.