apache / flink-connector-elasticsearch
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 47 files with 3,296 lines of code in files.
    • 37 files that are 366+ days old (2,395 lines of code)
    • 0 files that are 181-365 days old (0 lines of code)
    • 0 files that are 91-180 days old (0 lines of code)
    • 10 files that are 31-90 days old (901 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
72% | 0% | 0% | 27% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 47 files with 3,296 lines of code in files.
    • 29 files have been last changed 366+ days ago (1,273 lines of code)
    • 2 files have been last changed 181-365 days ago (207 lines of code)
    • 0 files have been last changed 91-180 days ago (0 lines of code)
    • 16 files have been last changed 31-90 days ago (1,816 lines of code)
    • 0 files have been last changed 1-30 days ago (0 lines of code)
38% | 6% | 0% | 55% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, xml, properties, md, yaml, gitignore, txt, editorconfig, gitmodules
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java72% | 0% | 0% | 27% | 0%
xml100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java38% | 6% | 0% | 55% | 0%
xml100% | 0% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
flink-connector-elasticsearch-base69% | 0% | 0% | 30% | 0%
flink-connector-elasticsearch8100% | 0% | 0% | 0% | 0%
flink-connector-elasticsearch653% | 0% | 0% | 46% | 0%
flink-connector-elasticsearch758% | 0% | 0% | 41% | 0%
tools100% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
flink-connector-elasticsearch-base40% | 0% | 0% | 59% | 0%
flink-connector-elasticsearch653% | 0% | 0% | 46% | 0%
flink-connector-elasticsearch758% | 0% | 0% | 41% | 0%
flink-connector-elasticsearch814% | 41% | 0% | 43% | 0%
tools100% | 0% | 0% | 0% | 0%
Oldest Files (Top 47)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
ElasticsearchSinkBuilderBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
263 25 2022-04-01 2025-03-26 5 5 gejing@gmail.com reswqa@163.com
ElasticsearchWriter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
253 20 2022-04-01 2025-03-26 5 4 gejing@gmail.com reswqa@163.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...
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
ElasticsearchConfiguration.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
114 18 2022-04-01 2025-03-26 3 3 gejing@gmail.com reswqa@163.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
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
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
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
ElasticsearchSink.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
66 4 2022-04-01 2025-03-26 4 4 gejing@gmail.com reswqa@163.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
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
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
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
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
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
RequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
12 - 2022-04-01 2023-12-15 2 2 gejing@gmail.com pfischer@wikimedia.org
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/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
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
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
suppressions.xml
in tools/maven
6 - 2022-04-01 2022-09-14 2 2 gejing@gmail.com chesnay@apache.org
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
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
Elasticsearch8AsyncWriter.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
150 8 2023-03-25 2025-03-26 4 4 matheus.felisberto@hotmail.com reswqa@163.com
Elasticsearch8AsyncSinkBuilder.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
132 15 2023-03-25 2024-05-26 3 3 matheus.felisberto@hotmail.com liuml07@apache.org
NetworkConfig.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
75 4 2023-03-25 2024-05-26 3 3 matheus.felisberto@hotmail.com liuml07@apache.org
Elasticsearch8AsyncSink.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
69 1 2023-03-25 2025-03-26 3 3 matheus.felisberto@hotmail.com reswqa@163.com
OperationSerializer.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
34 4 2023-03-25 2023-03-25 1 1 matheus.felisberto@hotmail.com matheus.felisberto@hotmail.com
Operation.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
22 4 2023-03-25 2023-03-25 1 1 matheus.felisberto@hotmail.com matheus.felisberto@hotmail.com
Elasticsearch8AsyncSinkSerializer.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
18 3 2023-03-25 2023-03-25 1 1 matheus.felisberto@hotmail.com matheus.felisberto@hotmail.com
BulkResponseInspector.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
20 - 2023-12-01 2023-12-01 1 1 pfischer@wikimedia.org pfischer@wikimedia.org
FailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
8 - 2023-12-01 2023-12-01 1 1 pfischer@wikimedia.org pfischer@wikimedia.org
ElasticsearchDynamicTableFactoryBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
270 11 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
ElasticsearchRowDataLookupFunction.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/lookup
151 4 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
ElasticsearchDynamicSource.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
124 7 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
NetworkClientConfig.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch
120 18 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
RestClientUtils.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/utils
69 2 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch6DynamicTableFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
53 5 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch7ApiCallBridge.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch
42 3 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch6ApiCallBridge.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch
41 3 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch7DynamicTableFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/table
17 2 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
ElasticsearchApiCallBridge.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch
14 - 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Files Not Recently Changed (Top 47)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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...
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
Elasticsearch8AsyncSinkSerializer.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
18 3 2023-03-25 2023-03-25 1 1 matheus.felisberto@hotmail.com matheus.felisberto@hotmail.com
Operation.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
22 4 2023-03-25 2023-03-25 1 1 matheus.felisberto@hotmail.com matheus.felisberto@hotmail.com
OperationSerializer.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
34 4 2023-03-25 2023-03-25 1 1 matheus.felisberto@hotmail.com matheus.felisberto@hotmail.com
FailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
8 - 2023-12-01 2023-12-01 1 1 pfischer@wikimedia.org pfischer@wikimedia.org
BulkResponseInspector.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
20 - 2023-12-01 2023-12-01 1 1 pfischer@wikimedia.org pfischer@wikimedia.org
RequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
12 - 2022-04-01 2023-12-15 2 2 gejing@gmail.com pfischer@wikimedia.org
NetworkConfig.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
75 4 2023-03-25 2024-05-26 3 3 matheus.felisberto@hotmail.com liuml07@apache.org
Elasticsearch8AsyncSinkBuilder.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
132 15 2023-03-25 2024-05-26 3 3 matheus.felisberto@hotmail.com liuml07@apache.org
ElasticsearchApiCallBridge.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch
14 - 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch7DynamicTableFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/table
17 2 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch6ApiCallBridge.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch
41 3 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch7ApiCallBridge.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch
42 3 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch6DynamicTableFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
53 5 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
ElasticsearchSink.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
66 4 2022-04-01 2025-03-26 4 4 gejing@gmail.com reswqa@163.com
Elasticsearch8AsyncSink.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
69 1 2023-03-25 2025-03-26 3 3 matheus.felisberto@hotmail.com reswqa@163.com
RestClientUtils.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/utils
69 2 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
ElasticsearchConfiguration.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
114 18 2022-04-01 2025-03-26 3 3 gejing@gmail.com reswqa@163.com
NetworkClientConfig.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch
120 18 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
ElasticsearchDynamicSource.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
124 7 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch8AsyncWriter.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
150 8 2023-03-25 2025-03-26 4 4 matheus.felisberto@hotmail.com reswqa@163.com
ElasticsearchRowDataLookupFunction.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/lookup
151 4 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
ElasticsearchWriter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
253 20 2022-04-01 2025-03-26 5 4 gejing@gmail.com reswqa@163.com
ElasticsearchSinkBuilderBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
263 25 2022-04-01 2025-03-26 5 5 gejing@gmail.com reswqa@163.com
ElasticsearchDynamicTableFactoryBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
270 11 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Most Recently Created Files (Top 47)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
ElasticsearchDynamicTableFactoryBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
270 11 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
ElasticsearchRowDataLookupFunction.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/lookup
151 4 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
ElasticsearchDynamicSource.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
124 7 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
NetworkClientConfig.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch
120 18 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
RestClientUtils.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/utils
69 2 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch6DynamicTableFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
53 5 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch7ApiCallBridge.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch
42 3 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch6ApiCallBridge.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch
41 3 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch7DynamicTableFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/table
17 2 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
ElasticsearchApiCallBridge.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch
14 - 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
BulkResponseInspector.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
20 - 2023-12-01 2023-12-01 1 1 pfischer@wikimedia.org pfischer@wikimedia.org
FailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
8 - 2023-12-01 2023-12-01 1 1 pfischer@wikimedia.org pfischer@wikimedia.org
Elasticsearch8AsyncWriter.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
150 8 2023-03-25 2025-03-26 4 4 matheus.felisberto@hotmail.com reswqa@163.com
Elasticsearch8AsyncSinkBuilder.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
132 15 2023-03-25 2024-05-26 3 3 matheus.felisberto@hotmail.com liuml07@apache.org
NetworkConfig.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
75 4 2023-03-25 2024-05-26 3 3 matheus.felisberto@hotmail.com liuml07@apache.org
Elasticsearch8AsyncSink.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
69 1 2023-03-25 2025-03-26 3 3 matheus.felisberto@hotmail.com reswqa@163.com
OperationSerializer.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
34 4 2023-03-25 2023-03-25 1 1 matheus.felisberto@hotmail.com matheus.felisberto@hotmail.com
Operation.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
22 4 2023-03-25 2023-03-25 1 1 matheus.felisberto@hotmail.com matheus.felisberto@hotmail.com
Elasticsearch8AsyncSinkSerializer.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
18 3 2023-03-25 2023-03-25 1 1 matheus.felisberto@hotmail.com matheus.felisberto@hotmail.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
ElasticsearchSinkBuilderBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
263 25 2022-04-01 2025-03-26 5 5 gejing@gmail.com reswqa@163.com
ElasticsearchWriter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
253 20 2022-04-01 2025-03-26 5 4 gejing@gmail.com reswqa@163.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...
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
ElasticsearchConfiguration.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
114 18 2022-04-01 2025-03-26 3 3 gejing@gmail.com reswqa@163.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
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
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
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
ElasticsearchSink.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
66 4 2022-04-01 2025-03-26 4 4 gejing@gmail.com reswqa@163.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
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
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
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
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
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
RequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
12 - 2022-04-01 2023-12-15 2 2 gejing@gmail.com pfischer@wikimedia.org
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/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
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
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
suppressions.xml
in tools/maven
6 - 2022-04-01 2022-09-14 2 2 gejing@gmail.com chesnay@apache.org
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
Most Recently Changed Files (Top 47)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
ElasticsearchDynamicTableFactoryBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
270 11 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
ElasticsearchSinkBuilderBase.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
263 25 2022-04-01 2025-03-26 5 5 gejing@gmail.com reswqa@163.com
ElasticsearchWriter.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
253 20 2022-04-01 2025-03-26 5 4 gejing@gmail.com reswqa@163.com
ElasticsearchRowDataLookupFunction.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/lookup
151 4 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch8AsyncWriter.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
150 8 2023-03-25 2025-03-26 4 4 matheus.felisberto@hotmail.com reswqa@163.com
ElasticsearchDynamicSource.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
124 7 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
NetworkClientConfig.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch
120 18 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
ElasticsearchConfiguration.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table
114 18 2022-04-01 2025-03-26 3 3 gejing@gmail.com reswqa@163.com
RestClientUtils.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/utils
69 2 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch8AsyncSink.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
69 1 2023-03-25 2025-03-26 3 3 matheus.felisberto@hotmail.com reswqa@163.com
ElasticsearchSink.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
66 4 2022-04-01 2025-03-26 4 4 gejing@gmail.com reswqa@163.com
Elasticsearch6DynamicTableFactory.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table
53 5 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch7ApiCallBridge.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch
42 3 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch6ApiCallBridge.java
in flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch
41 3 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch7DynamicTableFactory.java
in flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/table
17 2 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
ElasticsearchApiCallBridge.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch
14 - 2025-03-26 2025-03-26 1 1 reswqa@163.com reswqa@163.com
Elasticsearch8AsyncSinkBuilder.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
132 15 2023-03-25 2024-05-26 3 3 matheus.felisberto@hotmail.com liuml07@apache.org
NetworkConfig.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
75 4 2023-03-25 2024-05-26 3 3 matheus.felisberto@hotmail.com liuml07@apache.org
RequestIndexer.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
12 - 2022-04-01 2023-12-15 2 2 gejing@gmail.com pfischer@wikimedia.org
BulkResponseInspector.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
20 - 2023-12-01 2023-12-01 1 1 pfischer@wikimedia.org pfischer@wikimedia.org
FailureHandler.java
in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink
8 - 2023-12-01 2023-12-01 1 1 pfischer@wikimedia.org pfischer@wikimedia.org
OperationSerializer.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
34 4 2023-03-25 2023-03-25 1 1 matheus.felisberto@hotmail.com matheus.felisberto@hotmail.com
Operation.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
22 4 2023-03-25 2023-03-25 1 1 matheus.felisberto@hotmail.com matheus.felisberto@hotmail.com
Elasticsearch8AsyncSinkSerializer.java
in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink
18 3 2023-03-25 2023-03-25 1 1 matheus.felisberto@hotmail.com matheus.felisberto@hotmail.com
suppressions.xml
in tools/maven
6 - 2022-04-01 2022-09-14 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
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
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
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
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
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/connector/elasticsearch/table
59 3 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
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
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
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
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
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/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
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
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
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