apache / flink-connector-mongodb
File Size

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

Intro
Learn more...
File Size Overall
0% | 0% | 15% | 41% | 42%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 0% | 15% | 41% | 42%
xml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
flink-connector-mongodb0% | 0% | 15% | 41% | 42%
tools0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
BsonToRowDataConverters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter
 364 17
RowDataToBsonConverters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter
 273 8
MongoWriter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer
 196 8
MongoDynamicTableSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 167 11
MongoScanSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 161 7
MongoDynamicTableFactory.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 160 7
MongoRowDataLookupFunction.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 120 5
MongoWriteOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config
 119 16
MongoReadOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config
 116 16
MongoSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 110 8
MongoUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 109 8
MongoScanSplitAssigner.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner
 107 7
MongoDynamicTableSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 104 7
MongoConnectorOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 103 1
MongoKeyExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 101 6
MongoSampleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 95 5
MongoConfiguration.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config
 95 19
MongoSourceEnumerator.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 90 8
MongoSourceBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 88 13
MongoSplitContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 86 12
MongoScanSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 81 10
MongoSourceEnumStateSerializer.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 80 4
MongoValidationUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 75 2
MongoShardedSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 72 2
MongoSourceSplitSerializer.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 70 5
MongoConnectionOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/config
 69 12
MongoSplitVectorSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 68 2
MongoSinkBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 62 9
MongoSerdeUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 62 5
MongoSourceReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader
 61 5
MongoSourceReaderContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader
 59 12
MongoRowDataSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 56 4
MongoSourceEnumState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 48 7
MongoSplitters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 46 2
MongoSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 42 2
MongoRecordEmitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/emitter
 39 5
PartitionStrategy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 36 2
MongoConstants.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 32 1
MongoSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 31 4
MongoScanSourceSplitState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 27 3
MongoSingleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 25 2
DefaultMongoSinkContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context
 25 3
MongoRowDataDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 25 3
MongoSplitAssigner.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner
 18 -
MongoSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer
 18 1
MongoDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/deserializer
 17 1
MongoSinkContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context
 11 -
MongoSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 8 -
MongoSourceSplitState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 8 -
suppressions.xml
in tools/maven
 6 -
Files With Most Units (Top 45)
File# lines# units
MongoConfiguration.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config
 95 19
BsonToRowDataConverters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter
 364 17
MongoReadOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config
 116 16
MongoWriteOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config
 119 16
MongoSourceBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 88 13
MongoSourceReaderContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader
 59 12
MongoSplitContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 86 12
MongoConnectionOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/config
 69 12
MongoDynamicTableSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 167 11
MongoScanSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 81 10
MongoSinkBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 62 9
MongoSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 110 8
MongoSourceEnumerator.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 90 8
MongoWriter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer
 196 8
MongoUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 109 8
RowDataToBsonConverters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter
 273 8
MongoScanSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 161 7
MongoSourceEnumState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 48 7
MongoScanSplitAssigner.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner
 107 7
MongoDynamicTableFactory.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 160 7
MongoDynamicTableSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 104 7
MongoKeyExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 101 6
MongoRecordEmitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/emitter
 39 5
MongoSourceReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader
 61 5
MongoSourceSplitSerializer.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 70 5
MongoSampleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 95 5
MongoSerdeUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 62 5
MongoRowDataLookupFunction.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 120 5
MongoSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 31 4
MongoSourceEnumStateSerializer.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 80 4
MongoRowDataSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 56 4
MongoScanSourceSplitState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 27 3
DefaultMongoSinkContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context
 25 3
MongoRowDataDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 25 3
MongoSingleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 25 2
PartitionStrategy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 36 2
MongoSplitVectorSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 68 2
MongoShardedSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 72 2
MongoSplitters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 46 2
MongoSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 42 2
MongoValidationUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 75 2
MongoDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/deserializer
 17 1
MongoSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer
 18 1
MongoConstants.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 32 1
MongoConnectorOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 103 1
Files With Long Lines (Top 3)

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

File# lines# units# long lines
MongoConnectorOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 103 1 15
PartitionStrategy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 36 2 1
MongoSampleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 95 5 1
Correlations

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

flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumerator.java x: 2 commits (all time) y: 90 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoScanSourceSplitReader.java x: 3 commits (all time) y: 161 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriter.java x: 2 commits (all time) y: 196 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context/DefaultMongoSinkContext.java x: 2 commits (all time) y: 25 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context/MongoSinkContext.java x: 2 commits (all time) y: 11 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/MongoSourceReader.java x: 2 commits (all time) y: 61 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/emitter/MongoRecordEmitter.java x: 2 commits (all time) y: 39 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoScanSourceSplit.java x: 2 commits (all time) y: 81 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoScanSourceSplitState.java x: 1 commits (all time) y: 27 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplitSerializer.java x: 2 commits (all time) y: 70 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplitState.java x: 2 commits (all time) y: 8 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/MongoSourceBuilder.java x: 2 commits (all time) y: 88 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoConnectorOptions.java x: 2 commits (all time) y: 103 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/config/MongoConnectionOptions.java x: 1 commits (all time) y: 69 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoConstants.java x: 1 commits (all time) y: 32 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoSerdeUtils.java x: 1 commits (all time) y: 62 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoUtils.java x: 1 commits (all time) y: 109 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoValidationUtils.java x: 1 commits (all time) y: 75 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/MongoSink.java x: 1 commits (all time) y: 42 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config/MongoWriteOptions.java x: 1 commits (all time) y: 119 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer/MongoSerializationSchema.java x: 1 commits (all time) y: 18 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config/MongoReadOptions.java x: 1 commits (all time) y: 116 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumState.java x: 1 commits (all time) y: 48 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumStateSerializer.java x: 1 commits (all time) y: 80 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner/MongoScanSplitAssigner.java x: 1 commits (all time) y: 107 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSampleSplitter.java x: 1 commits (all time) y: 95 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoShardedSplitter.java x: 1 commits (all time) y: 72 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSingleSplitter.java x: 1 commits (all time) y: 25 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitContext.java x: 1 commits (all time) y: 86 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitVectorSplitter.java x: 1 commits (all time) y: 68 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitters.java x: 1 commits (all time) y: 46 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/PartitionStrategy.java x: 1 commits (all time) y: 36 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/MongoSourceReaderContext.java x: 1 commits (all time) y: 59 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/deserializer/MongoDeserializationSchema.java x: 1 commits (all time) y: 17 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoSourceSplitReader.java x: 1 commits (all time) y: 8 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplit.java x: 1 commits (all time) y: 31 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactory.java x: 1 commits (all time) y: 160 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSink.java x: 1 commits (all time) y: 104 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSource.java x: 1 commits (all time) y: 167 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoKeyExtractor.java x: 1 commits (all time) y: 101 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/BsonToRowDataConverters.java x: 1 commits (all time) y: 364 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/RowDataToBsonConverters.java x: 1 commits (all time) y: 273 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization/MongoRowDataSerializationSchema.java x: 1 commits (all time) y: 56 lines of code
364.0
lines of code
  min: 8.0
  average: 82.35
  25th percentile: 34.0
  median: 70.0
  75th percentile: 105.5
  max: 364.0
0 3.0
commits (all time)
min: 1.0 | average: 1.27 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.5 | max: 3.0

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

flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumerator.java x: 2 contributors (all time) y: 90 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoScanSourceSplitReader.java x: 2 contributors (all time) y: 161 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriter.java x: 2 contributors (all time) y: 196 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context/DefaultMongoSinkContext.java x: 2 contributors (all time) y: 25 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context/MongoSinkContext.java x: 2 contributors (all time) y: 11 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/MongoSourceReader.java x: 2 contributors (all time) y: 61 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/emitter/MongoRecordEmitter.java x: 2 contributors (all time) y: 39 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoScanSourceSplit.java x: 2 contributors (all time) y: 81 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoScanSourceSplitState.java x: 1 contributors (all time) y: 27 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplitSerializer.java x: 2 contributors (all time) y: 70 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplitState.java x: 2 contributors (all time) y: 8 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/MongoSourceBuilder.java x: 2 contributors (all time) y: 88 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoConnectorOptions.java x: 2 contributors (all time) y: 103 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/config/MongoConnectionOptions.java x: 1 contributors (all time) y: 69 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoConstants.java x: 1 contributors (all time) y: 32 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoSerdeUtils.java x: 1 contributors (all time) y: 62 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoUtils.java x: 1 contributors (all time) y: 109 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoValidationUtils.java x: 1 contributors (all time) y: 75 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/MongoSink.java x: 1 contributors (all time) y: 42 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config/MongoWriteOptions.java x: 1 contributors (all time) y: 119 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer/MongoSerializationSchema.java x: 1 contributors (all time) y: 18 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config/MongoReadOptions.java x: 1 contributors (all time) y: 116 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumState.java x: 1 contributors (all time) y: 48 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumStateSerializer.java x: 1 contributors (all time) y: 80 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner/MongoScanSplitAssigner.java x: 1 contributors (all time) y: 107 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSampleSplitter.java x: 1 contributors (all time) y: 95 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoShardedSplitter.java x: 1 contributors (all time) y: 72 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSingleSplitter.java x: 1 contributors (all time) y: 25 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitContext.java x: 1 contributors (all time) y: 86 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitVectorSplitter.java x: 1 contributors (all time) y: 68 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitters.java x: 1 contributors (all time) y: 46 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/PartitionStrategy.java x: 1 contributors (all time) y: 36 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/MongoSourceReaderContext.java x: 1 contributors (all time) y: 59 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/deserializer/MongoDeserializationSchema.java x: 1 contributors (all time) y: 17 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoSourceSplitReader.java x: 1 contributors (all time) y: 8 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplit.java x: 1 contributors (all time) y: 31 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactory.java x: 1 contributors (all time) y: 160 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSink.java x: 1 contributors (all time) y: 104 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSource.java x: 1 contributors (all time) y: 167 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoKeyExtractor.java x: 1 contributors (all time) y: 101 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/BsonToRowDataConverters.java x: 1 contributors (all time) y: 364 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/RowDataToBsonConverters.java x: 1 contributors (all time) y: 273 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization/MongoRowDataSerializationSchema.java x: 1 contributors (all time) y: 56 lines of code
364.0
lines of code
  min: 8.0
  average: 82.35
  25th percentile: 34.0
  median: 70.0
  75th percentile: 105.5
  max: 364.0
0 2.0
contributors (all time)
min: 1.0 | average: 1.24 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.5 | max: 2.0

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

flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumerator.java x: 1 commits (30d) y: 90 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoScanSourceSplitReader.java x: 1 commits (30d) y: 161 lines of code
161.0
lines of code
  min: 90.0
  average: 125.5
  25th percentile: 90.0
  median: 125.5
  75th percentile: 161.0
  max: 161.0
0 1.0
commits (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

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

flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumerator.java x: 1 contributors (30d) y: 90 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoScanSourceSplitReader.java x: 1 contributors (30d) y: 161 lines of code
161.0
lines of code
  min: 90.0
  average: 125.5
  25th percentile: 90.0
  median: 125.5
  75th percentile: 161.0
  max: 161.0
0 1.0
contributors (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

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

flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumerator.java x: 1 commits (90d) y: 90 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoScanSourceSplitReader.java x: 1 commits (90d) y: 161 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriter.java x: 1 commits (90d) y: 196 lines of code
196.0
lines of code
  min: 90.0
  average: 149.0
  25th percentile: 90.0
  median: 161.0
  75th percentile: 196.0
  max: 196.0
0 1.0
commits (90d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

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

flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumerator.java x: 1 contributors (90d) y: 90 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoScanSourceSplitReader.java x: 1 contributors (90d) y: 161 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriter.java x: 1 contributors (90d) y: 196 lines of code
196.0
lines of code
  min: 90.0
  average: 149.0
  25th percentile: 90.0
  median: 161.0
  75th percentile: 196.0
  max: 196.0
0 1.0
contributors (90d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0