Package | Description |
---|---|
org.apache.flink.statefun.flink.core.httpfn | |
org.apache.flink.statefun.flink.core.nettyclient | |
org.apache.flink.statefun.flink.core.reqreply |
Modifier and Type | Method and Description |
---|---|
RequestReplyClient |
DefaultHttpRequestReplyClientFactory.createTransportClient(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode transportProperties,
java.net.URI endpointUrl) |
Modifier and Type | Method and Description |
---|---|
RequestReplyClient |
NettyRequestReplyClientFactory.createTransportClient(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode transportProperties,
java.net.URI endpointUrl) |
Modifier and Type | Class and Description |
---|---|
class |
ClassLoaderSafeRequestReplyClient
Decorator for a
RequestReplyClient that makes sure we always use the correct classloader. |
Modifier and Type | Method and Description |
---|---|
RequestReplyClient |
RequestReplyClientFactory.createTransportClient(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode transportProperties,
java.net.URI endpointUrl) |
Constructor and Description |
---|
ClassLoaderSafeRequestReplyClient(RequestReplyClient delegate) |
RequestReplyFunction(FunctionType functionType,
int maxNumBatchRequests,
RequestReplyClient client) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.