Skip to content

Commit 37d2588

Browse files
author
dapeng
committed
fix conflict
1 parent 631bffe commit 37d2588

2 files changed

Lines changed: 3 additions & 15 deletions

File tree

hbase/hbase-side/hbase-all-side/src/main/java/com/dtstack/flink/sql/side/hbase/HbaseAllReqRow.java

Lines changed: 3 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -25,34 +25,26 @@
2525
import com.dtstack.flink.sql.side.FieldInfo;
2626
import com.dtstack.flink.sql.side.JoinInfo;
2727
import com.dtstack.flink.sql.side.hbase.table.HbaseSideTableInfo;
28-
import com.dtstack.flink.sql.side.hbase.utils.HbaseUtils;
2928
import com.dtstack.flink.sql.side.hbase.utils.HbaseConfigUtils;
29+
import com.dtstack.flink.sql.side.hbase.utils.HbaseUtils;
30+
import com.google.common.collect.Maps;
3031
import org.apache.calcite.sql.JoinType;
3132
import org.apache.commons.collections.map.HashedMap;
32-
import org.apache.commons.lang.StringUtils;
3333
import org.apache.flink.api.java.typeutils.RowTypeInfo;
34-
import com.google.common.collect.Maps;
3534
import org.apache.flink.table.runtime.types.CRow;
3635
import org.apache.flink.table.typeutils.TimeIndicatorTypeInfo;
3736
import org.apache.flink.types.Row;
3837
import org.apache.flink.util.Collector;
3938
import org.apache.hadoop.conf.Configuration;
4039
import org.apache.hadoop.hbase.Cell;
4140
import org.apache.hadoop.hbase.CellUtil;
42-
import org.apache.hadoop.hbase.HBaseConfiguration;
4341
import org.apache.hadoop.hbase.TableName;
44-
import org.apache.hadoop.hbase.client.Connection;
45-
import org.apache.hadoop.hbase.client.ConnectionFactory;
46-
import org.apache.hadoop.hbase.client.Result;
47-
import org.apache.hadoop.hbase.client.ResultScanner;
48-
import org.apache.hadoop.hbase.client.Scan;
49-
import org.apache.hadoop.hbase.client.Table;
42+
import org.apache.hadoop.hbase.client.*;
5043
import org.apache.hadoop.hbase.util.Bytes;
5144
import org.apache.hadoop.security.UserGroupInformation;
5245
import org.slf4j.Logger;
5346
import org.slf4j.LoggerFactory;
5447

55-
import java.io.File;
5648
import java.io.IOException;
5749
import java.security.PrivilegedAction;
5850
import java.sql.SQLException;

hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/HbaseOutputFormat.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020

2121
package com.dtstack.flink.sql.sink.hbase;
2222

23-
import com.dtstack.flink.sql.enums.EUpdateMode;
2423
import com.dtstack.flink.sql.outputformat.AbstractDtRichOutputFormat;
2524
import com.google.common.collect.Maps;
2625
import org.apache.commons.lang3.StringUtils;
@@ -31,18 +30,15 @@
3130
import org.apache.hadoop.hbase.*;
3231
import org.apache.hadoop.hbase.client.Connection;
3332
import org.apache.hadoop.hbase.client.ConnectionFactory;
34-
import org.apache.hadoop.hbase.client.Delete;
3533
import org.apache.hadoop.hbase.client.Put;
3634
import org.apache.hadoop.hbase.client.Table;
37-
import org.apache.hadoop.hbase.util.Bytes;
3835
import org.apache.hadoop.security.UserGroupInformation;
3936
import org.slf4j.Logger;
4037
import org.slf4j.LoggerFactory;
4138

4239
import java.io.File;
4340
import java.io.IOException;
4441
import java.security.PrivilegedAction;
45-
import java.util.List;
4642
import java.util.Map;
4743
import java.util.Set;
4844

0 commit comments

Comments
 (0)