Path	Lines of Code
statefun-e2e-tests/pom.xml	107
statefun-e2e-tests/statefun-e2e-tests-common/pom.xml	88
statefun-e2e-tests/statefun-e2e-tests-common/src/main/java/org/apache/flink/statefun/e2e/common/StatefulFunctionsAppContainers.java	233
statefun-e2e-tests/statefun-e2e-tests-common/src/main/java/org/apache/flink/statefun/e2e/common/kafka/KafkaIOVerifier.java	114
statefun-e2e-tests/statefun-e2e-tests-common/src/main/java/org/apache/flink/statefun/e2e/common/kafka/KafkaProtobufSerializer.java	30
statefun-e2e-tests/statefun-e2e-tests-common/src/main/resources/flink-conf.yaml	21
statefun-e2e-tests/statefun-smoke-e2e-common/pom.xml	81
statefun-e2e-tests/statefun-smoke-e2e-common/src/main/java/org/apache/flink/statefun/e2e/smoke/SimpleVerificationServer.java	102
statefun-e2e-tests/statefun-smoke-e2e-common/src/main/java/org/apache/flink/statefun/e2e/smoke/SmokeRunner.java	61
statefun-e2e-tests/statefun-smoke-e2e-common/src/main/java/org/apache/flink/statefun/e2e/smoke/SmokeRunnerParameters.java	174
statefun-e2e-tests/statefun-smoke-e2e-common/src/main/protobuf/commands.proto	68
statefun-e2e-tests/statefun-smoke-e2e-common/src/test/java/org/apache/flink/statefun/e2e/smoke/SmokeRunnerParametersTest.java	21
statefun-e2e-tests/statefun-smoke-e2e-driver/pom.xml	139
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/driver/CommandFlinkSource.java	170
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/driver/CommandGenerator.java	133
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/driver/CommandRouter.java	20
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/driver/Constants.java	19
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/driver/DriverModule.java	53
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/driver/FunctionStateTracker.java	43
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/driver/Ids.java	17
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/java/org/apache/flink/statefun/e2e/smoke/driver/Types.java	69
statefun-e2e-tests/statefun-smoke-e2e-driver/src/main/protobuf/internal.proto	29
statefun-e2e-tests/statefun-smoke-e2e-driver/src/test/java/org/apache/flink/statefun/e2e/smoke/driver/CommandGeneratorTest.java	18
statefun-e2e-tests/statefun-smoke-e2e-driver/src/test/java/org/apache/flink/statefun/e2e/smoke/driver/FunctionStateTrackerTest.java	23
statefun-e2e-tests/statefun-smoke-e2e-driver/src/test/java/org/apache/flink/statefun/e2e/smoke/testutils/Utils.java	32
statefun-e2e-tests/statefun-smoke-e2e-embedded/pom.xml	64
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/embedded/AsyncCompleter.java	65
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/embedded/CommandInterpreter.java	138
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/embedded/CommandInterpreterFn.java	17
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/embedded/EmbeddedFnModule.java	21
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/main/java/org/apache/flink/statefun/e2e/smoke/embedded/FunctionProvider.java	17
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/test/java/org/apache/flink/statefun/e2e/smoke/embedded/EmbeddedSmokeHarnessTest.java	59
statefun-e2e-tests/statefun-smoke-e2e-embedded/src/test/java/org/apache/flink/statefun/e2e/smoke/embedded/SmokeVerificationEmbeddedE2E.java	20
statefun-e2e-tests/statefun-smoke-e2e-golang/pom.xml	13
statefun-e2e-tests/statefun-smoke-e2e-golang/src/main/go/CommandInterpreterFn.go	98
statefun-e2e-tests/statefun-smoke-e2e-golang/src/main/go/SmokeE2EMain.go	29
statefun-e2e-tests/statefun-smoke-e2e-golang/src/main/go/commands.pb.go	764
statefun-e2e-tests/statefun-smoke-e2e-golang/src/main/protobuf/commands.proto	63
statefun-e2e-tests/statefun-smoke-e2e-golang/src/test/java/org/apache/flink/statefun/e2e/smoke/golang/SmokeVerificationGolangE2E.java	47
statefun-e2e-tests/statefun-smoke-e2e-golang/src/test/resources/remote-module/module.yaml	5
statefun-e2e-tests/statefun-smoke-e2e-java/pom.xml	85
statefun-e2e-tests/statefun-smoke-e2e-java/src/main/java/org/apache/flink/statefun/e2e/smoke/java/CommandInterpreter.java	92
statefun-e2e-tests/statefun-smoke-e2e-java/src/main/java/org/apache/flink/statefun/e2e/smoke/java/CommandInterpreterAppServer.java	107
statefun-e2e-tests/statefun-smoke-e2e-java/src/main/java/org/apache/flink/statefun/e2e/smoke/java/CommandInterpreterFn.java	18
statefun-e2e-tests/statefun-smoke-e2e-java/src/main/java/org/apache/flink/statefun/e2e/smoke/java/Constants.java	31
statefun-e2e-tests/statefun-smoke-e2e-java/src/main/protobuf/commands.proto	62
statefun-e2e-tests/statefun-smoke-e2e-java/src/main/resources/certs/a_server.key.p8	27
statefun-e2e-tests/statefun-smoke-e2e-java/src/test/java/org/apache/flink/statefun/e2e/smoke/java/SmokeVerificationJavaE2E.java	40
statefun-e2e-tests/statefun-smoke-e2e-java/src/test/resources/certs/a_client.key.p8	27
statefun-e2e-tests/statefun-smoke-e2e-java/src/test/resources/remote-module/module.yaml	11
statefun-e2e-tests/statefun-smoke-e2e-js/pom.xml	13
statefun-e2e-tests/statefun-smoke-e2e-js/src/test/java/org/apache/flink/statefun/e2e/smoke/js/SmokeVerificationJsE2E.java	42
statefun-e2e-tests/statefun-smoke-e2e-js/src/test/resources/remote-function/commands_pb.js	941
statefun-e2e-tests/statefun-smoke-e2e-js/src/test/resources/remote-function/smoke.js	85
statefun-e2e-tests/statefun-smoke-e2e-js/src/test/resources/remote-module/module.yaml	5
statefun-e2e-tests/statefun-smoke-e2e-multilang-base/pom.xml	56
statefun-e2e-tests/statefun-smoke-e2e-multilang-harness/pom.xml	41
statefun-e2e-tests/statefun-smoke-e2e-multilang-harness/src/test/java/org/apache/flink/statefun/e2e/smoke/multilang/harness/MultiLangSmokeHarnessTest.java	59
statefun-e2e-tests/statefun-smoke-e2e-multilang-harness/src/test/resources/module.yaml	5
statefun-flink/statefun-flink-common/src/test/java/org/apache/flink/statefun/flink/common/ResourceLocatorTest.java	82
statefun-flink/statefun-flink-common/src/test/java/org/apache/flink/statefun/flink/common/json/SelectorsTest.java	113
statefun-flink/statefun-flink-common/src/test/java/org/apache/flink/statefun/flink/common/protobuf/ProtobufSerializerTest.java	75
statefun-flink/statefun-flink-common/src/test/java/org/apache/flink/statefun/flink/common/protobuf/ProtobufTypeSerializerTest.java	34
statefun-flink/statefun-flink-common/src/test/protobuf/test.proto	53
statefun-flink/statefun-flink-common/src/test/resources/bar-module/module.yaml	39
statefun-flink/statefun-flink-common/src/test/resources/foo-module/module.yaml	11
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfigTest.java	80
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverseTest.java	26
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/TestUtils.java	27
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/backpressure/BoundedExponentialBackoffTest.java	38
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/backpressure/ThresholdBackPressureValveTest.java	52
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/di/ObjectContainerTest.java	18
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/feedback/CheckpointsTest.java	98
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/feedback/FeedbackChannelTest.java	78
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/functions/LocalStatefulFunctionGroupTest.java	101
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/functions/PendingAsyncOperationsTest.java	138
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/functions/PredefinedFunctionLoaderTest.java	79
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/functions/ReductionsTest.java	540
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/httpfn/DefaultHttpRequestReplyClientSpecTest.java	86
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/httpfn/TransportClientTest.java	211
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/httpfn/UnixDomainHttpEndpointTest.java	33
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/httpfn/UnixDomainSocketITCase.java	66
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/httpfn/binders/v1/HttpEndpointBinderV1Test.java	39
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/httpfn/binders/v2/HttpEndpointBinderV2Test.java	39
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/jsonmodule/RemoteModuleTest.java	125
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/logger/InputStreamUtilsTest.java	85
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/logger/MemorySegmentPoolTest.java	59
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/logger/OneBytePerReadByteArrayInputStream.java	16
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/logger/RandomReadLengthByteArrayInputStream.java	19
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/logger/UnboundedFeedbackLoggerTest.java	145
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/message/JavaPayloadSerializer.java	43
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/message/MessageTest.java	50
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/message/MessageTypeSerializerSnapshotTest.java	81
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/message/MessageTypeSerializerTest.java	62
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/metrics/NonNegativeCounterTest.java	19
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/nettyclient/EndpointTest.java	40
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/nettyclient/NettyClientTest.java	237
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/nettyclient/NettyProtobufTest.java	78
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequestTest.java	229
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValuesTest.java	164
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/reqreply/RequestReplyFunctionTest.java	438
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/state/PersistedStatesTest.java	281
statefun-flink/statefun-flink-core/src/test/protobuf/test.proto	53
statefun-flink/statefun-flink-core/src/test/resources/certs/a_client.key.p8	27
statefun-flink/statefun-flink-core/src/test/resources/certs/a_server.key.p8	27
statefun-flink/statefun-flink-core/src/test/resources/certs/b_client.key.p8	27
statefun-flink/statefun-flink-core/src/test/resources/certs/c_client.key.p8	26
statefun-flink/statefun-flink-core/src/test/resources/http-endpoint-binders/v1.yaml	10
statefun-flink/statefun-flink-core/src/test/resources/http-endpoint-binders/v2.yaml	12
statefun-flink/statefun-flink-core/src/test/resources/module-v3_0/module.yaml	43
statefun-flink/statefun-flink-core/src/test/resources/remote-module/module.yaml	12
statefun-flink/statefun-flink-datastream/src/test/java/org/apache/flink/statefun/flink/datastream/AsyncRequestReplyFunctionBuilderTest.java	87
statefun-flink/statefun-flink-datastream/src/test/java/org/apache/flink/statefun/flink/datastream/RequestReplyFunctionBuilderTest.java	93
statefun-flink/statefun-flink-datastream/src/test/java/org/apache/flink/statefun/flink/datastream/SerializableHttpFunctionProviderTest.java	19
statefun-flink/statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/common/ReflectionUtilTest.java	20
statefun-flink/statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/kafka/binders/egress/v1/GenericKafkaEgressBinderV1Test.java	31
statefun-flink/statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressBinderV1Test.java	36
statefun-flink/statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/kinesis/AwsAuthConfigPropertiesTest.java	137
statefun-flink/statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/kinesis/CachingPartitionerSerializerDelegateTest.java	67
statefun-flink/statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/kinesis/KinesisSinkProviderTest.java	35
statefun-flink/statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/kinesis/KinesisSourceProviderTest.java	37
statefun-flink/statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/kinesis/binders/egress/v1/GenericKinesisEgressBinderV1Test.java	31
statefun-flink/statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/kinesis/binders/ingress/v1/RoutableKinesisIngressBinderV1Test.java	38
statefun-flink/statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/testutils/TestModuleBinder.java	67
statefun-flink/statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/testutils/YamlUtils.java	18
statefun-flink/statefun-flink-io-bundle/src/test/resources/kafka-io-binders/generic-kafka-egress-v1.yaml	9
statefun-flink/statefun-flink-io-bundle/src/test/resources/kafka-io-binders/routable-kafka-ingress-v1.yaml	20
statefun-flink/statefun-flink-io-bundle/src/test/resources/kinesis-io-binders/generic-kinesis-egress-v1.yaml	15
statefun-flink/statefun-flink-io-bundle/src/test/resources/kinesis-io-binders/routable-kinesis-ingress-v1.yaml	25
statefun-flink/statefun-flink-state-processor/src/test/java/org/apache/flink/statefun/flink/state/processor/StatefulFunctionsSavepointCreatorTest.java	41
statefun-flink/statefun-flink-state-processor/src/test/java/org/apache/flink/statefun/flink/state/processor/operator/StateBootstrapperTest.java	169
statefun-flink/statefun-flink-state-processor/src/test/java/org/apache/flink/statefun/flink/state/processor/union/BootstrapDatasetUnionTest.java	103
statefun-flink/statefun-flink-state-processor/src/test/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataSerializerTest.java	81
statefun-kafka-io/src/test/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressBuilderTest.java	124
statefun-kafka-io/src/test/java/org/apache/flink/statefun/sdk/kafka/testutils/Matchers.java	32
statefun-kinesis-io/src/test/java/org/apache/flink/statefun/sdk/kinesis/KinesisEgressBuilderTest.java	32
statefun-kinesis-io/src/test/java/org/apache/flink/statefun/sdk/kinesis/KinesisIngressBuilderTest.java	39
statefun-sdk-embedded/src/test/java/org/apache/flink/statefun/sdk/state/PersistedAppendingBufferTest.java	64
statefun-sdk-embedded/src/test/java/org/apache/flink/statefun/sdk/state/PersistedStateRegistryTest.java	20
statefun-sdk-go/v3/pkg/statefun/cancellation_test.go	12
statefun-sdk-go/v3/pkg/statefun/context_test.go	150
statefun-sdk-go/v3/pkg/statefun/egress_test.go	59
statefun-sdk-go/v3/pkg/statefun/handler_test.go	70
statefun-sdk-go/v3/pkg/statefun/internal/cell_test.go	116
statefun-sdk-go/v3/pkg/statefun/message_test.go	36
statefun-sdk-go/v3/pkg/statefun/typename_test.go	27
statefun-sdk-go/v3/pkg/statefun/types_test.go	108
statefun-sdk-java/src/test/java/ValueSpecTest.java	25
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/StatefulFunctionSpecTest.java	36
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/handler/ConcurrentRequestReplyHandlerTest.java	78
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/handler/MoreFuturesTest.java	52
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/handler/TestUtils.java	63
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/slice/SliceOutputTest.java	95
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/slice/SliceProtobufUtilTest.java	13
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/storage/ConcurrentAddressScopedStorageTest.java	139
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/storage/StateValueContextsTest.java	109
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/storage/TestMutableType.java	48
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/testing/TestContextIntegrationTest.java	68
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/testing/TestContextTest.java	64
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/types/SanityPrimitiveTypeTest.java	156
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/types/SimpleTypeTest.java	40
statefun-sdk-js/test/core.test.ts	19
statefun-sdk-js/test/egress.test.ts	68
statefun-sdk-js/test/message.test.ts	62
statefun-sdk-js/test/statefun.test.ts	70
statefun-sdk-js/test/storage.test.ts	65
statefun-sdk-js/test/types.test.ts	62
statefun-sdk-python/tests/__init__.py	7
statefun-sdk-python/tests/message_test.py	16
statefun-sdk-python/tests/request_reply_test.py	147
statefun-sdk-python/tests/statefun_test.py	55
statefun-sdk-python/tests/storage_test.py	93
statefun-sdk-python/tests/typename_test.py	19
statefun-sdk-python/tests/types_test.py	27
statefun-sdk-python/tests/valuespec_test.py	26
statefun-testutil/src/test/java/org/apache/flink/statefun/testutils/function/FunctionTestHarnessTest.java	114