apache / flink-connector-cassandra
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 40 files with 2,687 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)
    • 8 files changed 6-20 times (838 lines of code)
    • 32 files changed 1-5 times (1,849 lines of code)
0% | 0% | 0% | 31% | 68%
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 40 files with 2,687 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 1 file changed by 11-25 contributors (386 lines of code)
    • 4 files changed by 6-10 contributors (310 lines of code)
    • 20 files changed by 2-5 contributors (963 lines of code)
    • 15 files changed by 1 contributor (1,028 lines of code)
0% | 14% | 11% | 35% | 38%
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, xml, md, yml, properties, gitignore, txt, json, editorconfig, gitmodules, yaml
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 31% | 68%
xml0% | 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
flink-connector-cassandra0% | 0% | 0% | 31% | 68%
tools0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 40)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
CassandraSinkBase.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 135 11 2016-10-10 2022-07-13 16 10 chesnay@apache.org echauchot@apache.org
CassandraSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 386 43 2016-10-10 2021-10-21 16 13 chesnay@apache.org fabianpaul@ververica.com
CassandraPojoSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 78 7 2016-11-23 2022-06-13 9 7 chesnay@apache.org echauchot@apache.org
CassandraAppendTableSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 72 5 2017-04-21 2020-12-28 7 7 jing.fan@uber.com dev@flink.apache.org
CassandraTupleSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 25 1 2016-10-10 2022-06-13 6 6 chesnay@apache.org echauchot@apache.org
CassandraScalaProductSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 26 1 2016-10-10 2022-06-13 6 5 chesnay@apache.org echauchot@apache.org
AbstractCassandraTupleSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 42 4 2016-10-10 2020-12-28 6 5 chesnay@apache.org dev@flink.apache.org
CassandraOutputFormatBase.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 74 8 2018-01-10 2022-07-13 6 4 shuyi@uber.com echauchot@apache.org
CassandraInputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 31 4 2016-11-29 2020-12-28 5 5 fhueske@apache.org dev@flink.apache.org
CassandraRowSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 32 1 2017-04-21 2022-06-13 5 5 jing.fan@uber.com echauchot@apache.org
CassandraPojoOutputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 60 6 2018-10-17 2022-07-13 5 3 bmeriaux@users.noreply.gith... echauchot@apache.org
CassandraInputFormatBase.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 64 5 2018-07-05 2023-04-06 5 5 jpcarterara@gmail.com echauchot@apache.org
CassandraTupleWriteAheadSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 123 4 2016-11-29 2020-12-28 5 5 fhueske@apache.org dev@flink.apache.org
CassandraOutputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 9 1 2016-11-29 2020-12-28 4 4 fhueske@apache.org dev@flink.apache.org
ClusterBuilder.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 9 1 2016-11-29 2023-05-02 4 4 fhueske@apache.org echauchot@apache.org
CassandraRowOutputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 24 2 2018-01-10 2022-06-13 4 3 shuyi@uber.com echauchot@apache.org
CassandraTupleOutputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 25 2 2018-01-10 2022-06-13 4 3 shuyi@uber.com echauchot@apache.org
CassandraCommitter.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 101 8 2016-11-29 2020-12-28 4 4 fhueske@apache.org dev@flink.apache.org
suppressions.xml
in tools/maven
 6 - 2022-06-08 2023-04-06 3 1 echauchot@apache.org echauchot@apache.org
CassandraFailureHandler.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 8 - 2018-09-21 2020-12-28 3 3 wittyameta@gmail.com dev@flink.apache.org
CassandraColumnarOutputFormatBase.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 36 3 2022-06-08 2023-04-06 3 1 echauchot@apache.org echauchot@apache.org
CassandraSplitSerializer.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split
 41 3 2023-03-22 2023-06-08 3 1 echauchot@apache.org echauchot@apache.org
CassandraPojoInputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 47 5 2018-07-05 2020-12-28 3 3 jpcarterara@gmail.com dev@flink.apache.org
CassandraEnumeratorStateSerializer.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator
 73 3 2023-03-22 2023-06-08 3 2 echauchot@apache.org echauchot@apache.org
CassandraSinkBaseConfig.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 73 10 2018-12-19 2020-12-28 3 3 park.jacob.96@gmail.com dev@flink.apache.org
CassandraRowWriteAheadSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 125 4 2017-04-21 2020-12-28 3 3 jing.fan@uber.com dev@flink.apache.org
MapperOptions.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 6 - 2017-04-12 2020-12-28 2 2 chesnay@apache.org dev@flink.apache.org
NoOpCassandraFailureHandler.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 11 1 2018-09-21 2020-12-28 2 2 wittyameta@gmail.com dev@flink.apache.org
CassandraSource.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source
 134 10 2023-03-22 2023-05-10 2 1 echauchot@apache.org echauchot@apache.org
CassandraRow.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader
 17 3 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
BigIntegerSerializationUtils.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/utils
 18 2 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraSourceReaderFactory.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader
 30 1 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
SimpleMapperOptions.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 40 7 2022-06-10 2022-06-10 1 1 pengmide@gmail.com pengmide@gmail.com
CassandraSplit.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split
 42 7 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraSourceReader.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader
 68 5 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraRecordEmitter.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader
 87 14 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraSplitEnumerator.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator
 110 9 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraEnumeratorState.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator
 114 10 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraSplitReader.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader
 131 8 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
SplitsGenerator.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split
 154 9 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
Files With Most Contributors (Top 40)
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
CassandraSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 386 43 2016-10-10 2021-10-21 16 13 chesnay@apache.org fabianpaul@ververica.com
CassandraSinkBase.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 135 11 2016-10-10 2022-07-13 16 10 chesnay@apache.org echauchot@apache.org
CassandraPojoSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 78 7 2016-11-23 2022-06-13 9 7 chesnay@apache.org echauchot@apache.org
CassandraAppendTableSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 72 5 2017-04-21 2020-12-28 7 7 jing.fan@uber.com dev@flink.apache.org
CassandraTupleSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 25 1 2016-10-10 2022-06-13 6 6 chesnay@apache.org echauchot@apache.org
AbstractCassandraTupleSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 42 4 2016-10-10 2020-12-28 6 5 chesnay@apache.org dev@flink.apache.org
CassandraScalaProductSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 26 1 2016-10-10 2022-06-13 6 5 chesnay@apache.org echauchot@apache.org
CassandraRowSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 32 1 2017-04-21 2022-06-13 5 5 jing.fan@uber.com echauchot@apache.org
CassandraTupleWriteAheadSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 123 4 2016-11-29 2020-12-28 5 5 fhueske@apache.org dev@flink.apache.org
CassandraInputFormatBase.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 64 5 2018-07-05 2023-04-06 5 5 jpcarterara@gmail.com echauchot@apache.org
CassandraInputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 31 4 2016-11-29 2020-12-28 5 5 fhueske@apache.org dev@flink.apache.org
CassandraOutputFormatBase.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 74 8 2018-01-10 2022-07-13 6 4 shuyi@uber.com echauchot@apache.org
CassandraCommitter.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 101 8 2016-11-29 2020-12-28 4 4 fhueske@apache.org dev@flink.apache.org
ClusterBuilder.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 9 1 2016-11-29 2023-05-02 4 4 fhueske@apache.org echauchot@apache.org
CassandraOutputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 9 1 2016-11-29 2020-12-28 4 4 fhueske@apache.org dev@flink.apache.org
CassandraPojoOutputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 60 6 2018-10-17 2022-07-13 5 3 bmeriaux@users.noreply.gith... echauchot@apache.org
CassandraTupleOutputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 25 2 2018-01-10 2022-06-13 4 3 shuyi@uber.com echauchot@apache.org
CassandraRowOutputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 24 2 2018-01-10 2022-06-13 4 3 shuyi@uber.com echauchot@apache.org
CassandraSinkBaseConfig.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 73 10 2018-12-19 2020-12-28 3 3 park.jacob.96@gmail.com dev@flink.apache.org
CassandraFailureHandler.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 8 - 2018-09-21 2020-12-28 3 3 wittyameta@gmail.com dev@flink.apache.org
CassandraRowWriteAheadSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 125 4 2017-04-21 2020-12-28 3 3 jing.fan@uber.com dev@flink.apache.org
CassandraPojoInputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 47 5 2018-07-05 2020-12-28 3 3 jpcarterara@gmail.com dev@flink.apache.org
CassandraEnumeratorStateSerializer.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator
 73 3 2023-03-22 2023-06-08 3 2 echauchot@apache.org echauchot@apache.org
NoOpCassandraFailureHandler.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 11 1 2018-09-21 2020-12-28 2 2 wittyameta@gmail.com dev@flink.apache.org
MapperOptions.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 6 - 2017-04-12 2020-12-28 2 2 chesnay@apache.org dev@flink.apache.org
suppressions.xml
in tools/maven
 6 - 2022-06-08 2023-04-06 3 1 echauchot@apache.org echauchot@apache.org
CassandraColumnarOutputFormatBase.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 36 3 2022-06-08 2023-04-06 3 1 echauchot@apache.org echauchot@apache.org
CassandraSplitSerializer.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split
 41 3 2023-03-22 2023-06-08 3 1 echauchot@apache.org echauchot@apache.org
CassandraSource.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source
 134 10 2023-03-22 2023-05-10 2 1 echauchot@apache.org echauchot@apache.org
SimpleMapperOptions.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 40 7 2022-06-10 2022-06-10 1 1 pengmide@gmail.com pengmide@gmail.com
CassandraRecordEmitter.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader
 87 14 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraSourceReader.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader
 68 5 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraSplitReader.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader
 131 8 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraRow.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader
 17 3 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraSourceReaderFactory.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader
 30 1 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraSplit.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split
 42 7 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
SplitsGenerator.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split
 154 9 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
BigIntegerSerializationUtils.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/utils
 18 2 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraEnumeratorState.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator
 114 10 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraSplitEnumerator.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator
 110 9 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
Files With Least Contributors (Top 40)
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
SplitsGenerator.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split
 154 9 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraSource.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source
 134 10 2023-03-22 2023-05-10 2 1 echauchot@apache.org echauchot@apache.org
CassandraSplitReader.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader
 131 8 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraEnumeratorState.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator
 114 10 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraSplitEnumerator.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator
 110 9 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraRecordEmitter.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader
 87 14 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraSourceReader.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader
 68 5 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraSplit.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split
 42 7 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraSplitSerializer.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split
 41 3 2023-03-22 2023-06-08 3 1 echauchot@apache.org echauchot@apache.org
SimpleMapperOptions.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 40 7 2022-06-10 2022-06-10 1 1 pengmide@gmail.com pengmide@gmail.com
CassandraColumnarOutputFormatBase.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 36 3 2022-06-08 2023-04-06 3 1 echauchot@apache.org echauchot@apache.org
CassandraSourceReaderFactory.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader
 30 1 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
BigIntegerSerializationUtils.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/utils
 18 2 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
CassandraRow.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader
 17 3 2023-03-22 2023-03-22 1 1 echauchot@apache.org echauchot@apache.org
suppressions.xml
in tools/maven
 6 - 2022-06-08 2023-04-06 3 1 echauchot@apache.org echauchot@apache.org
CassandraEnumeratorStateSerializer.java
in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator
 73 3 2023-03-22 2023-06-08 3 2 echauchot@apache.org echauchot@apache.org
NoOpCassandraFailureHandler.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 11 1 2018-09-21 2020-12-28 2 2 wittyameta@gmail.com dev@flink.apache.org
MapperOptions.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 6 - 2017-04-12 2020-12-28 2 2 chesnay@apache.org dev@flink.apache.org
CassandraRowWriteAheadSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 125 4 2017-04-21 2020-12-28 3 3 jing.fan@uber.com dev@flink.apache.org
CassandraSinkBaseConfig.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 73 10 2018-12-19 2020-12-28 3 3 park.jacob.96@gmail.com dev@flink.apache.org
CassandraPojoOutputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 60 6 2018-10-17 2022-07-13 5 3 bmeriaux@users.noreply.gith... echauchot@apache.org
CassandraPojoInputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 47 5 2018-07-05 2020-12-28 3 3 jpcarterara@gmail.com dev@flink.apache.org
CassandraTupleOutputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 25 2 2018-01-10 2022-06-13 4 3 shuyi@uber.com echauchot@apache.org
CassandraRowOutputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 24 2 2018-01-10 2022-06-13 4 3 shuyi@uber.com echauchot@apache.org
CassandraFailureHandler.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 8 - 2018-09-21 2020-12-28 3 3 wittyameta@gmail.com dev@flink.apache.org
CassandraCommitter.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 101 8 2016-11-29 2020-12-28 4 4 fhueske@apache.org dev@flink.apache.org
CassandraOutputFormatBase.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 74 8 2018-01-10 2022-07-13 6 4 shuyi@uber.com echauchot@apache.org
ClusterBuilder.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 9 1 2016-11-29 2023-05-02 4 4 fhueske@apache.org echauchot@apache.org
CassandraOutputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 9 1 2016-11-29 2020-12-28 4 4 fhueske@apache.org dev@flink.apache.org
CassandraTupleWriteAheadSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 123 4 2016-11-29 2020-12-28 5 5 fhueske@apache.org dev@flink.apache.org
CassandraInputFormatBase.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 64 5 2018-07-05 2023-04-06 5 5 jpcarterara@gmail.com echauchot@apache.org
AbstractCassandraTupleSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 42 4 2016-10-10 2020-12-28 6 5 chesnay@apache.org dev@flink.apache.org
CassandraRowSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 32 1 2017-04-21 2022-06-13 5 5 jing.fan@uber.com echauchot@apache.org
CassandraInputFormat.java
in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra
 31 4 2016-11-29 2020-12-28 5 5 fhueske@apache.org dev@flink.apache.org
CassandraScalaProductSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 26 1 2016-10-10 2022-06-13 6 5 chesnay@apache.org echauchot@apache.org
CassandraTupleSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 25 1 2016-10-10 2022-06-13 6 6 chesnay@apache.org echauchot@apache.org
CassandraPojoSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 78 7 2016-11-23 2022-06-13 9 7 chesnay@apache.org echauchot@apache.org
CassandraAppendTableSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 72 5 2017-04-21 2020-12-28 7 7 jing.fan@uber.com dev@flink.apache.org
CassandraSinkBase.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 135 11 2016-10-10 2022-07-13 16 10 chesnay@apache.org echauchot@apache.org
CassandraSink.java
in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra
 386 43 2016-10-10 2021-10-21 16 13 chesnay@apache.org fabianpaul@ververica.com
Correlations

File Size vs. Number of Changes: 40 points

flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorStateSerializer.java x: 73 lines of code y: 3 # changes flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/CassandraSplitSerializer.java x: 41 lines of code y: 3 # changes flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/CassandraSource.java x: 134 lines of code y: 2 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/ClusterBuilder.java x: 9 lines of code y: 4 # changes flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraColumnarOutputFormatBase.java x: 36 lines of code y: 3 # changes flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraInputFormatBase.java x: 64 lines of code y: 5 # changes tools/maven/suppressions.xml x: 6 lines of code y: 3 # changes flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorState.java x: 114 lines of code y: 1 # changes flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraSplitEnumerator.java x: 110 lines of code y: 1 # changes flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraRecordEmitter.java x: 87 lines of code y: 1 # changes flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraRow.java x: 17 lines of code y: 1 # changes flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSourceReader.java x: 68 lines of code y: 1 # changes flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSourceReaderFactory.java x: 30 lines of code y: 1 # changes flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSplitReader.java x: 131 lines of code y: 1 # changes flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/CassandraSplit.java x: 42 lines of code y: 1 # changes flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/SplitsGenerator.java x: 154 lines of code y: 1 # changes flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/utils/BigIntegerSerializationUtils.java x: 18 lines of code y: 1 # changes flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java x: 74 lines of code y: 6 # changes flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraPojoOutputFormat.java x: 60 lines of code y: 5 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java x: 135 lines of code y: 16 # changes flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraRowOutputFormat.java x: 24 lines of code y: 4 # changes flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraTupleOutputFormat.java x: 25 lines of code y: 4 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraPojoSink.java x: 78 lines of code y: 9 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowSink.java x: 32 lines of code y: 5 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraScalaProductSink.java x: 26 lines of code y: 6 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleSink.java x: 25 lines of code y: 6 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/SimpleMapperOptions.java x: 40 lines of code y: 1 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java x: 386 lines of code y: 16 # changes flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraInputFormat.java x: 31 lines of code y: 5 # changes flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraPojoInputFormat.java x: 47 lines of code y: 3 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/AbstractCassandraTupleSink.java x: 42 lines of code y: 6 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraAppendTableSink.java x: 72 lines of code y: 7 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java x: 101 lines of code y: 4 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraFailureHandler.java x: 8 lines of code y: 3 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowWriteAheadSink.java x: 125 lines of code y: 3 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleWriteAheadSink.java x: 123 lines of code y: 5 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/MapperOptions.java x: 6 lines of code y: 2 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/NoOpCassandraFailureHandler.java x: 11 lines of code y: 2 # changes
16.0
# changes
  min: 1.0
  average: 3.95
  25th percentile: 1.0
  median: 3.0
  75th percentile: 5.0
  max: 16.0
0 386.0
lines of code
min: 6.0 | average: 67.18 | 25th percentile: 25.0 | median: 44.5 | 75th percentile: 97.5 | max: 386.0

Number of Contributors vs. Number of Changes: 40 points

flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorStateSerializer.java x: 2 # contributors y: 3 # changes flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/CassandraSplitSerializer.java x: 1 # contributors y: 3 # changes flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/CassandraSource.java x: 1 # contributors y: 2 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/ClusterBuilder.java x: 4 # contributors y: 4 # changes flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraInputFormatBase.java x: 5 # contributors y: 5 # changes flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorState.java x: 1 # contributors y: 1 # changes flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java x: 4 # contributors y: 6 # changes flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraPojoOutputFormat.java x: 3 # contributors y: 5 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java x: 10 # contributors y: 16 # changes flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraRowOutputFormat.java x: 3 # contributors y: 4 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraPojoSink.java x: 7 # contributors y: 9 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraScalaProductSink.java x: 5 # contributors y: 6 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleSink.java x: 6 # contributors y: 6 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java x: 13 # contributors y: 16 # changes flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraPojoInputFormat.java x: 3 # contributors y: 3 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraAppendTableSink.java x: 7 # contributors y: 7 # changes flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/MapperOptions.java x: 2 # contributors y: 2 # changes
16.0
# changes
  min: 1.0
  average: 3.95
  25th percentile: 1.0
  median: 3.0
  75th percentile: 5.0
  max: 16.0
0 13.0
# contributors
min: 1.0 | average: 3.28 | 25th percentile: 1.0 | median: 3.0 | 75th percentile: 5.0 | max: 13.0

Number of Contributors vs. File Size: 40 points

flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorStateSerializer.java x: 2 # contributors y: 73 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/CassandraSplitSerializer.java x: 1 # contributors y: 41 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/CassandraSource.java x: 1 # contributors y: 134 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/ClusterBuilder.java x: 4 # contributors y: 9 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraColumnarOutputFormatBase.java x: 1 # contributors y: 36 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraInputFormatBase.java x: 5 # contributors y: 64 lines of code tools/maven/suppressions.xml x: 1 # contributors y: 6 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraEnumeratorState.java x: 1 # contributors y: 114 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/enumerator/CassandraSplitEnumerator.java x: 1 # contributors y: 110 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraRecordEmitter.java x: 1 # contributors y: 87 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraRow.java x: 1 # contributors y: 17 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSourceReader.java x: 1 # contributors y: 68 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSourceReaderFactory.java x: 1 # contributors y: 30 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSplitReader.java x: 1 # contributors y: 131 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/CassandraSplit.java x: 1 # contributors y: 42 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/SplitsGenerator.java x: 1 # contributors y: 154 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java x: 4 # contributors y: 74 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraPojoOutputFormat.java x: 3 # contributors y: 60 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java x: 10 # contributors y: 135 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraRowOutputFormat.java x: 3 # contributors y: 24 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraTupleOutputFormat.java x: 3 # contributors y: 25 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraPojoSink.java x: 7 # contributors y: 78 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowSink.java x: 5 # contributors y: 32 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraScalaProductSink.java x: 5 # contributors y: 26 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleSink.java x: 6 # contributors y: 25 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java x: 13 # contributors y: 386 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraInputFormat.java x: 5 # contributors y: 31 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraPojoInputFormat.java x: 3 # contributors y: 47 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/AbstractCassandraTupleSink.java x: 5 # contributors y: 42 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraAppendTableSink.java x: 7 # contributors y: 72 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java x: 4 # contributors y: 101 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraFailureHandler.java x: 3 # contributors y: 8 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowWriteAheadSink.java x: 3 # contributors y: 125 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseConfig.java x: 3 # contributors y: 73 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleWriteAheadSink.java x: 5 # contributors y: 123 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/MapperOptions.java x: 2 # contributors y: 6 lines of code flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/NoOpCassandraFailureHandler.java x: 2 # contributors y: 11 lines of code
386.0
lines of code
  min: 6.0
  average: 67.18
  25th percentile: 25.0
  median: 44.5
  75th percentile: 97.5
  max: 386.0
0 13.0
# contributors
min: 1.0 | average: 3.28 | 25th percentile: 1.0 | median: 3.0 | 75th percentile: 5.0 | max: 13.0