Path	Lines of Code
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverseValidator.java	18
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/AsyncSink.java	78
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/Reductions.java	127
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/logger/InputStreamUtils.java	19
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettySharedResources.java	69
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValues.java	134
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/spi/ExtensionResolverAccessor.java	8
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/DynamicallyRegisteredTypes.java	33
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/StaticallyRegisteredTypes.java	36
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueSerializerSnapshot.java	51
statefun-flink/statefun-flink-harness/src/main/java/org/apache/flink/statefun/flink/harness/Harness.java	141
statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressSpec.java	74
statefun-sdk-js/src/storage.ts	114
statefun-sdk-js/src/types.ts	134