apache / flink-connector-opensearch
File Size

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

Intro
Learn more...
File Size Overall
0% | 0% | 53% | 14% | 31%
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% | 53% | 15% | 31%
xml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
flink-connector-opensearch0% | 0% | 53% | 15% | 31%
tools0% | 0% | 0% | 0% | 100%
Longest Files (Top 36)
File# lines# units
OpensearchSink.java
in flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch
479 39
OpensearchWriter.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
268 16
IndexGeneratorFactory.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
236 15
OpensearchSinkBuilder.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
211 21
OpensearchDynamicSinkFactory.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
202 7
OpensearchDynamicSink.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
162 9
OpensearchConfiguration.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
118 19
OpensearchConnectorOptions.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
111 -
RowOpensearchEmitter.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
92 5
KeyExtractor.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
70 4
DefaultRestClientFactory.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
69 2
OpensearchValidationUtils.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
59 3
NetworkClientConfig.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
56 7
OpensearchSink.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
55 2
OpensearchBulkProcessorIndexer.java
in flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch
50 3
BulkProcessorConfig.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
43 6
BufferingNoOpRequestIndexer.java
in flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch
41 4
DefaultRestClientConfig.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
37 1
RequestIndexer.java
in flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch
28 1
NoOpFailureHandler.java
in flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/util
27 3
RestClientFactory.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
27 -
IndexGeneratorBase.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
26 3
OpensearchSinkFunction.java
in flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch
16 3
AbstractTimeIndexGenerator.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
16 2
StaticIndexGenerator.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
12 2
ActionRequestFailureHandler.java
in flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch
11 -
RequestIndexer.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
11 -
OpensearchEmitter.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
11 2
LogicalTypeWithIndex.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
10 -
IndexGenerator.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
10 1
BulkRequestConsumerFactory.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
9 -
RestClientFactory.java
in flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch
8 -
FlushBackoffType.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
8 -
FailureHandler.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
8 -
suppressions.xml
in tools/maven
6 -
OpensearchSinkBuilderSupplier.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
4 -
Files With Most Units (Top 25)
File# lines# units
OpensearchSink.java
in flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch
479 39
OpensearchSinkBuilder.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
211 21
OpensearchConfiguration.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
118 19
OpensearchWriter.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
268 16
IndexGeneratorFactory.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
236 15
OpensearchDynamicSink.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
162 9
NetworkClientConfig.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
56 7
OpensearchDynamicSinkFactory.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
202 7
BulkProcessorConfig.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
43 6
RowOpensearchEmitter.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
92 5
BufferingNoOpRequestIndexer.java
in flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch
41 4
KeyExtractor.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
70 4
NoOpFailureHandler.java
in flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/util
27 3
OpensearchBulkProcessorIndexer.java
in flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch
50 3
OpensearchSinkFunction.java
in flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch
16 3
OpensearchValidationUtils.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
59 3
IndexGeneratorBase.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
26 3
OpensearchSink.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
55 2
DefaultRestClientFactory.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
69 2
OpensearchEmitter.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
11 2
AbstractTimeIndexGenerator.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
16 2
StaticIndexGenerator.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
12 2
RequestIndexer.java
in flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch
28 1
DefaultRestClientConfig.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
37 1
IndexGenerator.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
10 1
Files With Long Lines (Top 3)

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

File# lines# units# long lines
OpensearchConfiguration.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
118 19 4
OpensearchSinkBuilder.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink
211 21 1
OpensearchDynamicSinkFactory.java
in flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table
202 7 1
Correlations

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

flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/FailureHandler.java x: 1 commits (all time) y: 8 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSink.java x: 3 commits (all time) y: 55 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkBuilder.java x: 3 commits (all time) y: 211 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchWriter.java x: 3 commits (all time) y: 268 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientConfig.java x: 1 commits (all time) y: 37 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientFactory.java x: 1 commits (all time) y: 69 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/RestClientFactory.java x: 1 commits (all time) y: 27 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchConnectorOptions.java x: 2 commits (all time) y: 111 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/BulkProcessorConfig.java x: 1 commits (all time) y: 43 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/NetworkClientConfig.java x: 1 commits (all time) y: 56 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchEmitter.java x: 1 commits (all time) y: 11 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/AbstractTimeIndexGenerator.java x: 1 commits (all time) y: 16 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/IndexGeneratorBase.java x: 1 commits (all time) y: 26 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/IndexGeneratorFactory.java x: 1 commits (all time) y: 236 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/KeyExtractor.java x: 1 commits (all time) y: 70 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchConfiguration.java x: 1 commits (all time) y: 118 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSink.java x: 1 commits (all time) y: 162 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSinkFactory.java x: 1 commits (all time) y: 202 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchSinkBuilderSupplier.java x: 1 commits (all time) y: 4 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchValidationUtils.java x: 1 commits (all time) y: 59 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/RowOpensearchEmitter.java x: 1 commits (all time) y: 92 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/StaticIndexGenerator.java x: 1 commits (all time) y: 12 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/BufferingNoOpRequestIndexer.java x: 1 commits (all time) y: 41 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/OpensearchBulkProcessorIndexer.java x: 1 commits (all time) y: 50 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/OpensearchSink.java x: 1 commits (all time) y: 479 lines of code tools/maven/suppressions.xml x: 1 commits (all time) y: 6 lines of code
479.0
lines of code
  min: 4.0
  average: 72.42
  25th percentile: 11.0
  median: 32.5
  75th percentile: 86.5
  max: 479.0
0 3.0
commits (all time)
min: 1.0 | average: 1.19 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 3.0

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

flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/FailureHandler.java x: 1 contributors (all time) y: 8 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSink.java x: 2 contributors (all time) y: 55 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkBuilder.java x: 2 contributors (all time) y: 211 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchWriter.java x: 2 contributors (all time) y: 268 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientConfig.java x: 1 contributors (all time) y: 37 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientFactory.java x: 1 contributors (all time) y: 69 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/RestClientFactory.java x: 1 contributors (all time) y: 27 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchConnectorOptions.java x: 1 contributors (all time) y: 111 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/BulkProcessorConfig.java x: 1 contributors (all time) y: 43 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/NetworkClientConfig.java x: 1 contributors (all time) y: 56 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchEmitter.java x: 1 contributors (all time) y: 11 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/AbstractTimeIndexGenerator.java x: 1 contributors (all time) y: 16 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/IndexGeneratorBase.java x: 1 contributors (all time) y: 26 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/IndexGeneratorFactory.java x: 1 contributors (all time) y: 236 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/KeyExtractor.java x: 1 contributors (all time) y: 70 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchConfiguration.java x: 1 contributors (all time) y: 118 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSink.java x: 1 contributors (all time) y: 162 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSinkFactory.java x: 1 contributors (all time) y: 202 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchSinkBuilderSupplier.java x: 1 contributors (all time) y: 4 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchValidationUtils.java x: 1 contributors (all time) y: 59 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/RowOpensearchEmitter.java x: 1 contributors (all time) y: 92 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/StaticIndexGenerator.java x: 1 contributors (all time) y: 12 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/BufferingNoOpRequestIndexer.java x: 1 contributors (all time) y: 41 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/OpensearchBulkProcessorIndexer.java x: 1 contributors (all time) y: 50 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/OpensearchSink.java x: 1 contributors (all time) y: 479 lines of code tools/maven/suppressions.xml x: 1 contributors (all time) y: 6 lines of code
479.0
lines of code
  min: 4.0
  average: 72.42
  25th percentile: 11.0
  median: 32.5
  75th percentile: 86.5
  max: 479.0
0 2.0
contributors (all time)
min: 1.0 | average: 1.08 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 2.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): 7 points

flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/FailureHandler.java x: 1 commits (90d) y: 8 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSink.java x: 2 commits (90d) y: 55 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkBuilder.java x: 2 commits (90d) y: 211 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchWriter.java x: 2 commits (90d) y: 268 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientConfig.java x: 1 commits (90d) y: 37 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientFactory.java x: 1 commits (90d) y: 69 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/RestClientFactory.java x: 1 commits (90d) y: 27 lines of code
268.0
lines of code
  min: 8.0
  average: 96.43
  25th percentile: 27.0
  median: 55.0
  75th percentile: 211.0
  max: 268.0
0 2.0
commits (90d)
min: 1.0 | average: 1.43 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 2.0

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

flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/FailureHandler.java x: 1 contributors (90d) y: 8 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSink.java x: 2 contributors (90d) y: 55 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkBuilder.java x: 2 contributors (90d) y: 211 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchWriter.java x: 2 contributors (90d) y: 268 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientConfig.java x: 1 contributors (90d) y: 37 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientFactory.java x: 1 contributors (90d) y: 69 lines of code flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/RestClientFactory.java x: 1 contributors (90d) y: 27 lines of code
268.0
lines of code
  min: 8.0
  average: 96.43
  25th percentile: 27.0
  median: 55.0
  75th percentile: 211.0
  max: 268.0
0 2.0
contributors (90d)
min: 1.0 | average: 1.43 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 2.0