Package | Description |
---|---|
org.apache.flink.statefun.flink.datastream |
Modifier and Type | Method and Description |
---|---|
static RequestReplyFunctionBuilder |
RequestReplyFunctionBuilder.requestReplyFunctionBuilder(FunctionType functionType,
java.net.URI endpoint)
Create a new builder for a remote function with a given type and an endpoint.
|
RequestReplyFunctionBuilder |
RequestReplyFunctionBuilder.withConnectTimeout(java.time.Duration duration)
Set a timeout for connecting to function endpoints.
|
RequestReplyFunctionBuilder |
RequestReplyFunctionBuilder.withMaxNumBatchRequests(int maxNumBatchRequests)
Sets the max messages to batch together for a specific address.
|
RequestReplyFunctionBuilder |
RequestReplyFunctionBuilder.withMaxRequestDuration(java.time.Duration duration)
Set a maximum request duration.
|
RequestReplyFunctionBuilder |
RequestReplyFunctionBuilder.withReadTimeout(java.time.Duration duration)
Set a timeout for individual read IO operations during a function invocation request.
|
RequestReplyFunctionBuilder |
RequestReplyFunctionBuilder.withWriteTimeout(java.time.Duration duration)
Set a timeout for individual write IO operations during a function invocation request.
|
Modifier and Type | Method and Description |
---|---|
StatefulFunctionDataStreamBuilder |
StatefulFunctionDataStreamBuilder.withRequestReplyRemoteFunction(RequestReplyFunctionBuilder builder)
Adds a remote RequestReply type of function provider to this builder.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.