apache / flink-statefun
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
5% | 0% | 10% | 27% | 56%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
go40% | 0% | 19% | 34% | 5%
java0% | 0% | 9% | 23% | 66%
ts0% | 0% | 0% | 75% | 25%
py0% | 0% | 0% | 51% | 48%
proto0% | 0% | 0% | 44% | 55%
yaml0% | 0% | 0% | 0% | 100%
js0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
statefun-sdk-go40% | 0% | 19% | 34% | 5%
statefun-flink0% | 0% | 8% | 23% | 68%
statefun-sdk-java0% | 0% | 24% | 22% | 53%
statefun-sdk-js0% | 0% | 0% | 73% | 26%
statefun-sdk-python0% | 0% | 0% | 51% | 48%
statefun-kafka-io0% | 0% | 0% | 42% | 57%
statefun-sdk-embedded0% | 0% | 0% | 20% | 79%
statefun-sdk-protos0% | 0% | 0% | 60% | 39%
statefun-testutil0% | 0% | 0% | 51% | 48%
statefun-kinesis-io0% | 0% | 0% | 15% | 84%
tools0% | 0% | 0% | 0% | 100%
statefun-shaded0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
request-reply.pb.go
in statefun-sdk-go/v3/pkg/statefun/internal/protocol
 1318 134
types.pb.go
in statefun-sdk-go/v3/pkg/statefun/internal/protocol
 387 39
Types.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types
 347 44
ConcurrentAddressScopedStorage.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage
 282 21
ObjectOpenHashMap.java
in statefun-flink/statefun-flink-core/src/main/java/it/unimi/dsi/fastutil/objects
 271 18
RequestReplyFunction.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply
 257 17
NettyClient.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient
 254 18
types.go
in statefun-sdk-go/v3/pkg/statefun
 253 12
RoutableKafkaIngressSpec.java
in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1
 246 17
NettyRequest.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient
 206 18
RoutableKinesisIngressSpec.java
in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/ingress/v1
 200 15
StatefulFunctionsConfig.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 185 23
handler.go
in statefun-sdk-go/v3/pkg/statefun
 180 6
egress.go
in statefun-sdk-go/v3/pkg/statefun
 176 5
Selectors.java
in statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/json
 174 14
request_reply_v3.py
in statefun-sdk-python/statefun
 172 18
proto
request-reply.proto
in statefun-sdk-protos/src/main/protobuf/sdk
 167 -
handler.ts
in statefun-sdk-js/src
 164 12
TaggedBootstrapDataSerializer.java
in statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union
 164 14
TestContext.java
in statefun-testutil/src/main/java/org/apache/flink/statefun/testutils/function
 163 11
NettyRequestReplyHandler.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient
 159 12
FunctionGroupOperator.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions
 154 8
kinesis-egress.pb.go
in statefun-sdk-go/v3/pkg/statefun/internal/protocol
 150 12
StatefulFunctionsUniverse.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 149 18
KafkaIngressStartupPosition.java
in statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka
 144 30
Harness.java
in statefun-flink/statefun-flink-harness/src/main/java/org/apache/flink/statefun/flink/harness
 141 16
MessageTypeSerializer.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message
 140 23
kafka-egress.pb.go
in statefun-sdk-go/v3/pkg/statefun/internal/protocol
 139 11
UnboundedFeedbackLogger.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/logger
 139 10
types.ts
in statefun-sdk-js/src
 134 16
ObjectContainer.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/di
 134 16
PersistedRemoteFunctionValues.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply
 134 10
message.go
in statefun-sdk-go/v3/pkg/statefun
 133 17
ConcurrentContext.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler
 132 10
Reductions.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions
 127 6
PersistedAppendingBuffer.java
in statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state
 126 23
ReusableContext.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions
 124 12
LegacyRemoteModuleV30.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule
 123 12
FeedbackUnionOperator.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback
 121 9
MessageWrapper.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message
 119 22
core.ts
in statefun-sdk-js/src
 117 10
storage.ts
in statefun-sdk-js/src
 114 8
NettyRequestReplySpec.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient
 114 11
cell.go
in statefun-sdk-go/v3/pkg/statefun/internal
 112 12
ConcurrentRequestReplyHandler.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler
 112 7
GenericKafkaEgressSpec.java
in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/egress/v1
 112 9
storage.go
in statefun-sdk-go/v3/pkg/statefun
 111 9
KinesisEgressMessage.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/io
 110 14
FlinkStateDelayedMessagesBuffer.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions
 110 8
PersistedTable.java
in statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state
 109 21
Files With Most Units (Top 50)
File# lines# units
request-reply.pb.go
in statefun-sdk-go/v3/pkg/statefun/internal/protocol
 1318 134
Types.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types
 347 44
types.pb.go
in statefun-sdk-go/v3/pkg/statefun/internal/protocol
 387 39
KafkaIngressStartupPosition.java
in statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka
 144 30
PersistedAppendingBuffer.java
in statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state
 126 23
MessageTypeSerializer.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message
 140 23
StatefulFunctionsConfig.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 185 23
MessageWrapper.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message
 119 22
SideEffects.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing
 107 22
messages.py
in statefun-sdk-python/statefun
 106 22
ConcurrentAddressScopedStorage.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage
 282 21
PersistedTable.java
in statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state
 109 21
ValueSpec.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java
 100 20
request_reply_v3.py
in statefun-sdk-python/statefun
 172 18
StatefulFunctionsUniverse.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 149 18
NettyClient.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient
 254 18
NettyRequest.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient
 206 18
ObjectOpenHashMap.java
in statefun-flink/statefun-flink-core/src/main/java/it/unimi/dsi/fastutil/objects
 271 18
message.go
in statefun-sdk-go/v3/pkg/statefun
 133 17
PersistedValue.java
in statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state
 82 17
RoutableKafkaIngressSpec.java
in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1
 246 17
RequestReplyFunction.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply
 257 17
MessageFactory.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message
 93 17
OkHttpUnixSocketBridge.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn
 100 17
TestContext.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing
 87 16
types.ts
in statefun-sdk-js/src
 134 16
ProtobufTypeSerializer.java
in statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/protobuf
 92 16
Harness.java
in statefun-flink/statefun-flink-harness/src/main/java/org/apache/flink/statefun/flink/harness
 141 16
ObjectContainer.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/di
 134 16
HashCommon.java
in statefun-flink/statefun-flink-core/src/main/java/it/unimi/dsi/fastutil
 91 16
IngressRecord.java
in statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/ingress
 82 15
MessageBuilder.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message
 82 15
RoutableKinesisIngressSpec.java
in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/ingress/v1
 200 15
FlinkFunctionTypeMetrics.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics
 96 15
KinesisIngressBuilder.java
in statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/ingress
 106 14
AwsCredentials.java
in statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/auth
 73 14
KafkaIngressBuilder.java
in statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka
 108 14
KinesisEgressMessage.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/io
 110 14
message.ts
in statefun-sdk-js/src
 104 14
Selectors.java
in statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/json
 174 14
TaggedBootstrapDataSerializer.java
in statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union
 164 14
ModuleSpecs.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/spi
 100 14
DefaultHttpRequestReplyClientSpec.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn
 90 14
AwsRegion.java
in statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/auth
 75 13
KafkaProducerSemantic.java
in statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka
 51 13
KafkaEgressMessage.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/io
 98 13
UnimplementedTypeSerializer.java
in statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common
 60 13
KinesisIngressStartupPosition.java
in statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/ingress
 64 12
KafkaEgressBuilder.java
in statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka
 66 12
types.go
in statefun-sdk-go/v3/pkg/statefun
 253 12
Files With Long Lines (Top 17)

There are 17 files with lines longer than 120 characters. In total, there are 42 long lines.

File# lines# units# long lines
request-reply.pb.go
in statefun-sdk-go/v3/pkg/statefun/internal/protocol
 1318 134 18
egress.ts
in statefun-sdk-js/src
 85 3 4
handler.go
in statefun-sdk-go/v3/pkg/statefun
 180 6 3
value_spec.go
in statefun-sdk-go/v3/pkg/statefun
 65 6 2
kinesis-egress.pb.go
in statefun-sdk-go/v3/pkg/statefun/internal/protocol
 150 12 2
StatefulFunctionsConfig.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 185 23 2
KafkaIngressSpec.java
in statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka
 74 9 1
cell.go
in statefun-sdk-go/v3/pkg/statefun/internal
 112 12 1
context.go
in statefun-sdk-go/v3/pkg/statefun
 106 9 1
proto
request-reply.proto
in statefun-sdk-protos/src/main/protobuf/sdk
 167 - 1
storage.ts
in statefun-sdk-js/src
 114 8 1
handler.ts
in statefun-sdk-js/src
 164 12 1
PersistedStateRegistry.java
in statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state
 57 9 1
RequestReplyFunction.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply
 257 17 1
PersistedRemoteFunctionValues.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply
 134 10 1
MessageFactory.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message
 93 17 1
NettyClient.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient
 254 18 1
Correlations

File Size vs. Commits (all time): 445 points

statefun-sdk-python/setup.py x: 5 commits (all time) y: 27 lines of code tools/k8s/Chart.yaml x: 8 commits (all time) y: 6 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfigValidator.java x: 9 commits (all time) y: 83 lines of code statefun-flink/statefun-flink-harness/src/main/java/org/apache/flink/statefun/flink/harness/Harness.java x: 10 commits (all time) y: 141 lines of code statefun-flink/statefun-flink-launcher/src/main/java/org/apache/flink/statefun/flink/launcher/StatefulFunctionsClusterEntryPoint.java x: 5 commits (all time) y: 108 lines of code tools/k8s/templates/config-map.yaml x: 10 commits (all time) y: 61 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java x: 20 commits (all time) y: 185 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/HttpConnectionPoolManager.java x: 2 commits (all time) y: 56 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyClient.java x: 3 commits (all time) y: 254 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequestReplySpec.java x: 4 commits (all time) y: 114 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettySharedResources.java x: 2 commits (all time) y: 69 lines of code statefun-sdk-python/statefun/request_reply_v3.py x: 4 commits (all time) y: 172 lines of code statefun-sdk-go/v3/pkg/statefun/handler.go x: 4 commits (all time) y: 180 lines of code statefun-sdk-go/v3/pkg/statefun/context.go x: 2 commits (all time) y: 106 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/DefaultHttpRequestReplyClientSpec.java x: 4 commits (all time) y: 90 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequestReplyClientFactory.java x: 2 commits (all time) y: 39 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyTransportModule.java x: 3 commits (all time) y: 14 lines of code statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/AsyncRequestReplyFunctionBuilder.java x: 1 commits (all time) y: 58 lines of code statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/RequestReplyFunctionBuilder.java x: 8 commits (all time) y: 60 lines of code statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/SerializableHttpFunctionProvider.java x: 5 commits (all time) y: 46 lines of code statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/StatefulFunctionBuilder.java x: 1 commits (all time) y: 18 lines of code statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/StatefulFunctionDataStreamBuilder.java x: 8 commits (all time) y: 90 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage/ConcurrentAddressScopedStorage.java x: 3 commits (all time) y: 282 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/common/MailboxExecutorFacade.java x: 2 commits (all time) y: 16 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackSinkOperator.java x: 3 commits (all time) y: 52 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackUnionOperator.java x: 7 commits (all time) y: 121 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackUnionOperatorFactory.java x: 7 commits (all time) y: 67 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionGroupDispatchFactory.java x: 4 commits (all time) y: 54 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionGroupOperator.java x: 18 commits (all time) y: 154 lines of code statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/operator/FunctionsStateBootstrapOperator.java x: 6 commits (all time) y: 70 lines of code statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/json/StateFunObjectMapper.java x: 2 commits (all time) y: 43 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/DefaultHttpRequestReplyClientFactory.java x: 4 commits (all time) y: 79 lines of code tools/k8s/values.yaml x: 6 commits (all time) y: 18 lines of code tools/docker/flink-distribution-template/conf/flink-conf.yaml x: 16 commits (all time) y: 19 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/RouterTranslator.java x: 3 commits (all time) y: 42 lines of code statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/ResourceLocator.java x: 2 commits (all time) y: 85 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverses.java x: 4 commits (all time) y: 21 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/JsonServiceLoader.java x: 7 commits (all time) y: 101 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/spi/Modules.java x: 6 commits (all time) y: 66 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionEndpointSpec.java x: 5 commits (all time) y: 95 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/TransportClientConstants.java x: 3 commits (all time) y: 8 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/TransportClientSpec.java x: 2 commits (all time) y: 29 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/LocalFunctionGroup.java x: 2 commits (all time) y: 36 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/MessageFactory.java x: 5 commits (all time) y: 93 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FlinkFunctionTypeMetrics.java x: 7 commits (all time) y: 96 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FlinkUserMetrics.java x: 1 commits (all time) y: 27 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FunctionTypeMetrics.java x: 5 commits (all time) y: 15 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/IngressRouterOperator.java x: 4 commits (all time) y: 98 lines of code statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/BootstrapDatasetUnion.java x: 2 commits (all time) y: 102 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Context.java x: 3 commits (all time) y: 25 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/Router.java x: 2 commits (all time) y: 15 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/metrics/Counter.java x: 1 commits (all time) y: 11 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/metrics/Metrics.java x: 1 commits (all time) y: 4 lines of code statefun-testutil/src/main/java/org/apache/flink/statefun/testutils/function/TestContext.java x: 4 commits (all time) y: 163 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/RequestReplyFunction.java x: 17 commits (all time) y: 257 lines of code statefun-sdk-js/src/context.ts x: 2 commits (all time) y: 66 lines of code statefun-sdk-js/src/core.ts x: 2 commits (all time) y: 117 lines of code statefun-sdk-js/src/handler.ts x: 2 commits (all time) y: 164 lines of code statefun-sdk-js/src/storage.ts x: 2 commits (all time) y: 114 lines of code statefun-sdk-js/src/types.ts x: 2 commits (all time) y: 134 lines of code statefun-sdk-go/v3/pkg/statefun/egress.go x: 3 commits (all time) y: 176 lines of code statefun-sdk-go/v3/pkg/statefun/internal/cell.go x: 3 commits (all time) y: 112 lines of code statefun-sdk-go/v3/pkg/statefun/cancellation.go x: 1 commits (all time) y: 24 lines of code statefun-sdk-go/v3/pkg/statefun/internal/protocol/kafka-egress.pb.go x: 1 commits (all time) y: 139 lines of code statefun-sdk-go/v3/pkg/statefun/internal/protocol/kinesis-egress.pb.go x: 1 commits (all time) y: 150 lines of code statefun-sdk-go/v3/pkg/statefun/internal/protocol/request-reply.pb.go x: 1 commits (all time) y: 1318 lines of code statefun-sdk-go/v3/pkg/statefun/internal/protocol/types.pb.go x: 1 commits (all time) y: 387 lines of code statefun-sdk-go/v3/pkg/statefun/message.go x: 1 commits (all time) y: 133 lines of code statefun-sdk-go/v3/pkg/statefun/typename.go x: 1 commits (all time) y: 80 lines of code statefun-sdk-go/v3/pkg/statefun/types.go x: 1 commits (all time) y: 253 lines of code statefun-sdk-go/v3/pkg/statefun/value_spec.go x: 1 commits (all time) y: 65 lines of code statefun-sdk-protos/src/main/protobuf/io/kafka-egress.proto x: 3 commits (all time) y: 27 lines of code statefun-sdk-protos/src/main/protobuf/sdk/request-reply.proto x: 6 commits (all time) y: 167 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/ChannelAttributes.java x: 1 commits (all time) y: 9 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyHeaders.java x: 1 commits (all time) y: 37 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyProtobuf.java x: 1 commits (all time) y: 71 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequest.java x: 1 commits (all time) y: 206 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequestReplyHandler.java x: 1 commits (all time) y: 159 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequestTimeoutTask.java x: 1 commits (all time) y: 33 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionProvider.java x: 19 commits (all time) y: 33 lines of code statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/protobuf/ProtobufSerializer.java x: 2 commits (all time) y: 78 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverse.java x: 5 commits (all time) y: 149 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/LegacyRemoteModuleV30.java x: 1 commits (all time) y: 123 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/ModuleConfigurationException.java x: 2 commits (all time) y: 10 lines of code statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/KafkaSinkProvider.java x: 3 commits (all time) y: 65 lines of code statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/egress/v1/GenericKafkaEgressSpec.java x: 1 commits (all time) y: 112 lines of code statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressDeserializer.java x: 1 commits (all time) y: 50 lines of code statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressSpec.java x: 1 commits (all time) y: 246 lines of code statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/AwsCredentialsJsonDeserializer.java x: 1 commits (all time) y: 45 lines of code statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/egress/v1/GenericKinesisEgressSpec.java x: 1 commits (all time) y: 91 lines of code statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/ingress/v1/RoutableKinesisIngressSpec.java x: 1 commits (all time) y: 200 lines of code statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaEgressBuilder.java x: 4 commits (all time) y: 66 lines of code statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaEgressSpec.java x: 2 commits (all time) y: 51 lines of code statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/ingress/KinesisIngressBuilder.java x: 4 commits (all time) y: 106 lines of code statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/json/Selectors.java x: 7 commits (all time) y: 174 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/MessageWrapper.java x: 3 commits (all time) y: 119 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing/SideEffects.java x: 1 commits (all time) y: 107 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing/TestContext.java x: 1 commits (all time) y: 87 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/Reductions.java x: 13 commits (all time) y: 127 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/Message.java x: 4 commits (all time) y: 13 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/ProtobufMessage.java x: 3 commits (all time) y: 89 lines of code statefun-flink/statefun-flink-core/src/main/protobuf/stateful-functions.proto x: 4 commits (all time) y: 43 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/Context.java x: 3 commits (all time) y: 19 lines of code statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressBuilder.java x: 11 commits (all time) y: 108 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValues.java x: 14 commits (all time) y: 134 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/Expiration.java x: 3 commits (all time) y: 40 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/StatefulFunctionSpec.java x: 3 commits (all time) y: 60 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/TypeName.java x: 3 commits (all time) y: 81 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/ValueSpec.java x: 6 commits (all time) y: 100 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/SimpleType.java x: 3 commits (all time) y: 73 lines of code statefun-sdk-python/statefun/utils.py x: 2 commits (all time) y: 59 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/TypeName.java x: 1 commits (all time) y: 56 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/match/MatchBinder.java x: 1 commits (all time) y: 73 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/PersistedAppendingBuffer.java x: 1 commits (all time) y: 126 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/ProtoUtils.java x: 3 commits (all time) y: 71 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/Types.java x: 2 commits (all time) y: 347 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/FlinkState.java x: 7 commits (all time) y: 90 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/FlinkStateBinder.java x: 4 commits (all time) y: 73 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/PersistedStates.java x: 9 commits (all time) y: 99 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/sdk/state/ApiExtension.java x: 6 commits (all time) y: 23 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackKey.java x: 3 commits (all time) y: 33 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/FlinkUniverse.java x: 6 commits (all time) y: 31 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/logger/UnboundedFeedbackLogger.java x: 6 commits (all time) y: 139 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/MessageTypeSerializer.java x: 2 commits (all time) y: 140 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/CheckpointToMessage.java x: 2 commits (all time) y: 24 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/StatefulFunctionTranslator.java x: 2 commits (all time) y: 93 lines of code tools/k8s/templates/master-deployment.yaml x: 3 commits (all time) y: 51 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/RetryingCallback.java x: 7 commits (all time) y: 109 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/OkHttpUtils.java x: 7 commits (all time) y: 45 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/StatefulFunctionRepository.java x: 8 commits (all time) y: 56 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/AsyncSink.java x: 5 commits (all time) y: 78 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/Sources.java x: 3 commits (all time) y: 97 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/OkHttpUnixSocketBridge.java x: 1 commits (all time) y: 100 lines of code statefun-flink/statefun-flink-launcher/src/main/java/org/apache/flink/statefun/flink/launcher/StatefulFunctionsJobGraphRetriever.java x: 2 commits (all time) y: 98 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverseProvider.java x: 2 commits (all time) y: 5 lines of code statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/StatefulFunctionsSavepointCreator.java x: 4 commits (all time) y: 71 lines of code statefun-flink/statefun-flink-core/src/main/java/it/unimi/dsi/fastutil/objects/ObjectOpenHashMap.java x: 2 commits (all time) y: 271 lines of code statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/KafkaSourceProvider.java x: 7 commits (all time) y: 70 lines of code statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressStartupPosition.java x: 3 commits (all time) y: 144 lines of code statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressSpec.java x: 7 commits (all time) y: 74 lines of code statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataSerializer.java x: 1 commits (all time) y: 164 lines of code
1318.0
lines of code
  min: 4.0
  average: 55.44
  25th percentile: 13.0
  median: 38.0
  75th percentile: 73.0
  max: 1318.0
0 20.0
commits (all time)
min: 1.0 | average: 2.31 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 20.0

File Size vs. Contributors (all time): 445 points

statefun-sdk-python/setup.py x: 3 contributors (all time) y: 27 lines of code tools/k8s/Chart.yaml x: 3 contributors (all time) y: 6 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfigValidator.java x: 5 contributors (all time) y: 83 lines of code statefun-flink/statefun-flink-harness/src/main/java/org/apache/flink/statefun/flink/harness/Harness.java x: 5 contributors (all time) y: 141 lines of code statefun-flink/statefun-flink-launcher/src/main/java/org/apache/flink/statefun/flink/launcher/StatefulFunctionsClusterEntryPoint.java x: 4 contributors (all time) y: 108 lines of code tools/k8s/templates/config-map.yaml x: 4 contributors (all time) y: 61 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java x: 6 contributors (all time) y: 185 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/HttpConnectionPoolManager.java x: 2 contributors (all time) y: 56 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyClient.java x: 3 contributors (all time) y: 254 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequestReplySpec.java x: 4 contributors (all time) y: 114 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettySharedResources.java x: 2 contributors (all time) y: 69 lines of code statefun-sdk-python/statefun/request_reply_v3.py x: 3 contributors (all time) y: 172 lines of code statefun-sdk-go/v3/pkg/statefun/handler.go x: 2 contributors (all time) y: 180 lines of code statefun-sdk-go/v3/pkg/statefun/context.go x: 2 contributors (all time) y: 106 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/DefaultHttpRequestReplyClientSpec.java x: 2 contributors (all time) y: 90 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequestReplyClientFactory.java x: 2 contributors (all time) y: 39 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyTransportModule.java x: 3 contributors (all time) y: 14 lines of code statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/AsyncRequestReplyFunctionBuilder.java x: 1 contributors (all time) y: 58 lines of code statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/RequestReplyFunctionBuilder.java x: 3 contributors (all time) y: 60 lines of code statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/SerializableHttpFunctionProvider.java x: 3 contributors (all time) y: 46 lines of code statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/StatefulFunctionBuilder.java x: 1 contributors (all time) y: 18 lines of code statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/StatefulFunctionDataStreamBuilder.java x: 4 contributors (all time) y: 90 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage/ConcurrentAddressScopedStorage.java x: 3 contributors (all time) y: 282 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/common/MailboxExecutorFacade.java x: 2 contributors (all time) y: 16 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackSinkOperator.java x: 3 contributors (all time) y: 52 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackUnionOperator.java x: 4 contributors (all time) y: 121 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackUnionOperatorFactory.java x: 4 contributors (all time) y: 67 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionGroupOperator.java x: 5 contributors (all time) y: 154 lines of code statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/operator/FunctionsStateBootstrapOperator.java x: 5 contributors (all time) y: 70 lines of code statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/json/StateFunObjectMapper.java x: 2 contributors (all time) y: 43 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/DefaultHttpRequestReplyClientFactory.java x: 2 contributors (all time) y: 79 lines of code tools/k8s/values.yaml x: 3 contributors (all time) y: 18 lines of code tools/docker/flink-distribution-template/conf/flink-conf.yaml x: 4 contributors (all time) y: 19 lines of code statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/ResourceLocator.java x: 2 contributors (all time) y: 85 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverses.java x: 3 contributors (all time) y: 21 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/JsonServiceLoader.java x: 3 contributors (all time) y: 101 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/spi/Modules.java x: 5 contributors (all time) y: 66 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionEndpointSpec.java x: 2 contributors (all time) y: 95 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/TransportClientConstants.java x: 2 contributors (all time) y: 8 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/TransportClientSpec.java x: 2 contributors (all time) y: 29 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/LocalFunctionGroup.java x: 2 contributors (all time) y: 36 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/ReusableContext.java x: 3 contributors (all time) y: 124 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/MessageFactory.java x: 3 contributors (all time) y: 93 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FlinkFunctionTypeMetrics.java x: 4 contributors (all time) y: 96 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FlinkUserMetrics.java x: 1 contributors (all time) y: 27 lines of code statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/BootstrapDatasetUnion.java x: 2 contributors (all time) y: 102 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Context.java x: 2 contributors (all time) y: 25 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/Router.java x: 2 contributors (all time) y: 15 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/metrics/Counter.java x: 1 contributors (all time) y: 11 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/metrics/Metrics.java x: 1 contributors (all time) y: 4 lines of code statefun-testutil/src/main/java/org/apache/flink/statefun/testutils/function/TestContext.java x: 4 contributors (all time) y: 163 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/RequestReplyFunction.java x: 3 contributors (all time) y: 257 lines of code statefun-sdk-js/src/context.ts x: 2 contributors (all time) y: 66 lines of code statefun-sdk-js/src/core.ts x: 2 contributors (all time) y: 117 lines of code statefun-sdk-js/src/handler.ts x: 2 contributors (all time) y: 164 lines of code statefun-sdk-js/src/storage.ts x: 2 contributors (all time) y: 114 lines of code statefun-sdk-js/src/types.ts x: 2 contributors (all time) y: 134 lines of code statefun-sdk-go/v3/pkg/statefun/egress.go x: 1 contributors (all time) y: 176 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/binders/v2/HttpEndpointBinderV2.java x: 1 contributors (all time) y: 53 lines of code statefun-sdk-go/v3/pkg/statefun/internal/cell.go x: 1 contributors (all time) y: 112 lines of code statefun-sdk-go/v3/pkg/statefun/cancellation.go x: 1 contributors (all time) y: 24 lines of code statefun-sdk-go/v3/pkg/statefun/internal/protocol/kafka-egress.pb.go x: 1 contributors (all time) y: 139 lines of code statefun-sdk-go/v3/pkg/statefun/internal/protocol/kinesis-egress.pb.go x: 1 contributors (all time) y: 150 lines of code statefun-sdk-go/v3/pkg/statefun/internal/protocol/request-reply.pb.go x: 1 contributors (all time) y: 1318 lines of code statefun-sdk-go/v3/pkg/statefun/internal/protocol/types.pb.go x: 1 contributors (all time) y: 387 lines of code statefun-sdk-go/v3/pkg/statefun/message.go x: 1 contributors (all time) y: 133 lines of code statefun-sdk-go/v3/pkg/statefun/typename.go x: 1 contributors (all time) y: 80 lines of code statefun-sdk-go/v3/pkg/statefun/types.go x: 1 contributors (all time) y: 253 lines of code statefun-sdk-go/v3/pkg/statefun/value_spec.go x: 1 contributors (all time) y: 65 lines of code statefun-sdk-protos/src/main/protobuf/sdk/request-reply.proto x: 3 contributors (all time) y: 167 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/ChannelAttributes.java x: 1 contributors (all time) y: 9 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyHeaders.java x: 1 contributors (all time) y: 37 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyProtobuf.java x: 1 contributors (all time) y: 71 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequest.java x: 1 contributors (all time) y: 206 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequestReplyHandler.java x: 1 contributors (all time) y: 159 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequestTimeoutTask.java x: 1 contributors (all time) y: 33 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionProvider.java x: 3 contributors (all time) y: 33 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverse.java x: 3 contributors (all time) y: 149 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/LegacyRemoteModuleV30.java x: 1 contributors (all time) y: 123 lines of code statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressDeserializer.java x: 1 contributors (all time) y: 50 lines of code statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressSpec.java x: 1 contributors (all time) y: 246 lines of code statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/AwsCredentialsJsonDeserializer.java x: 1 contributors (all time) y: 45 lines of code statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/egress/v1/GenericKinesisEgressSpec.java x: 1 contributors (all time) y: 91 lines of code statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/ingress/v1/RoutableKinesisIngressSpec.java x: 1 contributors (all time) y: 200 lines of code statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaEgressSpec.java x: 2 contributors (all time) y: 51 lines of code statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/ingress/KinesisIngressBuilder.java x: 1 contributors (all time) y: 106 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/MessageWrapper.java x: 3 contributors (all time) y: 119 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing/TestContext.java x: 1 contributors (all time) y: 87 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/Reductions.java x: 2 contributors (all time) y: 127 lines of code statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/KinesisSourceProvider.java x: 1 contributors (all time) y: 98 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/StatefulFunctionSpec.java x: 2 contributors (all time) y: 60 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/SimpleType.java x: 2 contributors (all time) y: 73 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/match/MatchBinder.java x: 1 contributors (all time) y: 73 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/PersistedAppendingBuffer.java x: 1 contributors (all time) y: 126 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/Types.java x: 2 contributors (all time) y: 347 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/logger/UnboundedFeedbackLogger.java x: 2 contributors (all time) y: 139 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/OkHttpUnixSocketBridge.java x: 1 contributors (all time) y: 100 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverseProvider.java x: 2 contributors (all time) y: 5 lines of code statefun-flink/statefun-flink-core/src/main/java/it/unimi/dsi/fastutil/objects/ObjectOpenHashMap.java x: 2 contributors (all time) y: 271 lines of code statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressStartupPosition.java x: 1 contributors (all time) y: 144 lines of code statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataSerializer.java x: 1 contributors (all time) y: 164 lines of code
1318.0
lines of code
  min: 4.0
  average: 55.44
  25th percentile: 13.0
  median: 38.0
  75th percentile: 73.0
  max: 1318.0
0 6.0
contributors (all time)
min: 1.0 | average: 1.5 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 6.0

File Size vs. Commits (30 days): 0 points

No data for "commits (30d)" vs. "lines of code".

File Size vs. Contributors (30 days): 0 points

No data for "contributors (30d)" vs. "lines of code".

File Size vs. Commits (90 days): 0 points

No data for "commits (90d)" vs. "lines of code".

File Size vs. Contributors (90 days): 0 points

No data for "contributors (90d)" vs. "lines of code".