apache / flink-statefun
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 445 files with 24,669 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 30 files changed 6-20 times (2,770 lines of code)
    • 415 files changed 1-5 times (21,899 lines of code)
0% | 0% | 0% | 11% | 88%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 445 files with 24,669 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 1 file changed by 6-10 contributors (185 lines of code)
    • 155 files changed by 2-5 contributors (10,961 lines of code)
    • 289 files changed by 1 contributor (13,523 lines of code)
0% | 0% | <1% | 44% | 54%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, md, xml, html, go, yaml, py, sh, svg, ts, proto, js, p8, properties, json, txt, css, scss, yml, gitignore, mod, toml, gitmodules
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 13% | 86%
yaml0% | 0% | 0% | 36% | 63%
go0% | 0% | 0% | 0% | 100%
ts0% | 0% | 0% | 0% | 100%
py0% | 0% | 0% | 0% | 100%
proto0% | 0% | 0% | 0% | 100%
js0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
statefun-flink0% | 0% | 0% | 17% | 82%
statefun-kafka-io0% | 0% | 0% | 30% | 69%
tools0% | 0% | 0% | 36% | 63%
statefun-sdk-go0% | 0% | 0% | 0% | 100%
statefun-sdk-java0% | 0% | 0% | 0% | 100%
statefun-sdk-embedded0% | 0% | 0% | 0% | 100%
statefun-sdk-js0% | 0% | 0% | 0% | 100%
statefun-sdk-python0% | 0% | 0% | 0% | 100%
statefun-kinesis-io0% | 0% | 0% | 0% | 100%
statefun-testutil0% | 0% | 0% | 0% | 100%
statefun-sdk-protos0% | 0% | 0% | 0% | 100%
statefun-shaded0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
HttpFunctionProvider.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn
 33 3 2020-02-10 2021-08-12 17 3 igalshilman@gmail.com tzulitai@apache.org
flink-conf.yaml
in tools/docker/flink-distribution-template/conf
 19 - 2019-10-05 2021-12-15 16 4 igalshilman@gmail.com sjwiesman@gmail.com
FunctionGroupOperator.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions
 154 8 2020-01-22 2022-01-19 16 5 igalshilman@gmail.com trohrmann@apache.org
StatefulFunctionsConfig.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 185 23 2020-02-19 2022-03-10 16 6 sjwiesman@gmail.com filip.karnicki@gmail.com
RequestReplyFunction.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply
 257 17 2020-02-27 2021-09-22 13 3 igalshilman@gmail.com igal@apache.org
PersistedRemoteFunctionValues.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply
 134 10 2020-06-03 2021-05-25 12 2 tzulitai@apache.org tzulitai@apache.org
Reductions.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions
 127 6 2020-01-22 2021-06-14 10 2 igalshilman@gmail.com igalshilman@gmail.com
StatefulFunctionsJob.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 61 3 2020-01-22 2022-03-10 9 4 igalshilman@gmail.com filip.karnicki@gmail.com
StatefulFunctionsConfigValidator.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 83 7 2020-03-03 2022-10-06 9 5 tzulitai@apache.org 784517+galenwarren@users.no...
KafkaIngressBuilder.java
in statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka
 108 14 2020-01-22 2021-05-28 9 2 igalshilman@gmail.com tzulitai@apache.org
Harness.java
in statefun-flink/statefun-flink-harness/src/main/java/org/apache/flink/statefun/flink/harness
 141 16 2020-01-22 2022-10-06 9 5 igalshilman@gmail.com 784517+galenwarren@users.no...
Chart.yaml
in tools/k8s
 6 - 2020-03-24 2022-11-03 8 3 igalshilman@gmail.com tzulitai@apache.org
RequestReplyFunctionBuilder.java
in statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream
 60 8 2020-08-18 2022-02-09 8 3 igalshilman@gmail.com 784517+galenwarren@users.no...
config-map.yaml
in tools/k8s/templates
 61 - 2020-03-24 2022-07-03 8 4 igalshilman@gmail.com root@viper.run
StatefulFunctionDataStreamBuilder.java
in statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream
 90 10 2020-06-19 2022-02-09 8 4 igalshilman@gmail.com 784517+galenwarren@users.no...
OkHttpUtils.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn
 45 3 2020-02-10 2020-09-14 7 2 igalshilman@gmail.com igalshilman@gmail.com
FlinkState.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state
 90 7 2020-01-22 2021-01-21 7 2 igalshilman@gmail.com tzulitai@apache.org
FlinkFunctionTypeMetrics.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics
 96 15 2020-01-22 2021-10-07 7 4 igalshilman@gmail.com sjwiesman@gmail.com
FeedbackUnionOperator.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback
 121 9 2020-01-22 2022-01-19 7 4 igalshilman@gmail.com trohrmann@apache.org
Selectors.java
in statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/json
 174 14 2020-01-22 2021-07-07 7 3 igalshilman@gmail.com tzulitai@apache.org
ApiExtension.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/sdk/state
 23 5 2020-01-22 2021-01-21 6 2 igalshilman@gmail.com tzulitai@apache.org
FlinkUniverse.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation
 31 2 2020-01-22 2020-12-21 6 3 igalshilman@gmail.com igalshilman@gmail.com
Modules.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/spi
 66 3 2020-01-22 2021-12-09 6 5 igalshilman@gmail.com igal@apache.org
FeedbackUnionOperatorFactory.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback
 67 5 2020-01-22 2022-01-19 6 4 igalshilman@gmail.com trohrmann@apache.org
KafkaSourceProvider.java
in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka
 70 4 2020-01-22 2020-02-01 6 2 igalshilman@gmail.com tzulitai@apache.org
FunctionsStateBootstrapOperator.java
in statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/operator
 70 5 2020-01-22 2022-01-19 6 5 igalshilman@gmail.com trohrmann@apache.org
KafkaIngressSpec.java
in statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka
 74 9 2020-01-22 2020-02-01 6 2 igalshilman@gmail.com tzulitai@apache.org
PersistedStates.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state
 99 9 2020-02-07 2021-01-21 6 2 igalshilman@gmail.com tzulitai@apache.org
JsonServiceLoader.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule
 101 10 2020-01-22 2021-12-09 6 3 igalshilman@gmail.com igal@apache.org
ReusableContext.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions
 124 12 2020-01-22 2021-09-27 6 3 igalshilman@gmail.com igal@apache.org
KinesisFlinkIOModule.java
in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis
 13 1 2020-03-15 2021-08-03 5 1 tzulitai@apache.org tzulitai@apache.org
FunctionTypeMetrics.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics
 15 - 2020-01-22 2021-09-27 5 3 igalshilman@gmail.com igal@apache.org
values.yaml
in tools/k8s
 18 - 2020-03-24 2021-12-15 5 3 igalshilman@gmail.com sjwiesman@gmail.com
setup.py
in statefun-sdk-python
 27 - 2021-03-24 2022-11-03 5 3 igalshilman@gmail.com tzulitai@apache.org
FormatVersion.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule
 29 2 2020-03-04 2021-07-07 5 1 tzulitai@apache.org tzulitai@apache.org
SerializableHttpFunctionProvider.java
in statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream
 46 2 2020-08-18 2022-02-09 5 3 igalshilman@gmail.com 784517+galenwarren@users.no...
AsyncSink.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions
 78 4 2020-01-22 2020-09-04 5 2 igalshilman@gmail.com tzulitai@apache.org
MessageFactory.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message
 93 17 2020-01-22 2021-09-27 5 3 igalshilman@gmail.com igal@apache.org
HttpFunctionEndpointSpec.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn
 95 12 2020-11-30 2021-10-13 5 2 tzulitai@apache.org igal@apache.org
ValueSpec.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java
 100 20 2021-02-23 2021-03-30 5 2 igalshilman@gmail.com tzulitai@apache.org
StatefulFunctionsClusterEntryPoint.java
in statefun-flink/statefun-flink-launcher/src/main/java/org/apache/flink/statefun/flink/launcher
 108 7 2020-01-22 2022-10-06 5 4 igalshilman@gmail.com 784517+galenwarren@users.no...
StatefulFunctionsUniverse.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 149 18 2020-01-22 2021-08-03 5 3 igalshilman@gmail.com tzulitai@apache.org
proto
request-reply.proto
in statefun-sdk-protos/src/main/protobuf/sdk
 167 - 2021-01-27 2021-08-11 5 3 igalshilman@gmail.com sjwiesman@gmail.com
Message.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message
 13 1 2020-01-22 2021-06-14 4 1 igalshilman@gmail.com igalshilman@gmail.com
RequestReplyClient.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply
 13 - 2020-02-27 2021-07-07 4 2 igalshilman@gmail.com tzulitai@apache.org
KafkaFlinkIoModule.java
in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka
 13 1 2020-01-22 2021-08-03 4 2 igalshilman@gmail.com tzulitai@apache.org
StatefulFunctionsUniverses.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 21 2 2020-01-22 2021-12-09 4 3 igalshilman@gmail.com igal@apache.org
State.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state
 21 - 2020-01-22 2021-01-21 4 2 igalshilman@gmail.com tzulitai@apache.org
proto
stateful-functions.proto
in statefun-flink/statefun-flink-core/src/main/protobuf
 43 - 2020-01-22 2021-06-14 4 1 igalshilman@gmail.com igalshilman@gmail.com
EmbeddedTranslator.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation
 52 3 2020-06-12 2020-09-15 4 2 igalshilman@gmail.com galenwarren@users.noreply.g...
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
StatefulFunctionsConfig.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 185 23 2020-02-19 2022-03-10 16 6 sjwiesman@gmail.com filip.karnicki@gmail.com
FunctionGroupOperator.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions
 154 8 2020-01-22 2022-01-19 16 5 igalshilman@gmail.com trohrmann@apache.org
Harness.java
in statefun-flink/statefun-flink-harness/src/main/java/org/apache/flink/statefun/flink/harness
 141 16 2020-01-22 2022-10-06 9 5 igalshilman@gmail.com 784517+galenwarren@users.no...
StatefulFunctionsConfigValidator.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 83 7 2020-03-03 2022-10-06 9 5 tzulitai@apache.org 784517+galenwarren@users.no...
FunctionsStateBootstrapOperator.java
in statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/operator
 70 5 2020-01-22 2022-01-19 6 5 igalshilman@gmail.com trohrmann@apache.org
Modules.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/spi
 66 3 2020-01-22 2021-12-09 6 5 igalshilman@gmail.com igal@apache.org
flink-conf.yaml
in tools/docker/flink-distribution-template/conf
 19 - 2019-10-05 2021-12-15 16 4 igalshilman@gmail.com sjwiesman@gmail.com
StatefulFunctionsJob.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 61 3 2020-01-22 2022-03-10 9 4 igalshilman@gmail.com filip.karnicki@gmail.com
config-map.yaml
in tools/k8s/templates
 61 - 2020-03-24 2022-07-03 8 4 igalshilman@gmail.com root@viper.run
StatefulFunctionDataStreamBuilder.java
in statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream
 90 10 2020-06-19 2022-02-09 8 4 igalshilman@gmail.com 784517+galenwarren@users.no...
FlinkFunctionTypeMetrics.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics
 96 15 2020-01-22 2021-10-07 7 4 igalshilman@gmail.com sjwiesman@gmail.com
FeedbackUnionOperator.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback
 121 9 2020-01-22 2022-01-19 7 4 igalshilman@gmail.com trohrmann@apache.org
FeedbackUnionOperatorFactory.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback
 67 5 2020-01-22 2022-01-19 6 4 igalshilman@gmail.com trohrmann@apache.org
StatefulFunctionsClusterEntryPoint.java
in statefun-flink/statefun-flink-launcher/src/main/java/org/apache/flink/statefun/flink/launcher
 108 7 2020-01-22 2022-10-06 5 4 igalshilman@gmail.com 784517+galenwarren@users.no...
TestContext.java
in statefun-testutil/src/main/java/org/apache/flink/statefun/testutils/function
 163 11 2020-02-10 2021-09-27 4 4 sjwiesman@gmail.com igal@apache.org
IngressRouterOperator.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation
 98 4 2020-01-22 2021-09-27 4 4 igalshilman@gmail.com igal@apache.org
NettyRequestReplySpec.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient
 114 11 2021-08-10 2022-03-02 4 4 igalshilman@gmail.com filip.karnicki@gmail.com
HttpFunctionProvider.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn
 33 3 2020-02-10 2021-08-12 17 3 igalshilman@gmail.com tzulitai@apache.org
RequestReplyFunction.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply
 257 17 2020-02-27 2021-09-22 13 3 igalshilman@gmail.com igal@apache.org
Chart.yaml
in tools/k8s
 6 - 2020-03-24 2022-11-03 8 3 igalshilman@gmail.com tzulitai@apache.org
RequestReplyFunctionBuilder.java
in statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream
 60 8 2020-08-18 2022-02-09 8 3 igalshilman@gmail.com 784517+galenwarren@users.no...
Selectors.java
in statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/json
 174 14 2020-01-22 2021-07-07 7 3 igalshilman@gmail.com tzulitai@apache.org
FlinkUniverse.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation
 31 2 2020-01-22 2020-12-21 6 3 igalshilman@gmail.com igalshilman@gmail.com
JsonServiceLoader.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule
 101 10 2020-01-22 2021-12-09 6 3 igalshilman@gmail.com igal@apache.org
ReusableContext.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions
 124 12 2020-01-22 2021-09-27 6 3 igalshilman@gmail.com igal@apache.org
values.yaml
in tools/k8s
 18 - 2020-03-24 2021-12-15 5 3 igalshilman@gmail.com sjwiesman@gmail.com
setup.py
in statefun-sdk-python
 27 - 2021-03-24 2022-11-03 5 3 igalshilman@gmail.com tzulitai@apache.org
proto
request-reply.proto
in statefun-sdk-protos/src/main/protobuf/sdk
 167 - 2021-01-27 2021-08-11 5 3 igalshilman@gmail.com sjwiesman@gmail.com
SerializableHttpFunctionProvider.java
in statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream
 46 2 2020-08-18 2022-02-09 5 3 igalshilman@gmail.com 784517+galenwarren@users.no...
FunctionTypeMetrics.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics
 15 - 2020-01-22 2021-09-27 5 3 igalshilman@gmail.com igal@apache.org
MessageFactory.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message
 93 17 2020-01-22 2021-09-27 5 3 igalshilman@gmail.com igal@apache.org
StatefulFunctionsUniverse.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 149 18 2020-01-22 2021-08-03 5 3 igalshilman@gmail.com tzulitai@apache.org
request_reply_v3.py
in statefun-sdk-python/statefun
 172 18 2021-03-24 2022-02-25 4 3 igalshilman@gmail.com igal@apache.org
StatefulFunctionsUniverses.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 21 2 2020-01-22 2021-12-09 4 3 igalshilman@gmail.com igal@apache.org
FunctionGroupDispatchFactory.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions
 54 5 2020-01-22 2022-01-19 4 3 igalshilman@gmail.com trohrmann@apache.org
MessageWrapper.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message
 119 22 2021-02-23 2021-05-25 3 3 igalshilman@gmail.com knauf.konstantin@gmail.com
ConcurrentAddressScopedStorage.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage
 282 21 2021-02-23 2022-01-28 3 3 igalshilman@gmail.com igal@apache.org
proto
kinesis-egress.proto
in statefun-sdk-protos/src/main/protobuf/io
 28 - 2021-01-27 2021-08-11 3 3 igalshilman@gmail.com sjwiesman@gmail.com
proto
kafka-egress.proto
in statefun-sdk-protos/src/main/protobuf/io
 27 - 2021-01-27 2021-08-11 3 3 igalshilman@gmail.com sjwiesman@gmail.com
MessageFactoryType.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message
 7 - 2020-01-22 2021-09-27 3 3 igalshilman@gmail.com igal@apache.org
FeedbackSinkOperator.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback
 52 5 2020-01-22 2022-01-19 3 3 igalshilman@gmail.com trohrmann@apache.org
NettyClient.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient
 254 18 2021-08-10 2022-03-02 3 3 igalshilman@gmail.com filip.karnicki@gmail.com
NettyTransportModule.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient
 14 1 2021-08-10 2022-02-09 3 3 igalshilman@gmail.com 784517+galenwarren@users.no...
StatefulFunctionsJobConstants.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core
 12 1 2020-01-22 2020-02-19 3 3 igalshilman@gmail.com sjwiesman@gmail.com
PersistedRemoteFunctionValues.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply
 134 10 2020-06-03 2021-05-25 12 2 tzulitai@apache.org tzulitai@apache.org
Reductions.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions
 127 6 2020-01-22 2021-06-14 10 2 igalshilman@gmail.com igalshilman@gmail.com
KafkaIngressBuilder.java
in statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka
 108 14 2020-01-22 2021-05-28 9 2 igalshilman@gmail.com tzulitai@apache.org
FlinkState.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state
 90 7 2020-01-22 2021-01-21 7 2 igalshilman@gmail.com tzulitai@apache.org
OkHttpUtils.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn
 45 3 2020-02-10 2020-09-14 7 2 igalshilman@gmail.com igalshilman@gmail.com
KafkaIngressSpec.java
in statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka
 74 9 2020-01-22 2020-02-01 6 2 igalshilman@gmail.com tzulitai@apache.org
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
request-reply.pb.go
in statefun-sdk-go/v3/pkg/statefun/internal/protocol
 1318 134 2021-08-11 2021-08-11 1 1 sjwiesman@gmail.com sjwiesman@gmail.com
types.pb.go
in statefun-sdk-go/v3/pkg/statefun/internal/protocol
 387 39 2021-08-11 2021-08-11 1 1 sjwiesman@gmail.com sjwiesman@gmail.com
types.go
in statefun-sdk-go/v3/pkg/statefun
 253 12 2021-08-11 2021-08-11 1 1 sjwiesman@gmail.com sjwiesman@gmail.com
RoutableKafkaIngressSpec.java
in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1
 246 17 2021-08-03 2021-08-03 1 1 tzulitai@apache.org tzulitai@apache.org
NettyRequest.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient
 206 18 2021-08-10 2021-08-10 1 1 igalshilman@gmail.com igalshilman@gmail.com
RoutableKinesisIngressSpec.java
in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/ingress/v1
 200 15 2021-08-03 2021-08-03 1 1 tzulitai@apache.org tzulitai@apache.org
egress.go
in statefun-sdk-go/v3/pkg/statefun
 176 5 2021-08-11 2021-09-01 3 1 sjwiesman@gmail.com sjwiesman@gmail.com
TaggedBootstrapDataSerializer.java
in statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union
 164 14 2020-01-22 2020-01-22 1 1 igalshilman@gmail.com igalshilman@gmail.com
NettyRequestReplyHandler.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient
 159 12 2021-08-10 2021-08-10 1 1 igalshilman@gmail.com igalshilman@gmail.com
kinesis-egress.pb.go
in statefun-sdk-go/v3/pkg/statefun/internal/protocol
 150 12 2021-08-11 2021-08-11 1 1 sjwiesman@gmail.com sjwiesman@gmail.com
KafkaIngressStartupPosition.java
in statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka
 144 30 2020-01-30 2020-02-01 2 1 tzulitai@apache.org tzulitai@apache.org
kafka-egress.pb.go
in statefun-sdk-go/v3/pkg/statefun/internal/protocol
 139 11 2021-08-11 2021-08-11 1 1 sjwiesman@gmail.com sjwiesman@gmail.com
message.go
in statefun-sdk-go/v3/pkg/statefun
 133 17 2021-08-11 2021-08-11 1 1 sjwiesman@gmail.com sjwiesman@gmail.com
ConcurrentContext.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler
 132 10 2021-02-23 2021-06-14 2 1 igalshilman@gmail.com igalshilman@gmail.com
PersistedAppendingBuffer.java
in statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state
 126 23 2021-03-24 2021-03-24 1 1 igalshilman@gmail.com igalshilman@gmail.com
LegacyRemoteModuleV30.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule
 123 12 2021-08-03 2021-08-03 1 1 tzulitai@apache.org tzulitai@apache.org
cell.go
in statefun-sdk-go/v3/pkg/statefun/internal
 112 12 2021-08-11 2021-08-19 3 1 sjwiesman@gmail.com sjwiesman@gmail.com
GenericKafkaEgressSpec.java
in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/egress/v1
 112 9 2021-08-03 2021-08-03 1 1 tzulitai@apache.org tzulitai@apache.org
storage.go
in statefun-sdk-go/v3/pkg/statefun
 111 9 2021-08-11 2021-08-19 2 1 sjwiesman@gmail.com sjwiesman@gmail.com
FlinkStateDelayedMessagesBuffer.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions
 110 8 2020-01-22 2021-06-14 2 1 igalshilman@gmail.com igalshilman@gmail.com
PersistedTable.java
in statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state
 109 21 2021-03-24 2021-03-24 1 1 igalshilman@gmail.com igalshilman@gmail.com
RetryingCallback.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn
 109 10 2020-02-13 2020-09-20 3 1 igalshilman@gmail.com igalshilman@gmail.com
SideEffects.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing
 107 22 2021-05-25 2021-05-25 1 1 knauf.konstantin@gmail.com knauf.konstantin@gmail.com
KinesisIngressBuilder.java
in statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/ingress
 106 14 2020-03-15 2021-08-03 4 1 tzulitai@apache.org tzulitai@apache.org
messages.py
in statefun-sdk-python/statefun
 106 22 2021-03-24 2021-03-24 1 1 igalshilman@gmail.com igalshilman@gmail.com
core.py
in statefun-sdk-python/statefun
 104 12 2021-03-24 2021-03-24 1 1 igalshilman@gmail.com igalshilman@gmail.com
ModuleSpecs.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/spi
 100 14 2020-01-22 2020-01-22 1 1 igalshilman@gmail.com igalshilman@gmail.com
OkHttpUnixSocketBridge.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn
 100 17 2020-05-19 2020-05-19 1 1 igalshilman@gmail.com igalshilman@gmail.com
KinesisSourceProvider.java
in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis
 98 8 2020-03-15 2021-05-28 4 1 tzulitai@apache.org tzulitai@apache.org
Loggers.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/logger
 98 10 2020-01-22 2020-10-21 3 1 igalshilman@gmail.com igalshilman@gmail.com
ProtobufTypeSerializer.java
in statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/protobuf
 92 16 2020-01-22 2020-01-22 1 1 igalshilman@gmail.com igalshilman@gmail.com
GenericKinesisEgressSpec.java
in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/egress/v1
 91 9 2021-08-03 2021-08-03 1 1 tzulitai@apache.org tzulitai@apache.org
SdkMessage.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message
 89 10 2020-01-22 2021-06-14 3 1 igalshilman@gmail.com igalshilman@gmail.com
ProtobufMessage.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message
 89 9 2020-01-22 2021-06-14 3 1 igalshilman@gmail.com igalshilman@gmail.com
TestContext.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing
 87 16 2021-05-25 2021-05-25 1 1 knauf.konstantin@gmail.com knauf.konstantin@gmail.com
AwsAuthConfigProperties.java
in statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis
 87 5 2020-03-15 2020-03-16 2 1 tzulitai@apache.org tzulitai@apache.org
RemoteValueSerializer.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote
 86 10 2021-01-21 2021-01-21 1 1 tzulitai@apache.org tzulitai@apache.org
ProtobufTypeSerializerSnapshot.java
in statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/protobuf
 83 8 2020-01-22 2020-01-22 1 1 igalshilman@gmail.com igalshilman@gmail.com
IngressRecord.java
in statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/ingress
 82 15 2020-03-15 2020-03-15 1 1 tzulitai@apache.org tzulitai@apache.org
PersistedValue.java
in statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state
 82 17 2021-03-24 2021-03-24 1 1 igalshilman@gmail.com igalshilman@gmail.com
TaggedBootstrapDataTypeInfo.java
in statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union
 82 11 2020-01-22 2020-01-22 1 1 igalshilman@gmail.com igalshilman@gmail.com
AsyncMessageDecorator.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions
 82 8 2020-01-22 2021-06-14 4 1 igalshilman@gmail.com igalshilman@gmail.com
typename.go
in statefun-sdk-go/v3/pkg/statefun
 80 8 2021-08-11 2021-08-11 1 1 sjwiesman@gmail.com sjwiesman@gmail.com
HttpConnectionPoolHandler.java
in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient
 79 10 2021-08-10 2021-08-10 1 1 igalshilman@gmail.com igalshilman@gmail.com
ProtobufSerializer.java
in statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/protobuf
 78 8 2020-01-22 2021-08-10 2 1 igalshilman@gmail.com igalshilman@gmail.com
SliceOutput.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice
 77 12 2021-02-23 2021-02-23 1 1 igalshilman@gmail.com igalshilman@gmail.com
StateValueContexts.java
in statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage
 76 4 2021-02-23 2021-02-23 1 1 igalshilman@gmail.com igalshilman@gmail.com
AwsRegion.java
in statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/auth
 75 13 2020-03-15 2020-03-15 1 1 tzulitai@apache.org tzulitai@apache.org
AwsCredentials.java
in statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/auth
 73 14 2020-03-15 2020-03-15 1 1 tzulitai@apache.org tzulitai@apache.org
MatchBinder.java
in statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/match
 73 7 2021-03-24 2021-03-24 1 1 igalshilman@gmail.com igalshilman@gmail.com
Correlations

File Size vs. Number of Changes: 445 points

statefun-sdk-python/setup.py x: 27 lines of code y: 5 # changes tools/k8s/Chart.yaml x: 6 lines of code y: 8 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfigValidator.java x: 83 lines of code y: 9 # changes statefun-flink/statefun-flink-harness/src/main/java/org/apache/flink/statefun/flink/harness/Harness.java x: 141 lines of code y: 9 # changes statefun-flink/statefun-flink-launcher/src/main/java/org/apache/flink/statefun/flink/launcher/StatefulFunctionsClusterEntryPoint.java x: 108 lines of code y: 5 # changes tools/k8s/templates/config-map.yaml x: 61 lines of code y: 8 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java x: 185 lines of code y: 16 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsJob.java x: 61 lines of code y: 9 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/HttpConnectionPoolManager.java x: 56 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyClient.java x: 254 lines of code y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequestReplySpec.java x: 114 lines of code y: 4 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettySharedResources.java x: 69 lines of code y: 2 # changes statefun-sdk-python/statefun/request_reply_v3.py x: 172 lines of code y: 4 # changes statefun-sdk-go/v3/pkg/statefun/handler.go x: 180 lines of code y: 4 # changes statefun-sdk-go/v3/pkg/statefun/context.go x: 106 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/DefaultHttpRequestReplyClientSpec.java x: 90 lines of code y: 4 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequestReplyClientFactory.java x: 39 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyTransportModule.java x: 14 lines of code y: 3 # changes statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/AsyncRequestReplyFunctionBuilder.java x: 58 lines of code y: 1 # changes statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/SerializableHttpFunctionProvider.java x: 46 lines of code y: 5 # changes statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/StatefulFunctionBuilder.java x: 18 lines of code y: 1 # changes statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/StatefulFunctionDataStreamBuilder.java x: 90 lines of code y: 8 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage/ConcurrentAddressScopedStorage.java x: 282 lines of code y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/common/MailboxExecutorFacade.java x: 16 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackSinkOperator.java x: 52 lines of code y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackUnionOperator.java x: 121 lines of code y: 7 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackUnionOperatorFactory.java x: 67 lines of code y: 6 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionGroupDispatchFactory.java x: 54 lines of code y: 4 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionGroupOperator.java x: 154 lines of code y: 16 # changes statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/operator/FunctionsStateBootstrapOperator.java x: 70 lines of code y: 6 # changes statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/json/StateFunObjectMapper.java x: 43 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/DefaultHttpRequestReplyClientFactory.java x: 79 lines of code y: 4 # changes tools/k8s/values.yaml x: 18 lines of code y: 5 # changes tools/docker/flink-distribution-template/conf/flink-conf.yaml x: 19 lines of code y: 16 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/RouterTranslator.java x: 42 lines of code y: 3 # changes statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/ResourceLocator.java x: 85 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverses.java x: 21 lines of code y: 4 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/JsonServiceLoader.java x: 101 lines of code y: 6 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/spi/Modules.java x: 66 lines of code y: 6 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionEndpointSpec.java x: 95 lines of code y: 5 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/TransportClientConstants.java x: 8 lines of code y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/TransportClientSpec.java x: 29 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/LocalFunctionGroup.java x: 36 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/ReusableContext.java x: 124 lines of code y: 6 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/MessageFactoryType.java x: 7 lines of code y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FlinkFuncionTypeMetricsFactory.java x: 18 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FlinkFunctionTypeMetrics.java x: 96 lines of code y: 7 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FlinkUserMetrics.java x: 27 lines of code y: 1 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FunctionTypeMetrics.java x: 15 lines of code y: 5 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/IngressRouterOperator.java x: 98 lines of code y: 4 # changes statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/BootstrapDatasetUnion.java x: 102 lines of code y: 2 # changes statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Context.java x: 25 lines of code y: 3 # changes statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/metrics/Counter.java x: 11 lines of code y: 1 # changes statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/metrics/Metrics.java x: 4 lines of code y: 1 # changes statefun-testutil/src/main/java/org/apache/flink/statefun/testutils/function/TestContext.java x: 163 lines of code y: 4 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/NonNegativeCounter.java x: 29 lines of code y: 1 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/RequestReplyFunction.java x: 257 lines of code y: 13 # changes statefun-sdk-js/src/context.ts x: 66 lines of code y: 2 # changes statefun-sdk-js/src/core.ts x: 117 lines of code y: 2 # changes statefun-sdk-js/src/handler.ts x: 164 lines of code y: 2 # changes statefun-sdk-js/src/message.ts x: 104 lines of code y: 2 # changes statefun-sdk-js/src/public_api.ts x: 5 lines of code y: 1 # changes statefun-sdk-js/src/storage.ts x: 114 lines of code y: 2 # changes statefun-sdk-js/src/types.ts x: 134 lines of code y: 2 # changes statefun-sdk-js/jest.config.js x: 14 lines of code y: 1 # changes statefun-sdk-go/v3/pkg/statefun/egress.go x: 176 lines of code y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/binders/v2/HttpEndpointBinderV2.java x: 53 lines of code y: 2 # changes statefun-sdk-go/v3/pkg/statefun/internal/cell.go x: 112 lines of code y: 3 # changes statefun-sdk-go/v3/pkg/statefun/storage.go x: 111 lines of code y: 2 # changes statefun-sdk-go/v3/pkg/statefun/cancellation.go x: 24 lines of code y: 1 # changes statefun-sdk-go/v3/pkg/statefun/internal/protocol/kafka-egress.pb.go x: 139 lines of code y: 1 # changes statefun-sdk-go/v3/pkg/statefun/internal/protocol/kinesis-egress.pb.go x: 150 lines of code y: 1 # changes statefun-sdk-go/v3/pkg/statefun/internal/protocol/request-reply.pb.go x: 1318 lines of code y: 1 # changes statefun-sdk-go/v3/pkg/statefun/internal/protocol/types.pb.go x: 387 lines of code y: 1 # changes statefun-sdk-go/v3/pkg/statefun/message.go x: 133 lines of code y: 1 # changes statefun-sdk-go/v3/pkg/statefun/typename.go x: 80 lines of code y: 1 # changes statefun-sdk-go/v3/pkg/statefun/types.go x: 253 lines of code y: 1 # changes statefun-sdk-go/v3/pkg/statefun/value_spec.go x: 65 lines of code y: 1 # changes statefun-sdk-protos/src/main/protobuf/io/kafka-egress.proto x: 27 lines of code y: 3 # changes statefun-sdk-protos/src/main/protobuf/sdk/request-reply.proto x: 167 lines of code y: 5 # changes statefun-sdk-protos/src/main/protobuf/types/types.proto x: 52 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/ChannelAttributes.java x: 9 lines of code y: 1 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyHeaders.java x: 37 lines of code y: 1 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyProtobuf.java x: 71 lines of code y: 1 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequest.java x: 206 lines of code y: 1 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequestReplyHandler.java x: 159 lines of code y: 1 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequestTimeoutTask.java x: 33 lines of code y: 1 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionProvider.java x: 33 lines of code y: 17 # changes statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/protobuf/ProtobufSerializer.java x: 78 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverse.java x: 149 lines of code y: 5 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/TransportClientsModule.java x: 13 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/UrlPathTemplate.java x: 16 lines of code y: 1 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/LegacyRemoteModuleV30.java x: 123 lines of code y: 1 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/ModuleConfigurationException.java x: 10 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/spi/ExtensionResolver.java x: 6 lines of code y: 2 # changes statefun-flink/statefun-flink-extensions/src/main/java/org/apache/flink/statefun/extensions/ComponentJsonObject.java x: 62 lines of code y: 1 # changes statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/common/AutoRoutableProtobufRouter.java x: 40 lines of code y: 1 # changes statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/common/json/PropertiesJsonDeserializer.java x: 22 lines of code y: 1 # changes statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/KafkaFlinkIoModule.java x: 13 lines of code y: 4 # changes statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/KafkaSinkProvider.java x: 65 lines of code y: 3 # changes statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/egress/v1/GenericKafkaEgressSpec.java x: 112 lines of code y: 1 # changes statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressDeserializer.java x: 50 lines of code y: 1 # changes statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressSpec.java x: 246 lines of code y: 1 # changes statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/KinesisFlinkIOModule.java x: 13 lines of code y: 5 # changes statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/AwsCredentialsJsonDeserializer.java x: 45 lines of code y: 1 # changes statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/egress/v1/GenericKinesisEgressSpec.java x: 91 lines of code y: 1 # changes statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/ingress/v1/RoutableKinesisIngressDeserializer.java x: 48 lines of code y: 1 # changes statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/ingress/v1/RoutableKinesisIngressSpec.java x: 200 lines of code y: 1 # changes statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaEgressBuilder.java x: 66 lines of code y: 4 # changes statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/ingress/KinesisIngressBuilder.java x: 106 lines of code y: 4 # changes statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/json/Selectors.java x: 174 lines of code y: 7 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/FormatVersion.java x: 29 lines of code y: 5 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/MessageWrapper.java x: 119 lines of code y: 3 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing/SideEffects.java x: 107 lines of code y: 1 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing/TestContext.java x: 87 lines of code y: 1 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/AsyncMessageDecorator.java x: 82 lines of code y: 4 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/DelayedMessagesBuffer.java x: 9 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/Reductions.java x: 127 lines of code y: 10 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/ProtobufMessage.java x: 89 lines of code y: 3 # changes statefun-flink/statefun-flink-core/src/main/protobuf/stateful-functions.proto x: 43 lines of code y: 4 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/Context.java x: 19 lines of code y: 3 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/ConcurrentContext.java x: 132 lines of code y: 2 # changes statefun-sdk-python/statefun/context.py x: 27 lines of code y: 2 # changes statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressBuilder.java x: 108 lines of code y: 9 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValues.java x: 134 lines of code y: 12 # changes statefun-sdk-python/statefun/storage.py x: 81 lines of code y: 2 # changes statefun-sdk-python/statefun/statefun_builder.py x: 42 lines of code y: 2 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/Expiration.java x: 40 lines of code y: 3 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/StatefulFunctionSpec.java x: 60 lines of code y: 3 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/TypeName.java x: 81 lines of code y: 3 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/ValueSpec.java x: 100 lines of code y: 5 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/SimpleType.java x: 73 lines of code y: 3 # changes statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/TypeName.java x: 56 lines of code y: 1 # changes statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/match/MatchBinder.java x: 73 lines of code y: 1 # changes statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/spi/StatefulFunctionModule.java x: 21 lines of code y: 1 # changes statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/Expiration.java x: 42 lines of code y: 1 # changes statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/PersistedAppendingBuffer.java x: 126 lines of code y: 1 # changes statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/PersistedTable.java x: 109 lines of code y: 1 # changes statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/PersistedValue.java x: 82 lines of code y: 1 # changes statefun-sdk-python/statefun/core.py x: 104 lines of code y: 1 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/EgressMessageBuilder.java x: 54 lines of code y: 1 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/ProtoUtils.java x: 71 lines of code y: 3 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/io/KinesisEgressMessage.java x: 110 lines of code y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/MessagePayloadSerializerKryo.java x: 60 lines of code y: 2 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/SliceProtobufUtil.java x: 32 lines of code y: 2 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/Slices.java x: 34 lines of code y: 2 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/Types.java x: 347 lines of code y: 2 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/SliceOutput.java x: 77 lines of code y: 1 # changes statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage/StateValueContexts.java x: 76 lines of code y: 1 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/common/PolyglotUtil.java x: 29 lines of code y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/FlinkState.java x: 90 lines of code y: 7 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/PersistedStates.java x: 99 lines of code y: 6 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/sdk/state/ApiExtension.java x: 23 lines of code y: 6 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FlinkTimerServiceFactory.java x: 26 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackKey.java x: 33 lines of code y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/FlinkUniverse.java x: 31 lines of code y: 6 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/PredefinedFunctionLoader.java x: 49 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/logger/UnboundedFeedbackLogger.java x: 139 lines of code y: 4 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/logger/Loggers.java x: 98 lines of code y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/MessageTypeInformation.java x: 58 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/MessageTypeSerializer.java x: 140 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/EmbeddedTranslator.java x: 52 lines of code y: 4 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/StatefulFunctionTranslator.java x: 93 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/RetryingCallback.java x: 109 lines of code y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/FlinkConfigExtractor.java x: 21 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/OkHttpUtils.java x: 45 lines of code y: 7 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/backpressure/ThresholdBackPressureValve.java x: 43 lines of code y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/StatefulFunctionRepository.java x: 56 lines of code y: 4 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/AsyncSink.java x: 78 lines of code y: 5 # changes statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/operator/StateBootstrapFunctionRegistry.java x: 100 lines of code y: 4 # changes statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/StatefulFunctionEgressStreams.java x: 22 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/Sources.java x: 97 lines of code y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/RoutableMessageBuilder.java x: 35 lines of code y: 1 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/OkHttpUnixSocketBridge.java x: 100 lines of code y: 1 # changes statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/AwsAuthConfigProperties.java x: 87 lines of code y: 2 # changes statefun-flink/statefun-flink-launcher/src/main/java/org/apache/flink/statefun/flink/launcher/StatefulFunctionsJobGraphRetriever.java x: 98 lines of code y: 2 # changes statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/Constants.java x: 10 lines of code y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/FlinkTableAccessor.java x: 63 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/AsyncOperationFailureNotifier.java x: 46 lines of code y: 2 # changes statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/StatefulFunctionsSavepointCreator.java x: 71 lines of code y: 4 # changes statefun-flink/statefun-flink-core/src/main/java/it/unimi/dsi/fastutil/HashCommon.java x: 91 lines of code y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/it/unimi/dsi/fastutil/objects/ObjectOpenHashMap.java x: 271 lines of code y: 2 # changes statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressStartupPosition.java x: 144 lines of code y: 2 # changes statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressSpec.java x: 74 lines of code y: 6 # changes statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/UnimplementedTypeSerializer.java x: 60 lines of code y: 1 # changes statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataSerializer.java x: 164 lines of code y: 1 # changes
17.0
# changes
  min: 1.0
  average: 2.18
  25th percentile: 1.0
  median: 1.0
  75th percentile: 2.0
  max: 17.0
0 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

Number of Contributors vs. Number of Changes: 445 points

statefun-sdk-python/setup.py x: 3 # contributors y: 5 # changes tools/k8s/Chart.yaml x: 3 # contributors y: 8 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfigValidator.java x: 5 # contributors y: 9 # changes statefun-flink/statefun-flink-launcher/src/main/java/org/apache/flink/statefun/flink/launcher/StatefulFunctionsClusterEntryPoint.java x: 4 # contributors y: 5 # changes tools/k8s/templates/config-map.yaml x: 4 # contributors y: 8 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java x: 6 # contributors y: 16 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsJob.java x: 4 # contributors y: 9 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/HttpConnectionPoolManager.java x: 2 # contributors y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyClient.java x: 3 # contributors y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequestReplySpec.java x: 4 # contributors y: 4 # changes statefun-sdk-python/statefun/request_reply_v3.py x: 3 # contributors y: 4 # changes statefun-sdk-go/v3/pkg/statefun/handler.go x: 2 # contributors y: 4 # changes statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/AsyncRequestReplyFunctionBuilder.java x: 1 # contributors y: 1 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackUnionOperator.java x: 4 # contributors y: 7 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackUnionOperatorFactory.java x: 4 # contributors y: 6 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionGroupOperator.java x: 5 # contributors y: 16 # changes statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/operator/FunctionsStateBootstrapOperator.java x: 5 # contributors y: 6 # changes tools/docker/flink-distribution-template/conf/flink-conf.yaml x: 4 # contributors y: 16 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/translation/RouterTranslator.java x: 2 # contributors y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/JsonServiceLoader.java x: 3 # contributors y: 6 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionEndpointSpec.java x: 2 # contributors y: 5 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/RequestReplyFunction.java x: 3 # contributors y: 13 # changes statefun-sdk-go/v3/pkg/statefun/egress.go x: 1 # contributors y: 3 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/binders/v2/HttpEndpointBinderV2.java x: 1 # contributors y: 2 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionProvider.java x: 3 # contributors y: 17 # changes statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/KinesisFlinkIOModule.java x: 1 # contributors y: 5 # changes statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/ingress/KinesisIngressBuilder.java x: 1 # contributors y: 4 # changes statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/json/Selectors.java x: 3 # contributors y: 7 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/Reductions.java x: 2 # contributors y: 10 # changes statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressBuilder.java x: 2 # contributors y: 9 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValues.java x: 2 # contributors y: 12 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/FlinkState.java x: 2 # contributors y: 7 # changes statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/PersistedStates.java x: 2 # contributors y: 6 # changes
17.0
# changes
  min: 1.0
  average: 2.18
  25th percentile: 1.0
  median: 1.0
  75th percentile: 2.0
  max: 17.0
0 6.0
# contributors
min: 1.0 | average: 1.5 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 6.0

Number of Contributors vs. File Size: 445 points

statefun-sdk-python/setup.py x: 3 # contributors y: 27 lines of code tools/k8s/Chart.yaml x: 3 # contributors y: 6 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfigValidator.java x: 5 # contributors y: 83 lines of code statefun-flink/statefun-flink-harness/src/main/java/org/apache/flink/statefun/flink/harness/Harness.java x: 5 # contributors y: 141 lines of code statefun-flink/statefun-flink-launcher/src/main/java/org/apache/flink/statefun/flink/launcher/StatefulFunctionsClusterEntryPoint.java x: 4 # contributors y: 108 lines of code tools/k8s/templates/config-map.yaml x: 4 # contributors y: 61 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java x: 6 # contributors 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 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 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 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 y: 69 lines of code statefun-sdk-python/statefun/request_reply_v3.py x: 3 # contributors y: 172 lines of code statefun-sdk-go/v3/pkg/statefun/handler.go x: 2 # contributors y: 180 lines of code statefun-sdk-go/v3/pkg/statefun/context.go x: 2 # contributors 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 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 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 y: 14 lines of code statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/AsyncRequestReplyFunctionBuilder.java x: 1 # contributors y: 58 lines of code statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/RequestReplyFunctionBuilder.java x: 3 # contributors y: 60 lines of code statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/SerializableHttpFunctionProvider.java x: 3 # contributors y: 46 lines of code statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/StatefulFunctionBuilder.java x: 1 # contributors y: 18 lines of code statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/StatefulFunctionDataStreamBuilder.java x: 4 # contributors y: 90 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage/ConcurrentAddressScopedStorage.java x: 3 # contributors 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 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 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 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 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 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 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 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 y: 79 lines of code tools/k8s/values.yaml x: 3 # contributors y: 18 lines of code tools/docker/flink-distribution-template/conf/flink-conf.yaml x: 4 # contributors y: 19 lines of code statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/ResourceLocator.java x: 2 # contributors y: 85 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverses.java x: 3 # contributors 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 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 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 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 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 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 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 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 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 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 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 y: 102 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Context.java x: 2 # contributors y: 25 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/Router.java x: 2 # contributors y: 15 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/metrics/Counter.java x: 1 # contributors y: 11 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/metrics/Metrics.java x: 1 # contributors y: 4 lines of code statefun-testutil/src/main/java/org/apache/flink/statefun/testutils/function/TestContext.java x: 4 # contributors 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 y: 257 lines of code statefun-sdk-js/src/context.ts x: 2 # contributors y: 66 lines of code statefun-sdk-js/src/core.ts x: 2 # contributors y: 117 lines of code statefun-sdk-js/src/handler.ts x: 2 # contributors y: 164 lines of code statefun-sdk-js/src/storage.ts x: 2 # contributors y: 114 lines of code statefun-sdk-js/src/types.ts x: 2 # contributors y: 134 lines of code statefun-sdk-go/v3/pkg/statefun/egress.go x: 1 # contributors 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 y: 53 lines of code statefun-sdk-go/v3/pkg/statefun/internal/cell.go x: 1 # contributors y: 112 lines of code statefun-sdk-go/v3/pkg/statefun/cancellation.go x: 1 # contributors y: 24 lines of code statefun-sdk-go/v3/pkg/statefun/internal/protocol/kafka-egress.pb.go x: 1 # contributors y: 139 lines of code statefun-sdk-go/v3/pkg/statefun/internal/protocol/kinesis-egress.pb.go x: 1 # contributors y: 150 lines of code statefun-sdk-go/v3/pkg/statefun/internal/protocol/request-reply.pb.go x: 1 # contributors y: 1318 lines of code statefun-sdk-go/v3/pkg/statefun/internal/protocol/types.pb.go x: 1 # contributors y: 387 lines of code statefun-sdk-go/v3/pkg/statefun/message.go x: 1 # contributors y: 133 lines of code statefun-sdk-go/v3/pkg/statefun/typename.go x: 1 # contributors y: 80 lines of code statefun-sdk-go/v3/pkg/statefun/types.go x: 1 # contributors y: 253 lines of code statefun-sdk-go/v3/pkg/statefun/value_spec.go x: 1 # contributors y: 65 lines of code statefun-sdk-protos/src/main/protobuf/sdk/request-reply.proto x: 3 # contributors 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 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 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 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 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 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 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 y: 33 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverse.java x: 3 # contributors 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 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 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 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 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 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 y: 200 lines of code statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaEgressSpec.java x: 2 # contributors y: 51 lines of code statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/ingress/KinesisIngressBuilder.java x: 1 # contributors y: 106 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/MessageWrapper.java x: 3 # contributors y: 119 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing/TestContext.java x: 1 # contributors 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 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 y: 98 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/StatefulFunctionSpec.java x: 2 # contributors y: 60 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/SimpleType.java x: 2 # contributors y: 73 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/match/MatchBinder.java x: 1 # contributors y: 73 lines of code statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/state/PersistedAppendingBuffer.java x: 1 # contributors y: 126 lines of code statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/Types.java x: 2 # contributors 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 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 y: 100 lines of code statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverseProvider.java x: 2 # contributors y: 5 lines of code statefun-flink/statefun-flink-core/src/main/java/it/unimi/dsi/fastutil/objects/ObjectOpenHashMap.java x: 2 # contributors y: 271 lines of code statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressStartupPosition.java x: 1 # contributors 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 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
min: 1.0 | average: 1.5 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 6.0