MCPcopy Create free account

hub / github.com/apache/flink-statefun-playground / types & classes

Types & classes90 in github.com/apache/flink-statefun-playground

⨍ Functions 333◇ Types & classes 90
↓ 1 callersClassKProducer
playground-internal/statefun-playground-producer/main.py:63
↓ 1 callersClassUserProfile
Protobuf type {@code org.apache.flink.statefun.playground.java.showcase.UserProfile}
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:7
ClassAPIGatewayStateFunHandlerProxy
Delegates AWS API Gateway requests to a StateFun {@link RequestReplyHandler}.
deployments/aws-lambda/src/main/java/org/apache/flink/statefun/playground/aws/APIGatewayStateFunHandlerProxy.java:31
ClassAddToCart
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:160
ClassAddress
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/IngressWebServer.java:111
StructAsyncOpsFn
AsyncOpsFn Showcase Part 5: Asyncronous operations ============================ This function demonstrates performing async operations during a func
go/showcase/pkg/showcase/part5/asyncops.go:41
ClassAsyncOpsShowcaseFn
<h1>Showcase Part 5: Asynchronous operations</h1> <p>This function demonstrates performing asynchronous operations during a function invocation. It i
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part5/asyncops/AsyncOpsShowcaseFn.java:49
ClassBasket
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/UserShoppingCartFn.java:161
ClassBuilder
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundIngressSpec.java:36
ClassBuilder
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundEgressSpec.java:44
ClassBuilder
Protobuf type {@code org.apache.flink.statefun.playground.java.showcase.UserProfile}
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:493
ClassCheckout
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:93
ClassClassPathUniverseProvider
This class duplicates StatefulFunctionsUniverses.ClassPathUniverseProvider because it is not public. Needs a new Statefun release to change the visibi
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/ClassPathUniverseProvider.java:30
ClassClearCart
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:68
ClassConfigurationValidator
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/ConfigurationValidator.java:28
ClassConnectedComponentsAppServer
Entry point to start an {@link Undertow} web server that exposes the functions that build up our connected components application {@link ConnectedComp
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/ConnectedComponentsAppServer.java:34
ClassConnectedComponentsFn
A stateful function that computes the connected component for a stream of vertices. <p>The underlying algorithm is a form of label propagation and wo
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/ConnectedComponentsFn.java:42
ClassConstants
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/Constants.java:10
ClassEgressHttpHandler
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressWebServer.java:56
ClassEgressRecord
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressRecord.java:5
ClassEgressRecord
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/types/EgressRecord.java:5
ClassEgressRecord
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/EgressRecord.java:5
ClassEgressRecord
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:275
StructEgressRecord
go/greeter/greeter.go:30
ClassEgressShowcaseFn
<h1>Showcase Part 3: Sending messages to egresses</h1> <p>To let your StateFun application interact with the outside world, functions may write messa
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part3/egresses/EgressShowcaseFn.java:45
ClassEgressWebServer
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressWebServer.java:20
ClassExpose
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Expose.java:35
StructGreetRequest
go/greeter/greeter.go:25
ClassGreeterAppServer
Entry point to start an {@link Undertow} web server that exposes the functions that build up our User Greeter application, {@link UserFn} and {@link G
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/GreeterAppServer.java:34
ClassGreeterAppServer
<h1>Showcase Part 6: Serving your stateful functions</h1> <p>This is the last part of the StateFun Java SDK showcase tutorial! In this section, we'd
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/GreeterAppServer.java:54
ClassGreeterAwsLambdaHandler
An <a href="https://aws.amazon.com/lambda/">AWS Lambda</a> {@link RequestHandler} implementation for serving StateFun functions through <a href="https
deployments/aws-lambda/src/main/java/org/apache/flink/statefun/playground/aws/GreeterAwsLambdaHandler.java:38
ClassGreeterFn
deployments/aws-lambda/src/main/java/org/apache/flink/statefun/playground/aws/GreeterFn.java:27
ClassGreetingsFn
A simple function that computes personalized greetings messages based on a given {@link UserProfile}. Then, it sends the greetings message back to the
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/GreetingsFn.java:38
ClassGreetingsFn
A simple function that computes personalized greetings messages based on a given {@link UserProfile}. Then, it sends the greetings message back to the
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/GreetingsFn.java:39
ClassIdentifiers
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Identifiers.java:22
ClassIngressHttpHandler
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/IngressWebServer.java:35
ClassIngressWebServer
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/IngressWebServer.java:18
ClassItemAvailability
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:244
ClassLease
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/RefCountedContainer.java:33
ClassLocalEnvironmentEntrypoint
Entrypoint that starts a local Flink environment to run the given Stateful Functions application in this process.
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/LocalEnvironmentEntrypoint.java:37
ClassLocalEnvironmentEntrypointITCase
playground-internal/statefun-playground-entrypoint/src/test/java/org/apache/flink/statefun/playground/internal/entrypoint/LocalEnvironmentEntrypointITCase.java:6
EnumLoginType
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/types/UserLogin.java:33
EnumLoginType
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/UserLogin.java:33
TypeAliasLoginType
go/showcase/pkg/showcase/part1/user_login.go:44
ClassMessages
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:28
ClassMessagingPrimitivesShowcaseFn
<h1>Showcase Part 2: Messaging Primitives</h1> <p>This function demonstrates how to send messages to other functions. <h2>Next steps</h2> Besides s
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part2/messaging/MessagingPrimitivesShowcaseFn.java:46
ClassModule
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/binders/ingress/v1/Module.java:7
ClassModule
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/binders/egress/v1/Module.java:7
ClassMyCustomTypes
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/MyCustomTypes.java:26
ClassMyProtobufType
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/MyProtobufType.java:6
ClassParseException
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/ParseException.java:3
StructPerson
go/greeter/greeter.go:43
ClassPlaygroundEgress
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundEgress.java:13
ClassPlaygroundEgressBinder
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/binders/egress/v1/PlaygroundEgressBinder.java:10
ClassPlaygroundEgressSpec
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundEgressSpec.java:15
ClassPlaygroundFlinkIoModule
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundFlinkIoModule.java:8
ClassPlaygroundIngress
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundIngress.java:10
ClassPlaygroundIngressBinder
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/binders/ingress/v1/PlaygroundIngressBinder.java:11
ClassPlaygroundIngressSpec
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundIngressSpec.java:13
ClassPlaygroundSinkProvider
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundSinkProvider.java:8
ClassPlaygroundSourceProvider
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundSourceProvider.java:8
ClassReceipt
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:111
ClassRefCountedContainer
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/RefCountedContainer.java:8
ClassRequestItem
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:226
ClassRestockItem
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:135
StructStateStorageFn
StateStorageFn Showcase Part 3: Function State Storage ============================ One of StateFun's most powerful features is its capability of ma
go/showcase/pkg/showcase/part4/storage.go:38
ClassStateStorageShowcaseFn
<h1>Showcase Part 4: Function state storage</h1> <p>One of StateFun's most powerful features is its capability of managing function state in a consis
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part4/storage/StateStorageShowcaseFn.java:49
ClassStatefulFunctionsRuntimeProcesses
A Java program that starts a few containerized processes using {@link Testcontainers}: <ul> <li>A set of StateFun processes, including a manager an
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/StatefulFunctionsRuntimeProcesses.java:50
EnumStatus
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:246
ClassStockFn
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/StockFn.java:36
ClassTypeSystemShowcaseFn
<h1>Showcase Part 1: Type System</h1> <p>This function demonstrates StateFun's type system using the Java SDK. <h2>Core {@link Type} abstraction</h2
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/TypeSystemShowcaseFn.java:80
ClassTypeUtils
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/TypeUtils.java:29
ClassTypes
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/types/Types.java:9
ClassTypes
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/Types.java:9
ClassUndertowHttpHandler
A simple Undertow {@link HttpHandler} that delegates requests from StateFun runtime processes to a StateFun {@link RequestReplyHandler}.
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/undertow/UndertowHttpHandler.java:34
ClassUndertowHttpHandler
A simple Undertow {@link HttpHandler} that delegates requests from StateFun runtime processes to a StateFun {@link RequestReplyHandler}.
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/UndertowHttpHandler.java:34
ClassUndertowHttpHandler
A simple Undertow {@link HttpHandler} that delegates requests from StateFun runtime processes to a StateFun {@link RequestReplyHandler}.
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/undertow/UndertowHttpHandler.java:34
ClassUndertowStateFunHandler
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Expose.java:65
ClassUserFn
A stateful function that is invoked with {@link UserLogin} events, and persists in state storage the number of times we've seen the user log in as wel
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/UserFn.java:41
ClassUserFn
A stateful function that is invoked with {@link UserLogin} events, and persists in state storage the number of times we've seen the user log in as wel
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/UserFn.java:41
StructUserFn
go/showcase/pkg/showcase/part6/user_fn.go:31
ClassUserLogin
Java Bean class for user login events, which are passed around in JSON form. <p>Please take a look at {@link Types#USER_LOGIN_JSON_TYPE} on how a cus
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/types/UserLogin.java:31
ClassUserLogin
Java Bean class for user login events, which are passed around in JSON form. <p>Please take a look at {@link MyCustomTypes#USER_LOGIN_JSON_TYPE} on h
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/UserLogin.java:31
StructUserLogin
UserLogin is a struct for user login events, which are passed around in JSON form.
go/showcase/pkg/showcase/part1/user_login.go:33
StructUserProfile
go/showcase/pkg/showcase/part6/profile.go:23
InterfaceUserProfileOrBuilder
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfileOrBuilder.java:6
ClassUserShoppingCartFn
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/UserShoppingCartFn.java:45
ClassUtils
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/binders/Utils.java:10
ClassVertex
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/Vertex.java:6
ClassVertexComponentChange
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/VertexComponentChange.java:5