File tree Expand file tree Collapse file tree 1 file changed +4
-5
lines changed
rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/all Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change 29
29
import org .apache .calcite .sql .JoinType ;
30
30
import org .apache .commons .collections .CollectionUtils ;
31
31
import org .apache .commons .lang3 .StringUtils ;
32
- import org .apache .flink .api .common .typeinfo .TypeInformation ;
33
32
import org .apache .flink .configuration .Configuration ;
34
33
import org .apache .flink .table .dataformat .BaseRow ;
35
- import org .apache .flink .table .typeutils .TimeIndicatorTypeInfo ;
36
34
import org .apache .flink .types .Row ;
37
35
import org .apache .flink .util .Collector ;
38
36
import org .slf4j .Logger ;
39
37
import org .slf4j .LoggerFactory ;
40
38
41
- import java .sql .*;
42
- import java .time .LocalDateTime ;
39
+ import java .sql .Connection ;
40
+ import java .sql .ResultSet ;
41
+ import java .sql .SQLException ;
42
+ import java .sql .Statement ;
43
43
import java .util .ArrayList ;
44
44
import java .util .Calendar ;
45
- import java .util .HashMap ;
46
45
import java .util .List ;
47
46
import java .util .Map ;
48
47
import java .util .Objects ;
You can’t perform that action at this time.
0 commit comments