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% | 23% | 36% | 40%
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% | 23% | 36% | 40%
xml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
flink-connector-mongodb0% | 0% | 23% | 36% | 40%
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
MongoDynamicTableSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 229 13
MongoFilterPushDownVisitor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 204 9
MongoWriter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer
 196 8
MongoScanSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 165 7
MongoDynamicTableFactory.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 157 7
MongoReadOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config
 139 17
MongoDynamicTableSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 132 9
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
MongoConnectorOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 117 1
MongoSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 115 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
MongoConfiguration.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config
 104 21
MongoPrimaryKeyExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 101 6
MongoScanSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 100 11
MongoSourceBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 96 14
MongoSampleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 95 5
MongoSourceEnumerator.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 90 8
MongoSplitContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 86 12
MongoPaginationSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 85 1
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
MongoShardKeysExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 75 4
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
MongoRowDataSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 63 4
MongoSerdeUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 62 5
MongoSinkBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 62 9
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
MongoSplitters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 48 2
MongoSourceEnumState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 48 7
MongoSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 42 2
PartitionStrategy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 40 2
MongoRecordEmitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/emitter
 39 5
MongoConstants.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 34 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
MongoRowDataDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 25 3
DefaultMongoSinkContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context
 25 3
FilterHandlingPolicy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 24 2
MongoSingleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 23 2
MongoSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer
 18 1
MongoSplitAssigner.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner
 18 -
MongoDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/deserializer
 17 1
Files With Most Units (Top 49)
File# lines# units
MongoConfiguration.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config
 104 21
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
 139 17
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
 96 14
MongoDynamicTableSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 229 13
MongoConnectionOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/config
 69 12
MongoSplitContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 86 12
MongoSourceReaderContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader
 59 12
MongoScanSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 100 11
MongoDynamicTableSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 132 9
MongoFilterPushDownVisitor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 204 9
MongoSinkBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 62 9
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
MongoWriter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer
 196 8
MongoSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 115 8
MongoSourceEnumerator.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 90 8
MongoDynamicTableFactory.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 157 7
MongoScanSplitAssigner.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner
 107 7
MongoSourceEnumState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 48 7
MongoScanSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 165 7
MongoPrimaryKeyExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 101 6
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
MongoSampleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 95 5
MongoSourceSplitSerializer.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 70 5
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
MongoRowDataSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 63 4
MongoShardKeysExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 75 4
MongoSourceEnumStateSerializer.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 80 4
MongoSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 31 4
MongoRowDataDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 25 3
DefaultMongoSinkContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context
 25 3
MongoScanSourceSplitState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 27 3
MongoValidationUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 75 2
FilterHandlingPolicy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 24 2
MongoSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 42 2
PartitionStrategy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 40 2
MongoSingleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 23 2
MongoSplitVectorSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 68 2
MongoSplitters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 48 2
MongoShardedSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 72 2
MongoConstants.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 34 1
MongoConnectorOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 117 1
MongoSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer
 18 1
MongoPaginationSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 85 1
MongoDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/deserializer
 17 1
Files With Long Lines (Top 4)

There are 4 files with lines longer than 120 characters. In total, there are 22 long lines.

File# lines# units# long lines
MongoConnectorOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 117 1 18
PartitionStrategy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 40 2 2
MongoPaginationSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 85 1 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): 53 points

flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/FilterHandlingPolicy.java x: 2 commits (all time) y: 24 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config/MongoReadOptions.java x: 3 commits (all time) y: 139 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactory.java x: 5 commits (all time) y: 157 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSink.java x: 3 commits (all time) y: 132 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoConstants.java x: 2 commits (all time) y: 34 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoPaginationSplitter.java x: 1 commits (all time) y: 85 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSampleSplitter.java x: 2 commits (all time) y: 95 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitVectorSplitter.java x: 2 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: 2 commits (all time) y: 48 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/PartitionStrategy.java x: 2 commits (all time) y: 40 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoConnectorOptions.java x: 4 commits (all time) y: 117 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config/MongoConfiguration.java x: 3 commits (all time) y: 104 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSource.java x: 3 commits (all time) y: 229 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoValidationUtils.java x: 2 commits (all time) y: 75 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoPrimaryKeyExtractor.java x: 1 commits (all time) y: 101 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoShardKeysExtractor.java x: 1 commits (all time) y: 75 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization/MongoRowDataSerializationSchema.java x: 2 commits (all time) y: 63 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/MongoSource.java x: 2 commits (all time) y: 115 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/MongoSourceBuilder.java x: 3 commits (all time) y: 96 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoScanSourceSplitReader.java x: 5 commits (all time) y: 165 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoFilterPushDownVisitor.java x: 1 commits (all time) y: 204 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoSourceSplitReader.java x: 2 commits (all time) y: 8 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoScanSourceSplit.java x: 3 commits (all time) y: 100 lines of code 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/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/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/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/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/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/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/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/MongoSplitContext.java x: 1 commits (all time) y: 86 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/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/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/MongoRowDataDeserializationSchema.java x: 1 commits (all time) y: 25 lines of code
364.0
lines of code
  min: 8.0
  average: 86.89
  25th percentile: 36.5
  median: 72.0
  75th percentile: 112.0
  max: 364.0
0 5.0
commits (all time)
min: 1.0 | average: 1.79 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 2.0 | max: 5.0

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

flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/FilterHandlingPolicy.java x: 2 contributors (all time) y: 24 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config/MongoReadOptions.java x: 2 contributors (all time) y: 139 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactory.java x: 3 contributors (all time) y: 157 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSink.java x: 2 contributors (all time) y: 132 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoConstants.java x: 2 contributors (all time) y: 34 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoPaginationSplitter.java x: 1 contributors (all time) y: 85 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSampleSplitter.java x: 2 contributors (all time) y: 95 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitVectorSplitter.java x: 2 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: 2 contributors (all time) y: 48 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/PartitionStrategy.java x: 2 contributors (all time) y: 40 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoConnectorOptions.java x: 4 contributors (all time) y: 117 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config/MongoConfiguration.java x: 3 contributors (all time) y: 104 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSource.java x: 3 contributors (all time) y: 229 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoValidationUtils.java x: 2 contributors (all time) y: 75 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoPrimaryKeyExtractor.java x: 1 contributors (all time) y: 101 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoShardKeysExtractor.java x: 1 contributors (all time) y: 75 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization/MongoRowDataSerializationSchema.java x: 2 contributors (all time) y: 63 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/MongoSource.java x: 2 contributors (all time) y: 115 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: 165 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoFilterPushDownVisitor.java x: 1 contributors (all time) y: 204 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoSourceSplitReader.java x: 2 contributors (all time) y: 8 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoScanSourceSplit.java x: 2 contributors (all time) y: 100 lines of code 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/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/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/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/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/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/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/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/MongoSplitContext.java x: 1 contributors (all time) y: 86 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/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/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/MongoRowDataDeserializationSchema.java x: 1 contributors (all time) y: 25 lines of code
364.0
lines of code
  min: 8.0
  average: 86.89
  25th percentile: 36.5
  median: 72.0
  75th percentile: 112.0
  max: 364.0
0 4.0
contributors (all time)
min: 1.0 | average: 1.62 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 2.0 | max: 4.0

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

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

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

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

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

flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/FilterHandlingPolicy.java x: 1 commits (90d) y: 24 lines of code
24.0
lines of code
  min: 24.0
  average: 24.0
  25th percentile: 24.0
  median: 24.0
  75th percentile: 24.0
  max: 24.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): 1 points

flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/FilterHandlingPolicy.java x: 1 contributors (90d) y: 24 lines of code
24.0
lines of code
  min: 24.0
  average: 24.0
  25th percentile: 24.0
  median: 24.0
  75th percentile: 24.0
  max: 24.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