Package | Description |
---|---|
org.apache.flink.statefun.flink.datastream |
Modifier and Type | Method and Description |
---|---|
static RequestReplyFunctionBuilder |
StatefulFunctionBuilder.requestReplyFunctionBuilder(FunctionType functionType,
java.net.URI endpoint)
Creates a function builder using the synchronous HTTP protocol.
|
static RequestReplyFunctionBuilder |
RequestReplyFunctionBuilder.requestReplyFunctionBuilder(FunctionType functionType,
java.net.URI 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.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.