Skip to content

Commit 7a57f79

Browse files
dengdejiushinidengdejiushini
committed
修改包名、类名，解决找不到类的问题
1 parent dc7134e commit 7a57f79

File tree

7 files changed

+13
-13
lines changed

7 files changed

+13
-13
lines changed

elasticsearch6/elasticsearch6-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch6/CustomerSinkFunc.java renamed to elasticsearch6/elasticsearch6-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/CustomerSinkFunc.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
* limitations under the License.
1717
*/
1818

19-
package com.dtstack.flink.sql.sink.elasticsearch6;
19+
package com.dtstack.flink.sql.sink.elasticsearch;
2020

2121
import org.apache.flink.api.common.functions.RuntimeContext;
2222
import org.apache.flink.api.java.tuple.Tuple2;

elasticsearch6/elasticsearch6-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch6/Elasticsearch6Sink.java renamed to elasticsearch6/elasticsearch6-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/ElasticsearchSink.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
* limitations under the License.
1717
*/
1818

19-
package com.dtstack.flink.sql.sink.elasticsearch6;
19+
package com.dtstack.flink.sql.sink.elasticsearch;
2020

2121
import org.apache.flink.api.common.typeinfo.TypeInformation;
2222
import org.apache.flink.api.java.tuple.Tuple2;
@@ -30,7 +30,7 @@
3030
import org.apache.flink.types.Row;
3131

3232
import com.dtstack.flink.sql.sink.IStreamSinkGener;
33-
import com.dtstack.flink.sql.sink.elasticsearch6.table.ElasticsearchTableInfo;
33+
import com.dtstack.flink.sql.sink.elasticsearch.table.ElasticsearchTableInfo;
3434
import com.dtstack.flink.sql.table.TargetTableInfo;
3535
import com.google.common.collect.Maps;
3636
import org.apache.commons.lang.StringUtils;
@@ -47,9 +47,9 @@
4747
* @author yinxi
4848
* @date 2020/1/9 - 15:08
4949
*/
50-
public class Elasticsearch6Sink implements RetractStreamTableSink<Row>, IStreamSinkGener<Elasticsearch6Sink> {
50+
public class ElasticsearchSink implements RetractStreamTableSink<Row>, IStreamSinkGener<ElasticsearchSink> {
5151

52-
private final Logger logger = LoggerFactory.getLogger(Elasticsearch6Sink.class);
52+
private final Logger logger = LoggerFactory.getLogger(ElasticsearchSink.class);
5353

5454
private String clusterName;
5555

@@ -150,7 +150,7 @@ public void setBulkFlushMaxActions(int bulkFlushMaxActions) {
150150
}
151151

152152
@Override
153-
public Elasticsearch6Sink genStreamSink(TargetTableInfo targetTableInfo) {
153+
public ElasticsearchSink genStreamSink(TargetTableInfo targetTableInfo) {
154154
ElasticsearchTableInfo elasticsearchTableInfo = (ElasticsearchTableInfo) targetTableInfo;
155155
esTableInfo = elasticsearchTableInfo;
156156
clusterName = elasticsearchTableInfo.getClusterName();

elasticsearch6/elasticsearch6-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch6/Es6Util.java renamed to elasticsearch6/elasticsearch6-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/Es6Util.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
* limitations under the License.
1717
*/
1818

19-
package com.dtstack.flink.sql.sink.elasticsearch6;
19+
package com.dtstack.flink.sql.sink.elasticsearch;
2020

2121
import org.apache.flink.types.Row;
2222
import org.apache.flink.util.Preconditions;

elasticsearch6/elasticsearch6-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch6/ExtendEs6ApiCallBridge.java renamed to elasticsearch6/elasticsearch6-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/ExtendEs6ApiCallBridge.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,13 +16,13 @@
1616
* limitations under the License.
1717
*/
1818

19-
package com.dtstack.flink.sql.sink.elasticsearch6;
19+
package com.dtstack.flink.sql.sink.elasticsearch;
2020

2121
import org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchApiCallBridge;
2222
import org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase;
2323
import org.apache.flink.util.Preconditions;
2424

25-
import com.dtstack.flink.sql.sink.elasticsearch6.table.ElasticsearchTableInfo;
25+
import com.dtstack.flink.sql.sink.elasticsearch.table.ElasticsearchTableInfo;
2626
import org.apache.http.HttpHost;
2727
import org.apache.http.auth.AuthScope;
2828
import org.apache.http.auth.UsernamePasswordCredentials;

elasticsearch6/elasticsearch6-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch6/MetricElasticsearch6Sink.java renamed to elasticsearch6/elasticsearch6-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/MetricElasticsearch6Sink.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
* limitations under the License.
1717
*/
1818

19-
package com.dtstack.flink.sql.sink.elasticsearch6;
19+
package com.dtstack.flink.sql.sink.elasticsearch;
2020

2121
import org.apache.flink.configuration.Configuration;
2222
import org.apache.flink.metrics.Counter;
@@ -27,7 +27,7 @@
2727
import org.apache.flink.streaming.connectors.elasticsearch.util.NoOpFailureHandler;
2828

2929
import com.dtstack.flink.sql.metric.MetricConstant;
30-
import com.dtstack.flink.sql.sink.elasticsearch6.table.ElasticsearchTableInfo;
30+
import com.dtstack.flink.sql.sink.elasticsearch.table.ElasticsearchTableInfo;
3131
import org.elasticsearch.client.RestHighLevelClient;
3232

3333
import java.util.List;

elasticsearch6/elasticsearch6-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch6/table/ElasticsearchSinkParser.java renamed to elasticsearch6/elasticsearch6-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/table/ElasticsearchSinkParser.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
* limitations under the License.
1717
*/
1818

19-
package com.dtstack.flink.sql.sink.elasticsearch6.table;
19+
package com.dtstack.flink.sql.sink.elasticsearch.table;
2020

2121
import com.dtstack.flink.sql.table.AbsTableParser;
2222
import com.dtstack.flink.sql.table.TableInfo;

elasticsearch6/elasticsearch6-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch6/table/ElasticsearchTableInfo.java renamed to elasticsearch6/elasticsearch6-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/table/ElasticsearchTableInfo.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
* limitations under the License.
1717
*/
1818

19-
package com.dtstack.flink.sql.sink.elasticsearch6.table;
19+
package com.dtstack.flink.sql.sink.elasticsearch.table;
2020

2121
import com.dtstack.flink.sql.table.TargetTableInfo;
2222
import com.google.common.base.Preconditions;

0 commit comments

Comments
 (0)