Skip to content

Commit 300b470

Browse files
committed
remove useless import
1 parent e408d12 commit 300b470

File tree

1 file changed

+0
-5
lines changed
  • cassandra/cassandra-side/cassandra-all-side/src/main/java/com/dtstack/flink/sql/side/cassandra

1 file changed

+0
-5
lines changed

cassandra/cassandra-side/cassandra-all-side/src/main/java/com/dtstack/flink/sql/side/cassandra/CassandraAllReqRow.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,6 @@
1919
package com.dtstack.flink.sql.side.cassandra;
2020

2121
import org.apache.flink.api.java.typeutils.RowTypeInfo;
22-
import org.apache.flink.table.runtime.types.CRow;
23-
import org.apache.flink.table.typeutils.TimeIndicatorTypeInfo;
2422
import org.apache.flink.types.Row;
2523
import org.apache.flink.util.Collector;
2624

@@ -45,10 +43,7 @@
4543
import org.apache.calcite.sql.JoinType;
4644
import org.apache.commons.collections.CollectionUtils;
4745
import org.apache.commons.lang3.StringUtils;
48-
import org.apache.flink.api.java.typeutils.RowTypeInfo;
4946
import org.apache.flink.table.dataformat.BaseRow;
50-
import org.apache.flink.types.Row;
51-
import org.apache.flink.util.Collector;
5247
import org.slf4j.Logger;
5348
import org.slf4j.LoggerFactory;
5449

0 commit comments

Comments
 (0)