Package | Description |
---|---|
org.apache.flink.statefun.flink.datastream |
Modifier and Type | Method and Description |
---|---|
static AsyncRequestReplyFunctionBuilder |
StatefulFunctionBuilder.asyncRequestReplyFunctionBuilder(FunctionType functionType,
java.net.URI endpoint)
Creates a function builder using the asynchronous HTTP protocol.
|
AsyncRequestReplyFunctionBuilder |
AsyncRequestReplyFunctionBuilder.withConnectionPoolMaxSize(int size)
The maximum connection pool size.
|
AsyncRequestReplyFunctionBuilder |
AsyncRequestReplyFunctionBuilder.withConnectTimeout(java.time.Duration duration)
Set a timeout for connecting to function endpoints.
|
AsyncRequestReplyFunctionBuilder |
AsyncRequestReplyFunctionBuilder.withMaxNumBatchRequests(int maxNumBatchRequests)
Sets the max messages to batch together for a specific address.
|
AsyncRequestReplyFunctionBuilder |
AsyncRequestReplyFunctionBuilder.withMaxRequestDuration(java.time.Duration duration)
Set a maximum request duration.
|
AsyncRequestReplyFunctionBuilder |
AsyncRequestReplyFunctionBuilder.withMaxRequestOrResponseSizeInBytes(int maxSizeInBytes)
The maximum size for a request or response payload.
|
AsyncRequestReplyFunctionBuilder |
AsyncRequestReplyFunctionBuilder.withPooledConnectionTTL(java.time.Duration duration)
The amount of time a connection will live in the connection pool.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.