You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ki...@apache.org on 2022/08/16 02:23:13 UTC
[incubator-seatunnel] branch dev updated: [Improve][Connector-V2] Make the attribute of http-connector from private to protected (#2418)
This is an automated email from the ASF dual-hosted git repository.
kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new f3b00ef69 [Improve][Connector-V2] Make the attribute of http-connector from private to protected (#2418)
f3b00ef69 is described below
commit f3b00ef6965da8116d325cb27772c5494c4358d2
Author: TyrantLucifer <Ty...@gmail.com>
AuthorDate: Tue Aug 16 10:23:08 2022 +0800
[Improve][Connector-V2] Make the attribute of http-connector from private to protected (#2418)
---
.../apache/seatunnel/connectors/seatunnel/http/sink/HttpSink.java | 6 +++---
.../seatunnel/connectors/seatunnel/http/sink/HttpSinkWriter.java | 6 +++---
.../seatunnel/connectors/seatunnel/http/source/HttpSource.java | 6 +++---
.../connectors/seatunnel/http/source/HttpSourceReader.java | 7 +++----
4 files changed, 12 insertions(+), 13 deletions(-)
diff --git a/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSink.java b/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSink.java
index 8466b8b2a..10bbe46a6 100644
--- a/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSink.java
+++ b/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSink.java
@@ -41,9 +41,9 @@ import java.util.stream.Collectors;
@AutoService(SeaTunnelSink.class)
public class HttpSink extends AbstractSimpleSink<SeaTunnelRow, Void> {
- private final HttpParameter httpParameter = new HttpParameter();
- private SeaTunnelRowType seaTunnelRowType;
- private Config pluginConfig;
+ protected final HttpParameter httpParameter = new HttpParameter();
+ protected SeaTunnelRowType seaTunnelRowType;
+ protected Config pluginConfig;
@Override
public String getPluginName() {
diff --git a/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSinkWriter.java b/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSinkWriter.java
index dfbc6576a..de02bcd9d 100644
--- a/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSinkWriter.java
+++ b/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/sink/HttpSinkWriter.java
@@ -34,9 +34,9 @@ import java.util.Objects;
public class HttpSinkWriter extends AbstractSinkWriter<SeaTunnelRow, Void> {
private static final Logger LOGGER = LoggerFactory.getLogger(HttpSinkWriter.class);
- private final HttpClientProvider httpClient = HttpClientProvider.getInstance();
- private final SeaTunnelRowType seaTunnelRowType;
- private final HttpParameter httpParameter;
+ protected final HttpClientProvider httpClient = HttpClientProvider.getInstance();
+ protected final SeaTunnelRowType seaTunnelRowType;
+ protected final HttpParameter httpParameter;
public HttpSinkWriter(SeaTunnelRowType seaTunnelRowType, HttpParameter httpParameter) {
this.seaTunnelRowType = seaTunnelRowType;
diff --git a/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSource.java b/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSource.java
index cf09193ae..91d986a34 100644
--- a/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSource.java
+++ b/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSource.java
@@ -41,9 +41,9 @@ import com.google.auto.service.AutoService;
@AutoService(SeaTunnelSource.class)
public class HttpSource extends AbstractSingleSplitSource<SeaTunnelRow> {
- private final HttpParameter httpParameter = new HttpParameter();
- private SeaTunnelRowType rowType;
- private SeaTunnelContext seaTunnelContext;
+ protected final HttpParameter httpParameter = new HttpParameter();
+ protected SeaTunnelRowType rowType;
+ protected SeaTunnelContext seaTunnelContext;
@Override
public String getPluginName() {
diff --git a/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSourceReader.java b/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSourceReader.java
index 12b687791..70d38fcca 100644
--- a/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSourceReader.java
+++ b/seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSourceReader.java
@@ -33,11 +33,10 @@ import java.io.IOException;
import java.util.Objects;
public class HttpSourceReader extends AbstractSingleSplitReader<SeaTunnelRow> {
-
private static final Logger LOGGER = LoggerFactory.getLogger(HttpSourceReader.class);
- private final SingleSplitReaderContext context;
- private final HttpParameter httpParameter;
- private HttpClientProvider httpClient;
+ protected final SingleSplitReaderContext context;
+ protected final HttpParameter httpParameter;
+ protected HttpClientProvider httpClient;
public HttpSourceReader(HttpParameter httpParameter, SingleSplitReaderContext context) {
this.context = context;