MCPcopy Create free account

hub / github.com/apache/flink-statefun-playground / functions

Functions333 in github.com/apache/flink-statefun-playground

⨍ Functions 333◇ Types & classes 90
↓ 1 callersMethodgetTopics
()
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundEgressSpec.java:40
↓ 1 callersMethodgetUserId
()
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/types/UserLogin.java:49
↓ 1 callersMethodgetUserId
()
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/UserLogin.java:49
↓ 1 callersMethodgetUserName
()
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/types/UserLogin.java:53
↓ 1 callersMethodgetUserName
()
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/UserLogin.java:53
↓ 1 callersMethodid
()
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundIngressSpec.java:26
↓ 1 callersMethodinitEmpty
()
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/UserShoppingCartFn.java:174
↓ 1 callersMethodisInitialized
()
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:273
↓ 1 callersMethodjsonProducerContainer
(Network network)
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/StatefulFunctionsRuntimeProcesses.java:110
↓ 1 callersMethodkafkaContainer
(Network network)
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/StatefulFunctionsRuntimeProcesses.java:82
↓ 1 callersFunctionmain
()
playground-internal/statefun-playground-producer/main.py:88
↓ 1 callersMethodmain
(String[] args)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/LocalEnvironmentEntrypoint.java:43
↓ 1 callersMethodmanagerContainer
(Network network)
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/StatefulFunctionsRuntimeProcesses.java:88
↓ 1 callersMethodmergeUnknownFields
( final com.google.protobuf.UnknownFieldSet unknownFields)
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:1077
↓ 1 callersMethodoffer
(String topic, ByteString message)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressWebServer.java:49
↓ 1 callersMethodonComplete
(HttpServerExchange exchange, Slice responseBytes, Throwable ex)
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/undertow/UndertowHttpHandler.java:52
↓ 1 callersMethodonComplete
(HttpServerExchange exchange, Slice responseBytes, Throwable ex)
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/UndertowHttpHandler.java:52
↓ 1 callersMethodonComplete
(HttpServerExchange exchange, Slice responseBytes, Throwable ex)
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/undertow/UndertowHttpHandler.java:52
↓ 1 callersMethodonSuccess
(HttpServerExchange exchange, Slice result)
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Expose.java:100
↓ 1 callersMethodopen
(Configuration parameters)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundEgress.java:28
↓ 1 callersMethodoutputConnectedComponentChange
(Context context, int vertexId, int componentId)
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/ConnectedComponentsFn.java:142
↓ 1 callersMethodparseAddress
(String relativePath)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/IngressWebServer.java:99
↓ 1 callersMethodparseConfiguration
(String[] args)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/LocalEnvironmentEntrypoint.java:57
↓ 1 callersMethodparseConfigurationOptions
( MultipleParameterTool parameterTool, Configuration flinkConfiguration)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/LocalEnvironmentEntrypoint.java:66
↓ 1 callersMethodparseModuleOption
( MultipleParameterTool parameterTool, Configuration flinkConfiguration)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/LocalEnvironmentEntrypoint.java:89
↓ 1 callersMethodparsePartialFrom
( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLit
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:1103
↓ 1 callersMethodparseTypeUrl
(HeaderMap requestHeaders)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/IngressWebServer.java:89
↓ 1 callersMethodparser
()
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:1112
↓ 1 callersFunctionproduce
(producer, delay_seconds: int, requests)
playground-internal/statefun-playground-producer/main.py:76
↓ 1 callersFunctionread_jsons
(path: str)
playground-internal/statefun-playground-producer/main.py:45
↓ 1 callersMethodtoString
()
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:129
↓ 1 callersMethodtype
()
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundEgressSpec.java:31
↓ 1 callersMethodvalidate
(Configuration configuration)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/ConfigurationValidator.java:32
↓ 1 callersMethodvalidateCustomPayloadSerializerClassName
(Configuration configuration)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/ConfigurationValidator.java:38
↓ 1 callersMethodvalidateNoHeapBackedTimers
(Configuration configuration)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/ConfigurationValidator.java:68
↓ 1 callersMethodvalidateUnalignedCheckpointsDisabled
(Configuration configuration)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/ConfigurationValidator.java:77
↓ 1 callersMethodworkerContainer
(Network network)
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/StatefulFunctionsRuntimeProcesses.java:100
MethodAPIGatewayStateFunHandlerProxy
(RequestReplyHandler stateFunHandler)
deployments/aws-lambda/src/main/java/org/apache/flink/statefun/playground/aws/APIGatewayStateFunHandlerProxy.java:42
MethodAddToCart
( @JsonProperty("userId") String userId, @JsonProperty("itemId") String itemId, @JsonP
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:165
MethodAddress
(String namespace, String functionType, String key)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/IngressWebServer.java:116
MethodBasket
(@JsonProperty("basket") Map<String, Integer> basket)
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/UserShoppingCartFn.java:178
MethodBuilder
(@JsonProperty("port") int port)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundIngressSpec.java:40
MethodBuilder
(@JsonProperty("port") int port, @JsonProperty("topics") Set<String> topics)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundEgressSpec.java:49
MethodBuilder
()
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:517
MethodCheckout
(@JsonProperty("userId") String userId)
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:96
MethodClearCart
(@JsonProperty("userId") String userId)
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:71
MethodConfigurationValidator
()
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/ConfigurationValidator.java:30
MethodConstants
()
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/Constants.java:26
FunctionEgressFn
EgressFn Showcase Part 3: Sending messages to egresses ============================ To let your StateFun application interact with the outside world
go/showcase/pkg/showcase/part3/egress.go:34
MethodEgressHttpHandler
(Map<String, BlockingQueue<ByteString>> queues)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressWebServer.java:59
MethodEgressRecord
()
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressRecord.java:12
MethodEgressRecord
()
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/types/EgressRecord.java:12
MethodEgressRecord
()
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/EgressRecord.java:12
MethodEgressRecord
()
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:282
MethodEgressWebServer
(int port, Set<String> topics)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressWebServer.java:26
FunctionGreeter
(ctx statefun.Context, message statefun.Message)
go/greeter/greeter.go:79
MethodIdentifiers
()
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Identifiers.java:24
MethodIngressHttpHandler
(BlockingQueue<AutoRoutable> messageQueue)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/IngressWebServer.java:38
MethodIngressWebServer
(int port, BlockingQueue<AutoRoutable> messageQueue)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/IngressWebServer.java:21
MethodInvoke
(ctx statefun.Context, message statefun.Message)
go/greeter/greeter.go:47
MethodInvoke
(ctx statefun.Context, msg statefun.Message)
go/showcase/pkg/showcase/part4/storage.go:62
MethodInvoke
(ctx statefun.Context, message statefun.Message)
go/showcase/pkg/showcase/part5/asyncops.go:59
MethodInvoke
(ctx statefun.Context, message statefun.Message)
go/showcase/pkg/showcase/part6/user_fn.go:57
MethodItemAvailability
( @JsonProperty("status") Status status, @JsonProperty("quantity") int quantity)
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:254
MethodLease
()
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/RefCountedContainer.java:37
MethodMarshalJSON
()
go/showcase/pkg/showcase/part1/user_login.go:65
FunctionMessaging
Messaging Showcase Part 2: Messaging Primitives ============================ This function demonstrates how to send messages to other functions. ==
go/showcase/pkg/showcase/part2/messaging.go:40
MethodMyProtobufType
()
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/MyProtobufType.java:7
FunctionNewAsyncOpsFn
()
go/showcase/pkg/showcase/part5/asyncops.go:46
FunctionNewStateStorageFn
()
go/showcase/pkg/showcase/part4/storage.go:44
MethodParseException
(String message)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/ParseException.java:4
MethodPlaygroundEgress
(int port, Set<String> topics)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundEgress.java:22
MethodPlaygroundEgressSpec
(int port, Set<String> topics)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundEgressSpec.java:21
MethodPlaygroundIngress
(int port)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundIngress.java:18
MethodPlaygroundIngressSpec
(int port)
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundIngressSpec.java:18
MethodReceipt
(@JsonProperty("userId") String userId, @JsonProperty("details") String details)
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:116
MethodRefCountedContainer
()
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/RefCountedContainer.java:18
MethodRequestItem
(@JsonProperty("quantity") int quantity)
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:229
MethodRestockItem
( @JsonProperty("itemId") String itemId, @JsonProperty("quantity") int quantity)
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:139
MethodTypeUtils
()
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/TypeUtils.java:31
FunctionTypes
Types Showcase Part 1: Type System ============================ This function demonstrates StateFun's type system using the GoLang SDK. Core Type abs
go/showcase/pkg/showcase/part1/types.go:59
MethodTypes
()
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/types/Types.java:11
MethodTypes
()
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/Types.java:11
MethodUndertowHttpHandler
(RequestReplyHandler handler)
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/undertow/UndertowHttpHandler.java:37
MethodUndertowHttpHandler
(RequestReplyHandler handler)
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/UndertowHttpHandler.java:37
MethodUndertowHttpHandler
(RequestReplyHandler handler)
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/undertow/UndertowHttpHandler.java:37
MethodUndertowStateFunHandler
(RequestReplyHandler handler)
java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Expose.java:68
MethodUnmarshalJSON
(b []byte)
go/showcase/pkg/showcase/part1/user_login.go:72
MethodUserLogin
()
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/types/UserLogin.java:47
MethodUserLogin
()
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/UserLogin.java:47
MethodUserProfile
(com.google.protobuf.GeneratedMessageV3.Builder<?> builder)
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:13
MethodUtils
()
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/binders/Utils.java:13
MethodVertex
()
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/Vertex.java:14
MethodVertexComponentChange
()
java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/VertexComponentChange.java:16
Method__init__
(self, broker, topic)
playground-internal/statefun-playground-producer/main.py:65
MethodaddFriend
<code>repeated string friend = 6;</code> @param value The friend to add. @return This builder for chaining.
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:1023
MethodaddFriendBytes
<code>repeated string friend = 6;</code> @param value The bytes of the friend to add. @return This builder for chaining.
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:1061
MethodaddRepeatedField
( com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value)
java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:620
Methodapply
(Context context, Message message)
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/UserFn.java:54
Methodapply
(Context context, Message message)
java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/GreetingsFn.java:49
← previousnext →101–200 of 333, ranked by callers