Modifier and Type | Class and Description |
---|---|
class |
FunctionProvider |
Modifier and Type | Method and Description |
---|---|
java.util.Map<FunctionType,StatefulFunctionProvider> |
StatefulFunctionsUniverse.functions() |
java.util.Map<java.lang.String,StatefulFunctionProvider> |
StatefulFunctionsUniverse.namespaceFunctions() |
Modifier and Type | Method and Description |
---|---|
void |
StatefulFunctionsUniverse.bindFunctionProvider(FunctionTypeNamespaceMatcher namespaceMatcher,
StatefulFunctionProvider provider) |
void |
StatefulFunctionsUniverse.bindFunctionProvider(FunctionType functionType,
StatefulFunctionProvider provider) |
Modifier and Type | Class and Description |
---|---|
class |
HttpFunctionProvider |
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 | Interface and Description |
---|---|
interface |
SerializableStatefulFunctionProvider |
Modifier and Type | Method and Description |
---|---|
void |
StatefulFunctionModule.Binder.bindFunctionProvider(FunctionTypeNamespaceMatcher namespaceMatcher,
StatefulFunctionProvider provider)
Binds a
StatefulFunctionProvider to the Stateful Functions application for all
functions under the specified namespace. |
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.