Modifier and Type | Method and Description |
---|---|
StatefulFunction |
FunctionProvider.functionOfType(FunctionType type) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<FunctionType,StatefulFunctionProvider> |
StatefulFunctionsUniverse.functions() |
Modifier and Type | Method and Description |
---|---|
void |
StatefulFunctionsUniverse.bindFunctionProvider(FunctionType functionType,
StatefulFunctionProvider provider) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.statefun.flink.core.functions.LiveFunction |
FunctionRepository.get(FunctionType type) |
Constructor and Description |
---|
StatefulFunctionInvocationException(FunctionType functionType,
java.lang.Throwable cause) |
Modifier and Type | Method and Description |
---|---|
FunctionType |
GrpcFunctionSpec.functionType() |
Modifier and Type | Method and Description |
---|---|
StatefulFunction |
GrpcFunctionProvider.functionOfType(FunctionType type) |
Constructor and Description |
---|
GrpcFunctionSpec(FunctionType functionType,
java.net.SocketAddress functionAddress) |
Constructor and Description |
---|
GrpcFunctionProvider(java.util.Map<FunctionType,GrpcFunctionSpec> supportedTypes) |
Modifier and Type | Method and Description |
---|---|
FunctionType |
HttpFunctionSpec.functionType() |
Modifier and Type | Method and Description |
---|---|
RequestReplyFunction |
HttpFunctionProvider.functionOfType(FunctionType type) |
Constructor and Description |
---|
HttpFunctionSpec(FunctionType functionType,
java.net.URI endpoint,
java.util.List<java.lang.String> states,
java.time.Duration maxRequestDuration,
int maxNumBatchRequests) |
Constructor and Description |
---|
HttpFunctionProvider(java.util.Map<FunctionType,HttpFunctionSpec> supportedTypes) |
Modifier and Type | Method and Description |
---|---|
FunctionType |
FunctionSpec.functionType() |
Modifier and Type | Method and Description |
---|---|
FunctionTypeMetrics |
FlinkMetricsFactory.forType(FunctionType functionType) |
FunctionTypeMetrics |
MetricsFactory.forType(FunctionType functionType) |
Modifier and Type | Method and Description |
---|---|
StateBootstrapFunction |
StateBootstrapFunctionProvider.bootstrapFunctionOfType(FunctionType type)
Creates a
StateBootstrapFunction instance for the given FunctionType , |
StatefulFunctionsSavepointCreator |
StatefulFunctionsSavepointCreator.withStateBootstrapFunctionProvider(FunctionType functionType,
StateBootstrapFunctionProvider bootstrapFunctionProvider)
Registers a
StateBootstrapFunctionProvider to the savepoint creator. |
Modifier and Type | Method and Description |
---|---|
void |
StateBootstrapFunctionRegistry.register(FunctionType functionType,
StateBootstrapFunctionProvider stateBootstrapFunctionProvider)
Registers a
StateBootstrapFunctionProvider . |
Modifier and Type | Method and Description |
---|---|
FunctionType |
Address.type()
Returns the
FunctionType that this address identifies. |
Modifier and Type | Method and Description |
---|---|
StatefulFunction |
StatefulFunctionProvider.functionOfType(FunctionType type)
Creates a
StatefulFunction instance for the given FunctionType , |
default void |
Context.send(FunctionType functionType,
java.lang.String id,
java.lang.Object message)
Invokes another function with an input, identified by the target function's
FunctionType and unique id. |
default void |
Context.sendAfter(java.time.Duration delay,
FunctionType functionType,
java.lang.String id,
java.lang.Object message)
Invokes another function with an input, identified by the target function's
FunctionType and unique id. |
Constructor and Description |
---|
Address(FunctionType type,
java.lang.String id)
Creates an
Address . |
Modifier and Type | Method and Description |
---|---|
default void |
Router.Downstream.forward(FunctionType functionType,
java.lang.String id,
T message)
Forwards the message as an input to a downstream function, addressed by a specified
FunctionType and the functions unique id within its type. |
Modifier and Type | Method and Description |
---|---|
void |
StatefulFunctionModule.Binder.bindFunctionProvider(FunctionType functionType,
StatefulFunctionProvider provider)
Binds a
StatefulFunctionProvider to the Stateful Functions application. |
Modifier and Type | Method and Description |
---|---|
static FunctionTestHarness |
FunctionTestHarness.test(StatefulFunctionProvider provider,
FunctionType type,
java.lang.String id)
Creates a test harness, pinning the function to a particular address.
|
static FunctionTestHarness |
FunctionTestHarness.test(StatefulFunctionProvider provider,
FunctionType type,
java.lang.String id,
java.time.Instant startTime)
Creates a test harness, pinning the function to a particular address.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.