apache / flink-connector-elasticsearch
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 66 files with 4,912 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 0 files changed 6-20 times (0 lines of code)
    • 66 files changed 1-5 times (4,912 lines of code)
0% | 0% | 0% | 0% | 100%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 66 files with 4,912 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 0 files changed by 6-10 contributors (0 lines of code)
    • 12 files changed by 2-5 contributors (1,535 lines of code)
    • 54 files changed by 1 contributor (3,377 lines of code)
0% | 0% | 0% | 31% | 68%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, xml, properties, md, yml, gitignore, txt, json, editorconfig, gitmodules, yaml
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
flink-connector-elasticsearch-base0% | 0% | 0% | 0% | 100%
flink-connector-elasticsearch60% | 0% | 0% | 0% | 100%
flink-connector-elasticsearch70% | 0% | 0% | 0% | 100%
tools0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
ElasticsearchSinkBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
317 22 2022-04-01 2022-11-22 3 2 gejing@gmail.com chesnay@apache.org
suppressions.xml
in tools/maven
6 - 2022-04-01 2022-09-14 2 2 gejing@gmail.com chesnay@apache.org
ElasticsearchSinkFunction.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
16 3 2022-04-01 2022-09-12 2 2 gejing@gmail.com chesnay@apache.org
ElasticsearchApiCallBridge.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
27 1 2022-04-01 2022-11-22 2 2 gejing@gmail.com chesnay@apache.org
Elasticsearch6SinkBuilder.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/sink
83 3 2022-04-01 2022-09-13 2 2 gejing@gmail.com snuyanzin@gmail.com
RowElasticsearchEmitter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
97 5 2022-04-01 2022-09-12 2 2 gejing@gmail.com chesnay@apache.org
Elasticsearch6ApiCallBridge.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6
104 6 2022-04-01 2022-11-22 2 2 gejing@gmail.com chesnay@apache.org
Elasticsearch7ApiCallBridge.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
108 6 2022-04-01 2022-11-22 2 2 gejing@gmail.com chesnay@apache.org
RowElasticsearchSinkFunction.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
110 7 2022-04-01 2022-09-12 2 2 gejing@gmail.com chesnay@apache.org
ElasticsearchConnectorOptions.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
117 1 2022-04-01 2022-04-03 2 1 gejing@gmail.com gejing@gmail.com
ElasticsearchSinkBuilderBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
194 18 2022-04-01 2022-05-16 2 2 gejing@gmail.com wang4luning@gmail.com
IndexGeneratorFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
235 15 2022-04-01 2022-09-12 2 2 gejing@gmail.com 11444089+alpreu@users.norep...
IndexGeneratorFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
238 15 2022-04-01 2022-09-12 2 2 gejing@gmail.com 11444089+alpreu@users.norep...
Elasticsearch6DynamicSink.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
253 19 2022-04-01 2022-04-03 2 1 gejing@gmail.com gejing@gmail.com
ElasticsearchSinkBuilderSupplier.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
5 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
FlushBackoffType.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
8 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
BulkRequestConsumerFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
9 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RestClientFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6
9 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RestClientFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
9 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
IndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
10 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
LogicalTypeWithIndex.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
10 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
IndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
10 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchEmitter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
11 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
11 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ActionRequestFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
11 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch7DynamicSinkFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/table
11 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
StaticIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
12 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
StaticIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
12 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
IgnoringFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util
13 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6ConnectorOptions.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
13 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6Configuration.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
13 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
BulkProcessorBuilderFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
14 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
AbstractTimeIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
16 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
AbstractTimeIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
16 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RequestFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
17 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
IndexGeneratorBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
26 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
IndexGeneratorBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
26 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RetryRejectedExecutionFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util
27 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
NoOpFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util
27 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
28 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
BufferingNoOpRequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
41 4 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
BulkProcessorConfig.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
43 6 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6Configuration.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
43 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch7Configuration.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
43 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6DynamicSinkFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
47 4 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
NetworkClientConfig.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
49 6 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
MapElasticsearchEmitter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
51 3 2022-07-04 2022-07-04 1 1 wang4luning@gmail.com wang4luning@gmail.com
ElasticsearchSink.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
51 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6BulkProcessorIndexer.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6
51 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch7BulkProcessorIndexer.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
51 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
ElasticsearchSinkBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
317 22 2022-04-01 2022-11-22 3 2 gejing@gmail.com chesnay@apache.org
Elasticsearch7ApiCallBridge.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
108 6 2022-04-01 2022-11-22 2 2 gejing@gmail.com chesnay@apache.org
Elasticsearch6ApiCallBridge.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6
104 6 2022-04-01 2022-11-22 2 2 gejing@gmail.com chesnay@apache.org
Elasticsearch6SinkBuilder.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/sink
83 3 2022-04-01 2022-09-13 2 2 gejing@gmail.com snuyanzin@gmail.com
suppressions.xml
in tools/maven
6 - 2022-04-01 2022-09-14 2 2 gejing@gmail.com chesnay@apache.org
ElasticsearchApiCallBridge.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
27 1 2022-04-01 2022-11-22 2 2 gejing@gmail.com chesnay@apache.org
ElasticsearchSinkFunction.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
16 3 2022-04-01 2022-09-12 2 2 gejing@gmail.com chesnay@apache.org
RowElasticsearchSinkFunction.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
110 7 2022-04-01 2022-09-12 2 2 gejing@gmail.com chesnay@apache.org
IndexGeneratorFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
235 15 2022-04-01 2022-09-12 2 2 gejing@gmail.com 11444089+alpreu@users.norep...
ElasticsearchSinkBuilderBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
194 18 2022-04-01 2022-05-16 2 2 gejing@gmail.com wang4luning@gmail.com
IndexGeneratorFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
238 15 2022-04-01 2022-09-12 2 2 gejing@gmail.com 11444089+alpreu@users.norep...
RowElasticsearchEmitter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
97 5 2022-04-01 2022-09-12 2 2 gejing@gmail.com chesnay@apache.org
Elasticsearch6DynamicSink.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
253 19 2022-04-01 2022-04-03 2 1 gejing@gmail.com gejing@gmail.com
ElasticsearchConnectorOptions.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
117 1 2022-04-01 2022-04-03 2 1 gejing@gmail.com gejing@gmail.com
ElasticsearchSink.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
127 14 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch7BulkProcessorIndexer.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
51 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RestClientFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
9 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch7Configuration.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
43 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch7DynamicSink.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
252 19 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch7DynamicSinkFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
148 5 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch7SinkBuilder.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink
83 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch7DynamicSinkFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/table
11 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6BulkProcessorIndexer.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6
51 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchSink.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6
127 14 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RestClientFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6
9 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6DynamicSinkFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
149 5 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6Configuration.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
43 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6DynamicSinkFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
47 4 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6Configuration.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
13 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6ConnectorOptions.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
13 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
28 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
NoOpFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util
27 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RetryRejectedExecutionFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util
27 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
IgnoringFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util
13 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
BufferingNoOpRequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
41 4 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
KeyExtractor.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
97 7 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchConfiguration.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
125 17 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
IndexGeneratorBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
26 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
IndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
10 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RequestFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
17 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchValidationUtils.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
59 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
AbstractTimeIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
16 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
StaticIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
12 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ActionRequestFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
11 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
NetworkClientConfig.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
49 6 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
FlushBackoffType.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
8 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
11 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchSink.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
51 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchEmitter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
11 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchWriter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
257 17 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
ElasticsearchWriter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
257 17 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6DynamicSink.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
253 19 2022-04-01 2022-04-03 2 1 gejing@gmail.com gejing@gmail.com
Elasticsearch7DynamicSink.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
252 19 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchDynamicSinkFactoryBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
214 9 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchDynamicSink.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
177 9 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6DynamicSinkFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
149 5 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch7DynamicSinkFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
148 5 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchSink.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
127 14 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchSink.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6
127 14 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchConfiguration.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
125 17 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchConnectorOptions.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
117 1 2022-04-01 2022-04-03 2 1 gejing@gmail.com gejing@gmail.com
ElasticsearchConfiguration.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
114 18 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchConnectorOptions.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
105 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
KeyExtractor.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
97 7 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch7SinkBuilder.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink
83 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
KeyExtractor.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
70 4 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchValidationUtils.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
59 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchValidationUtils.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
59 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch7BulkProcessorIndexer.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
51 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6BulkProcessorIndexer.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6
51 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchSink.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
51 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
MapElasticsearchEmitter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
51 3 2022-07-04 2022-07-04 1 1 wang4luning@gmail.com wang4luning@gmail.com
NetworkClientConfig.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
49 6 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6DynamicSinkFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
47 4 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch7Configuration.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
43 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6Configuration.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
43 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
BulkProcessorConfig.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
43 6 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
BufferingNoOpRequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
41 4 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
28 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
NoOpFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util
27 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RetryRejectedExecutionFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util
27 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
IndexGeneratorBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
26 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
IndexGeneratorBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
26 3 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RequestFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
17 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
AbstractTimeIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
16 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
AbstractTimeIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
16 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
BulkProcessorBuilderFactory.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
14 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6Configuration.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
13 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch6ConnectorOptions.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
13 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
IgnoringFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util
13 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
StaticIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
12 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
StaticIndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
12 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Elasticsearch7DynamicSinkFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/table
11 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ActionRequestFailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch
11 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
11 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
ElasticsearchEmitter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
11 2 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
IndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table
10 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
LogicalTypeWithIndex.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
10 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
IndexGenerator.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
10 1 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
RestClientFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7
9 - 2022-04-01 2022-04-01 1 1 gejing@gmail.com gejing@gmail.com
Correlations

File Size vs. Number of Changes: 66 points

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

Number of Contributors vs. Number of Changes: 66 points

flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java x: 2 # contributors y: 2 # changes flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java x: 2 # contributors y: 3 # changes flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/MapElasticsearchEmitter.java x: 1 # contributors y: 1 # changes flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConnectorOptions.java x: 1 # contributors y: 2 # changes
3.0
# changes
  min: 1.0
  average: 1.23
  25th percentile: 1.0
  median: 1.0
  75th percentile: 1.0
  max: 3.0
0 2.0
# contributors
min: 1.0 | average: 1.18 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 2.0

Number of Contributors vs. File Size: 66 points

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