apache / flink-connector-elasticsearch
File Size

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

Intro
Learn more...
File Size Overall
0% | 0% | 35% | 34% | 29%
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% | 35% | 34% | 29%
xml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
flink-connector-elasticsearch-base0% | 0% | 39% | 29% | 30%
flink-connector-elasticsearch60% | 0% | 28% | 42% | 29%
flink-connector-elasticsearch70% | 0% | 30% | 46% | 23%
tools0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
ElasticsearchSinkBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
317 22
ElasticsearchWriter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
257 17
Elasticsearch6DynamicSink.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
253 19
Elasticsearch7DynamicSink.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
252 19
IndexGeneratorFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
238 15
IndexGeneratorFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
235 15
ElasticsearchDynamicSinkFactoryBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
214 9
ElasticsearchSinkBuilderBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
194 18
ElasticsearchDynamicSink.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
177 9
Elasticsearch6DynamicSinkFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
149 5
Elasticsearch7DynamicSinkFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
148 5
ElasticsearchSink.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
127 14
ElasticsearchSink.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6
127 14
ElasticsearchConfiguration.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
125 17
ElasticsearchConnectorOptions.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
117 1
ElasticsearchConfiguration.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
114 18
RowElasticsearchSinkFunction.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
110 7
Elasticsearch7ApiCallBridge.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
108 6
ElasticsearchConnectorOptions.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
105 -
Elasticsearch6ApiCallBridge.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6
104 6
KeyExtractor.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
97 7
RowElasticsearchEmitter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
97 5
Elasticsearch7SinkBuilder.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink
83 3
Elasticsearch6SinkBuilder.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/sink
83 3
KeyExtractor.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
70 4
ElasticsearchValidationUtils.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
59 3
ElasticsearchValidationUtils.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
59 3
Elasticsearch7BulkProcessorIndexer.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
51 3
Elasticsearch6BulkProcessorIndexer.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6
51 3
ElasticsearchSink.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
51 2
MapElasticsearchEmitter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
51 3
NetworkClientConfig.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
49 6
Elasticsearch6DynamicSinkFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
47 4
Elasticsearch7Configuration.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
43 2
Elasticsearch6Configuration.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
43 2
BulkProcessorConfig.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
43 6
BufferingNoOpRequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
41 4
RequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
28 1
ElasticsearchApiCallBridge.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
27 1
NoOpFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util
27 3
RetryRejectedExecutionFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util
27 1
IndexGeneratorBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
26 3
IndexGeneratorBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
26 3
RequestFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
17 -
ElasticsearchSinkFunction.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
16 3
AbstractTimeIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
16 2
AbstractTimeIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
16 2
BulkProcessorBuilderFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
14 -
Elasticsearch6Configuration.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
13 1
Elasticsearch6ConnectorOptions.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
13 1
Files With Most Units (Top 50)
File# lines# units
ElasticsearchSinkBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
317 22
Elasticsearch7DynamicSink.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
252 19
Elasticsearch6DynamicSink.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
253 19
ElasticsearchSinkBuilderBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
194 18
ElasticsearchConfiguration.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
114 18
ElasticsearchConfiguration.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
125 17
ElasticsearchWriter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
257 17
IndexGeneratorFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
235 15
IndexGeneratorFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
238 15
ElasticsearchSink.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
127 14
ElasticsearchSink.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6
127 14
ElasticsearchDynamicSinkFactoryBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
214 9
ElasticsearchDynamicSink.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
177 9
KeyExtractor.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
97 7
RowElasticsearchSinkFunction.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
110 7
Elasticsearch7ApiCallBridge.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
108 6
Elasticsearch6ApiCallBridge.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6
104 6
NetworkClientConfig.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
49 6
BulkProcessorConfig.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
43 6
Elasticsearch7DynamicSinkFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
148 5
Elasticsearch6DynamicSinkFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
149 5
RowElasticsearchEmitter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
97 5
Elasticsearch6DynamicSinkFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
47 4
BufferingNoOpRequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
41 4
KeyExtractor.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
70 4
Elasticsearch7BulkProcessorIndexer.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
51 3
Elasticsearch7SinkBuilder.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink
83 3
Elasticsearch6BulkProcessorIndexer.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6
51 3
Elasticsearch6SinkBuilder.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/sink
83 3
NoOpFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util
27 3
ElasticsearchSinkFunction.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
16 3
IndexGeneratorBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
26 3
ElasticsearchValidationUtils.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
59 3
MapElasticsearchEmitter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
51 3
IndexGeneratorBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
26 3
ElasticsearchValidationUtils.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
59 3
Elasticsearch7Configuration.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
43 2
Elasticsearch6Configuration.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
43 2
AbstractTimeIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
16 2
StaticIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
12 2
ElasticsearchSink.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
51 2
ElasticsearchEmitter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
11 2
AbstractTimeIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
16 2
StaticIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
12 2
Elasticsearch7DynamicSinkFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/table
11 1
Elasticsearch6Configuration.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
13 1
Elasticsearch6ConnectorOptions.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
13 1
ElasticsearchApiCallBridge.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
27 1
RequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
28 1
RetryRejectedExecutionFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util
27 1
Files With Long Lines (Top 10)

There are 10 files with lines longer than 120 characters. In total, there are 50 long lines.

File# lines# units# long lines
Elasticsearch6DynamicSinkFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
149 5 11
Elasticsearch7DynamicSinkFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
148 5 10
ElasticsearchConfiguration.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
114 18 8
ElasticsearchConfiguration.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
125 17 5
ElasticsearchDynamicSinkFactoryBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
214 9 5
Elasticsearch7Configuration.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
43 2 3
Elasticsearch6Configuration.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
43 2 3
ElasticsearchConnectorOptions.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
117 1 3
ElasticsearchValidationUtils.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
59 3 1
ElasticsearchSinkBuilderBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
194 18 1
Correlations

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

flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java x: 2 commits (all time) y: 27 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java x: 3 commits (all time) y: 317 lines of code flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6ApiCallBridge.java x: 2 commits (all time) y: 104 lines of code flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7ApiCallBridge.java x: 2 commits (all time) y: 108 lines of code tools/maven/suppressions.xml x: 2 commits (all time) y: 6 lines of code flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch6SinkBuilder.java x: 2 commits (all time) y: 83 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorFactory.java x: 2 commits (all time) y: 238 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorFactory.java x: 2 commits (all time) y: 235 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/RowElasticsearchEmitter.java x: 2 commits (all time) y: 97 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkFunction.java x: 2 commits (all time) y: 16 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RowElasticsearchSinkFunction.java x: 2 commits (all time) y: 110 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/MapElasticsearchEmitter.java x: 1 commits (all time) y: 51 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilderBase.java x: 2 commits (all time) y: 194 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConnectorOptions.java x: 2 commits (all time) y: 117 lines of code flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java x: 2 commits (all time) y: 253 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorBuilderFactory.java x: 1 commits (all time) y: 14 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorConfig.java x: 1 commits (all time) y: 43 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkRequestConsumerFactory.java x: 1 commits (all time) y: 9 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchEmitter.java x: 1 commits (all time) y: 11 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriter.java x: 1 commits (all time) y: 257 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/FlushBackoffType.java x: 1 commits (all time) y: 8 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/NetworkClientConfig.java x: 1 commits (all time) y: 49 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/AbstractTimeIndexGenerator.java x: 1 commits (all time) y: 16 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchConfiguration.java x: 1 commits (all time) y: 114 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchConnectorOptions.java x: 1 commits (all time) y: 105 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSink.java x: 1 commits (all time) y: 177 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSinkFactoryBase.java x: 1 commits (all time) y: 214 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchSinkBuilderSupplier.java x: 1 commits (all time) y: 5 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchValidationUtils.java x: 1 commits (all time) y: 59 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorBase.java x: 1 commits (all time) y: 26 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/KeyExtractor.java x: 1 commits (all time) y: 70 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/StaticIndexGenerator.java x: 1 commits (all time) y: 12 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BufferingNoOpRequestIndexer.java x: 1 commits (all time) y: 41 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java x: 1 commits (all time) y: 28 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConfiguration.java x: 1 commits (all time) y: 125 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/KeyExtractor.java x: 1 commits (all time) y: 97 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RequestFactory.java x: 1 commits (all time) y: 17 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/IgnoringFailureHandler.java x: 1 commits (all time) y: 13 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/NoOpFailureHandler.java x: 1 commits (all time) y: 27 lines of code flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch6DynamicSinkFactory.java x: 1 commits (all time) y: 47 lines of code flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkFactory.java x: 1 commits (all time) y: 149 lines of code flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java x: 1 commits (all time) y: 127 lines of code flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch7SinkBuilder.java x: 1 commits (all time) y: 83 lines of code flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java x: 1 commits (all time) y: 252 lines of code flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkFactory.java x: 1 commits (all time) y: 148 lines of code
317.0
lines of code
  min: 5.0
  average: 74.42
  25th percentile: 13.0
  median: 45.0
  75th percentile: 111.0
  max: 317.0
0 3.0
commits (all time)
min: 1.0 | average: 1.23 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 3.0

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

flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java x: 2 contributors (all time) y: 27 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java x: 2 contributors (all time) y: 317 lines of code flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6ApiCallBridge.java x: 2 contributors (all time) y: 104 lines of code flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7ApiCallBridge.java x: 2 contributors (all time) y: 108 lines of code tools/maven/suppressions.xml x: 2 contributors (all time) y: 6 lines of code flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch6SinkBuilder.java x: 2 contributors (all time) y: 83 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorFactory.java x: 2 contributors (all time) y: 238 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorFactory.java x: 2 contributors (all time) y: 235 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/RowElasticsearchEmitter.java x: 2 contributors (all time) y: 97 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkFunction.java x: 2 contributors (all time) y: 16 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RowElasticsearchSinkFunction.java x: 2 contributors (all time) y: 110 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/MapElasticsearchEmitter.java x: 1 contributors (all time) y: 51 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilderBase.java x: 2 contributors (all time) y: 194 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConnectorOptions.java x: 1 contributors (all time) y: 117 lines of code flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java x: 1 contributors (all time) y: 253 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorBuilderFactory.java x: 1 contributors (all time) y: 14 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorConfig.java x: 1 contributors (all time) y: 43 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkRequestConsumerFactory.java x: 1 contributors (all time) y: 9 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchEmitter.java x: 1 contributors (all time) y: 11 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriter.java x: 1 contributors (all time) y: 257 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/FlushBackoffType.java x: 1 contributors (all time) y: 8 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/NetworkClientConfig.java x: 1 contributors (all time) y: 49 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/AbstractTimeIndexGenerator.java x: 1 contributors (all time) y: 16 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchConfiguration.java x: 1 contributors (all time) y: 114 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchConnectorOptions.java x: 1 contributors (all time) y: 105 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSink.java x: 1 contributors (all time) y: 177 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSinkFactoryBase.java x: 1 contributors (all time) y: 214 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchSinkBuilderSupplier.java x: 1 contributors (all time) y: 5 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchValidationUtils.java x: 1 contributors (all time) y: 59 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorBase.java x: 1 contributors (all time) y: 26 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/KeyExtractor.java x: 1 contributors (all time) y: 70 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/StaticIndexGenerator.java x: 1 contributors (all time) y: 12 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BufferingNoOpRequestIndexer.java x: 1 contributors (all time) y: 41 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java x: 1 contributors (all time) y: 28 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConfiguration.java x: 1 contributors (all time) y: 125 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/KeyExtractor.java x: 1 contributors (all time) y: 97 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RequestFactory.java x: 1 contributors (all time) y: 17 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/IgnoringFailureHandler.java x: 1 contributors (all time) y: 13 lines of code flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/NoOpFailureHandler.java x: 1 contributors (all time) y: 27 lines of code flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch6DynamicSinkFactory.java x: 1 contributors (all time) y: 47 lines of code flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkFactory.java x: 1 contributors (all time) y: 149 lines of code flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java x: 1 contributors (all time) y: 127 lines of code flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch7SinkBuilder.java x: 1 contributors (all time) y: 83 lines of code flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java x: 1 contributors (all time) y: 252 lines of code flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkFactory.java x: 1 contributors (all time) y: 148 lines of code
317.0
lines of code
  min: 5.0
  average: 74.42
  25th percentile: 13.0
  median: 45.0
  75th percentile: 111.0
  max: 317.0
0 2.0
contributors (all time)
min: 1.0 | average: 1.18 | 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): 0 points

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

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

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