Path	Lines of Code
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/Address.java	38
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/AddressScopedStorage.java	8
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/ApiExtension.java	12
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/Context.java	19
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/Expiration.java	40
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/StatefulFunction.java	6
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/StatefulFunctionSpec.java	60
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/StatefulFunctions.java	25
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/TypeName.java	81
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/ValueSpec.java	100
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/annotations/Internal.java	7
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/ConcurrentContext.java	132
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/ConcurrentRequestReplyHandler.java	112
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/MoreFutures.java	39
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/ProtoUtils.java	71
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/RequestReplyHandler.java	6
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/io/KafkaEgressMessage.java	98
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/io/KinesisEgressMessage.java	110
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/EgressMessage.java	8
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/EgressMessageBuilder.java	54
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/EgressMessageWrapper.java	52
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/Message.java	24
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/MessageBuilder.java	82
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/MessageWrapper.java	119
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/ByteStringSlice.java	51
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/Slice.java	13
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/SliceOutput.java	77
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/SliceProtobufUtil.java	32
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/Slices.java	34
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage/ConcurrentAddressScopedStorage.java	282
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage/IllegalStorageAccessException.java	7
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage/StateValueContexts.java	76
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing/SideEffects.java	107
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing/TestAddressScopedStorage.java	28
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing/TestContext.java	87
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/SimpleType.java	73
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/SliceType.java	38
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/Type.java	13
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/TypeCharacteristics.java	4
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/TypeSerializer.java	6
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/Types.java	347