Skip to content

Commit 3969e90

Browse files
committed
[Feature][connector-elasticsearch] elasticsearch source support PIT
1 parent 1bb296f commit 3969e90

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

Diff for: seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/config/ElasticsearchSourceOptions.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,8 @@ public class ElasticsearchSourceOptions extends ElasticsearchBaseOptions {
7272
Options.key("search_api_type")
7373
.enumType(SearchApiTypeEnum.class)
7474
.defaultValue(SearchApiTypeEnum.SCROLL)
75-
.withDescription("Choose API type for pagination: SCROLL or PIT (Point in Time).");
75+
.withDescription(
76+
"Choose API type for pagination: SCROLL or PIT (Point in Time).");
7677

7778
public static final Option<String> SQL_QUERY =
7879
Options.key("sql_query")

Diff for: seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source/ElasticsearchSource.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717

1818
package org.apache.seatunnel.connectors.seatunnel.elasticsearch.source;
1919

20-
import org.apache.seatunnel.connectors.seatunnel.elasticsearch.config.SearchApiTypeEnum;
2120
import org.apache.seatunnel.shade.com.google.common.annotations.VisibleForTesting;
2221

2322
import org.apache.seatunnel.api.configuration.ReadonlyConfig;
@@ -42,6 +41,7 @@
4241
import org.apache.seatunnel.connectors.seatunnel.elasticsearch.client.EsType;
4342
import org.apache.seatunnel.connectors.seatunnel.elasticsearch.config.ElasticsearchConfig;
4443
import org.apache.seatunnel.connectors.seatunnel.elasticsearch.config.ElasticsearchSourceOptions;
44+
import org.apache.seatunnel.connectors.seatunnel.elasticsearch.config.SearchApiTypeEnum;
4545
import org.apache.seatunnel.connectors.seatunnel.elasticsearch.config.SearchTypeEnum;
4646
import org.apache.seatunnel.connectors.seatunnel.elasticsearch.exception.ElasticsearchConnectorErrorCode;
4747
import org.apache.seatunnel.connectors.seatunnel.elasticsearch.exception.ElasticsearchConnectorException;

0 commit comments

Comments
 (0)