Functions — github.com/apache/flink-statefun-playground

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

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

playground-internal/statefun-playground-producer/main.py:69

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:561

↓ 30 callersMethodget

( ClassLoader classLoader, StatefulFunctionsConfig configuration)

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/ClassPathUniverseProvider.java:34

↓ 9 callersMethodgetName

<code>string name = 1;</code> @return The name.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfileOrBuilder.java:16

↓ 8 callersMethodbind

( ComponentJsonObject component, StatefulFunctionModule.Binder remoteModuleBinder)

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/binders/egress/v1/PlaygroundEgressBinder.java:15

↓ 8 callersMethodnewBuilder

()

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:472

↓ 8 callersMethodsleep

()

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/StatefulFunctionsRuntimeProcesses.java:122

↓ 6 callersFunctionenv

(arg: Arg)

playground-internal/statefun-playground-producer/main.py:40

↓ 6 callersMethodstop

()

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/IngressWebServer.java:31

↓ 5 callersMethodbuild

()

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundEgressSpec.java:55

↓ 5 callersMethodensureFriendIsMutable

()

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:961

↓ 5 callersMethodgetDefaultInstance

()

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:1096

↓ 5 callersMethodgetLastSeenDeltaMs

<code>int64 last_seen_delta_ms = 2;</code> @return The lastSeenDeltaMs.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfileOrBuilder.java:29

↓ 5 callersMethodgetSeenCount

<code>int32 seen_count = 4;</code> @return The seenCount.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfileOrBuilder.java:49

↓ 5 callersMethodgetVertexId

()

java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/Vertex.java:16

↓ 5 callersMethodhandle

(APIGatewayV2ProxyRequestEvent request)

deployments/aws-lambda/src/main/java/org/apache/flink/statefun/playground/aws/APIGatewayStateFunHandlerProxy.java:46

↓ 4 callersMethodadd

(String itemId, int quantity)

java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/UserShoppingCartFn.java:183

↓ 4 callersMethodid

()

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundEgressSpec.java:26

↓ 3 callersMethodequals

(final java.lang.Object obj)

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:340

↓ 3 callersMethodgetAge

<code>int32 age = 5;</code> @return The age.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfileOrBuilder.java:56

↓ 3 callersMethodgetDescriptor

()

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:114

↓ 3 callersMethodgetFriendList

<code>repeated string friend = 6;</code> @return A list containing the friend.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:241

↓ 3 callersMethodgetLoginLocation

<code>string login_location = 3;</code> @return The loginLocation.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfileOrBuilder.java:36

↓ 3 callersMethodgetSource

()

java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/VertexComponentChange.java:26

↓ 3 callersMethodgetTarget

()

java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/VertexComponentChange.java:30

↓ 3 callersMethodsetLastSeenDeltaMs

<code>int64 last_seen_delta_ms = 2;</code> @param value The lastSeenDeltaMs to set. @return This builder for chaining.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:798

↓ 3 callersMethodsetName

<code>string name = 1;</code> @param value The name to set. @return This builder for chaining.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:746

↓ 3 callersMethodsetSeenCount

<code>int32 seen_count = 4;</code> @param value The seenCount to set. @return This builder for chaining.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:907

↓ 2 callersMethodbroadcastVertexConnectedComponentChange

( Context context, int source, Iterable<Integer> neighbours, int componentId)

java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/ConnectedComponentsFn.java:120

↓ 2 callersMethodcreate

(int source, int target, int componentId)

java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/VertexComponentChange.java:38

↓ 2 callersMethodgetAge

<code>int32 age = 5;</code> @return The age.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:230

↓ 2 callersMethodgetCurrentNeighbours

(Context context)

java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/ConnectedComponentsFn.java:116

↓ 2 callersMethodgetEntries

()

java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/UserShoppingCartFn.java:196

↓ 2 callersMethodgetLastSeenDeltaMs

<code>int64 last_seen_delta_ms = 2;</code> @return The lastSeenDeltaMs.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:173

↓ 2 callersMethodgetLoginLocation

<code>string login_location = 3;</code> @return The loginLocation.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:184

↓ 2 callersMethodgetLoginLocationBytes

<code>string login_location = 3;</code> @return The bytes for loginLocation.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:200

↓ 2 callersMethodgetName

<code>string name = 1;</code> @return The name.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:138

↓ 2 callersMethodgetNameBytes

<code>string name = 1;</code> @return The bytes for name.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:154

↓ 2 callersMethodgetQuantity

()

java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:183

↓ 2 callersMethodgetSeenCount

<code>int32 seen_count = 4;</code> @return The seenCount.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:219

↓ 2 callersMethodmaybeForceBuilderInitialization

()

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:526

↓ 2 callersMethodmergeFrom

(com.google.protobuf.Message other)

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:626

↓ 2 callersMethodonException

(HttpServerExchange exchange, Throwable t)

java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Expose.java:94

↓ 2 callersMethodparseFrom

(java.nio.ByteBuffer data)

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:389

↓ 2 callersMethodparseJson

(JsonNode jsonNode, Class<T> clazz)

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/binders/Utils.java:26

↓ 2 callersMethodremove

(String itemId, int quantity)

java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/UserShoppingCartFn.java:187

↓ 2 callersMethodsendVertexConnectedComponentChange

( Context context, int source, int target, int currentComponentId)

java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/ConnectedComponentsFn.java:127

↓ 2 callersMethodsetAge

<code>int32 age = 5;</code> @param value The age to set. @return This builder for chaining.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:940

↓ 2 callersMethodsetLoginLocation

<code>string login_location = 3;</code> @param value The loginLocation to set. @return This builder for chaining.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:855

↓ 2 callersMethodtoBuilder

()

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:482

↓ 2 callersMethodupdateComponentId

(Context context, int vertexId, int componentId)

java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/ConnectedComponentsFn.java:137

↓ 2 callersMethodvalidateComponent

(ComponentJsonObject component, TypeName expected)

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/binders/Utils.java:17

↓ 1 callersFunctionGreetingSpec

()

go/showcase/pkg/showcase/part6/greetings_fn.go:65

↓ 1 callersMethodString

()

go/showcase/pkg/showcase/part1/user_login.go:39

↓ 1 callersMethodString

()

go/showcase/pkg/showcase/part1/user_login.go:61

↓ 1 callersFunctionUserFnSpec

UserFnSpec specification of the functions. This can be used to register the function - see main.

go/showcase/pkg/showcase/part6/user_fn.go:38

↓ 1 callersMethodaddAllFriend

<code>repeated string friend = 6;</code> @param values 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:1038

↓ 1 callersMethodasEgressRecord

(T value)

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundEgress.java:48

↓ 1 callersMethodasPlaygroundEgressSpec

(EgressSpec<T> spec)

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundSinkProvider.java:15

↓ 1 callersMethodasPlaygroundIngressSpec

(IngressSpec<T> spec)

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundSourceProvider.java:16

↓ 1 callersMethodbuildPartial

()

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:572

↓ 1 callersFunctioncall_faviorite_show_service

(user_name: str)

python/showcase/showcase/__main__.py:227

↓ 1 callersFunctioncall_favorite_ice_cream_service

(user_name: str)

python/showcase/showcase/__main__.py:222

↓ 1 callersMethodclear

()

java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/UserShoppingCartFn.java:206

↓ 1 callersMethodclose

()

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressWebServer.java:44

↓ 1 callersFunctioncomputeGreeting

(name string, visits int32)

go/greeter/greeter.go:101

↓ 1 callersFunctioncomputeGreeting

(profile UserProfile)

go/showcase/pkg/showcase/part6/greetings_fn.go:54

↓ 1 callersFunctioncompute_fancy_greeting

Compute a personalized greeting, based on the number of times this @name had been seen before.

python/greeter/functions.py:68

↓ 1 callersFunctioncompute_fancy_greeting

(name, seen)

javascript/greeter/functions.js:79

↓ 1 callersMethodcreateAutoRoutable

( byte[] payload, Address address, RoutingConfig routingConfig)

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/IngressWebServer.java:68

↓ 1 callersMethodcreateDefaultLocalEnvironmentFlinkConfiguration

()

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/LocalEnvironmentEntrypoint.java:97

↓ 1 callersMethodcreateGreetingsMessage

(UserProfile profile)

java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/GreetingsFn.java:64

↓ 1 callersMethodcreateGreetingsMessage

(UserProfile profile)

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/GreetingsFn.java:69

↓ 1 callersMethodcreateJsonType

(String typeNamespace, Class<T> jsonClass)

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/TypeUtils.java:35

↓ 1 callersMethodcreateProtobufType

( String typeNamespace, Descriptors.Descriptor protobufDescriptor, Parser<T> protobufParser)

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/TypeUtils.java:42

↓ 1 callersMethodcreateQueues

(Set<String> topics)

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressWebServer.java:37

↓ 1 callersMethodcreateResponse

(Slice responseSlice)

deployments/aws-lambda/src/main/java/org/apache/flink/statefun/playground/aws/APIGatewayStateFunHandlerProxy.java:54

↓ 1 callersMethodcreateRoutingConfig

(Address address, String typeUrl)

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/IngressWebServer.java:77

↓ 1 callersFunctioncreate_requests

(path: str, loop: bool, json_path)

playground-internal/statefun-playground-producer/main.py:51

↓ 1 callersMethodderef

()

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/RefCountedContainer.java:60

↓ 1 callersMethodgetAgeFromRemoteDatabase

A mock asynchronous request to fetch a user's age information from a remote database.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part5/asyncops/AsyncOpsShowcaseFn.java:82

↓ 1 callersFunctiongetAgeFromRemoteDb

getAgeFromRemoteDb is a mock async request to fetch a users age information from a remote database.

go/showcase/pkg/showcase/part5/asyncops.go:93

↓ 1 callersMethodgetComponentId

()

java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/VertexComponentChange.java:34

↓ 1 callersMethodgetDescriptor

()

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/MyProtobufType.java:20

↓ 1 callersMethodgetFriendCount

<code>repeated string friend = 6;</code> @return The count of friend.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java:249

↓ 1 callersMethodgetFriendList

<code>repeated string friend = 6;</code> @return A list containing the friend.

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfileOrBuilder.java:63

↓ 1 callersFunctiongetFriendsListFromAnotherRemoteDatabase

getFriendsListFromAnotherRemoteDatabase is mock asynchronouse request to fetch a user's friends list from a remote database

go/showcase/pkg/showcase/part5/asyncops.go:107

↓ 1 callersMethodgetFriendsListFromAnotherRemoteDatabase

A mock asynchronouse request to fetch a user's friends list from a remote database

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part5/asyncops/AsyncOpsShowcaseFn.java:95

↓ 1 callersMethodgetItemId

()

java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:179

↓ 1 callersMethodgetLoginType

()

java/greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/types/UserLogin.java:57

↓ 1 callersMethodgetLoginType

()

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/UserLogin.java:57

↓ 1 callersMethodgetNeighbours

()

java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/Vertex.java:20

↓ 1 callersMethodgetOrCreate

(Supplier<T> supplier)

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/RefCountedContainer.java:23

↓ 1 callersMethodgetPayload

()

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressRecord.java:18

↓ 1 callersMethodgetPort

()

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundIngressSpec.java:22

↓ 1 callersMethodgetPort

()

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundEgressSpec.java:36

↓ 1 callersMethodgetQuantity

()

java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:150

↓ 1 callersMethodgetQuantity

()

java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:234

↓ 1 callersMethodgetStatus

()

java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java:261

↓ 1 callersMethodgetTopic

()

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressRecord.java:14

next →1–100 of 333, ranked by callers