Modifier and Type | Field and Description |
---|---|
static FunctionType |
Constants.FN_TYPE |
Modifier and Type | Method and Description |
---|---|
StatefulFunction |
FunctionProvider.functionOfType(FunctionType functionType) |
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 |
---|---|
abstract FunctionType |
TargetFunctions.asSpecificFunctionType() |
Modifier and Type | Method and Description |
---|---|
java.net.URI |
UrlPathTemplate.apply(FunctionType functionType) |
StatefulFunction |
HttpFunctionProvider.functionOfType(FunctionType functionType) |
static TargetFunctions |
TargetFunctions.functionType(FunctionType functionType) |
Modifier and Type | Method and Description |
---|---|
RoutableMessageBuilder |
RoutableMessageBuilder.withSourceAddress(FunctionType functionType,
java.lang.String id) |
RoutableMessageBuilder |
RoutableMessageBuilder.withTargetAddress(FunctionType functionType,
java.lang.String id) |
Modifier and Type | Method and Description |
---|---|
FunctionTypeMetrics |
FlinkFuncionTypeMetricsFactory.forType(FunctionType functionType) |
FunctionTypeMetrics |
FuncionTypeMetricsFactory.forType(FunctionType functionType) |
FunctionTypeMetrics |
FunctionTypeMetricsRepository.getMetrics(FunctionType functionType) |
Constructor and Description |
---|
RequestReplyFunction(FunctionType functionType,
int maxNumBatchRequests,
RequestReplyClient client) |
Constructor and Description |
---|
FlinkStateBinder(State state,
FunctionType functionType) |
Modifier and Type | Method and Description |
---|---|
<T extends StatefulFunctionProvider & java.io.Serializable> |
EmbeddedTranslator.translate(java.util.List<org.apache.flink.streaming.api.datastream.DataStream<RoutableMessage>> ingresses,
java.lang.Iterable<EgressIdentifier<?>> egressesIds,
java.util.Map<FunctionType,T> functions) |
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.
|
StatefulFunctionDataStreamBuilder |
StatefulFunctionDataStreamBuilder.withFunctionProvider(FunctionType functionType,
SerializableStatefulFunctionProvider provider)
Adds a function provider to this builder
|
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 , |
boolean |
FunctionTypeNamespaceMatcher.matches(FunctionType 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 for a specific
FunctionType . |
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–2024 The Apache Software Foundation. All rights reserved.