|
21 | 21 |
|
22 | 22 | import com.dtstack.flink.sql.enums.ECacheContentType; |
23 | 23 | import com.dtstack.flink.sql.side.BaseAsyncReqRow; |
24 | | -import com.dtstack.flink.sql.side.CacheMissVal; |
25 | 24 | import com.dtstack.flink.sql.side.BaseSideInfo; |
| 25 | +import com.dtstack.flink.sql.side.CacheMissVal; |
26 | 26 | import com.dtstack.flink.sql.side.cache.CacheObj; |
27 | 27 | import com.dtstack.flink.sql.side.rdb.util.SwitchUtil; |
28 | | -import io.vertx.core.json.Json; |
| 28 | +import com.google.common.collect.Lists; |
29 | 29 | import io.vertx.core.json.JsonArray; |
30 | 30 | import io.vertx.ext.sql.SQLClient; |
31 | 31 | import io.vertx.ext.sql.SQLConnection; |
32 | | -import com.google.common.collect.Lists; |
33 | 32 | import org.apache.calcite.sql.JoinType; |
34 | | -import org.apache.commons.lang.exception.ExceptionUtils; |
35 | 33 | import org.apache.commons.lang3.StringUtils; |
36 | 34 | import org.apache.flink.streaming.api.functions.async.ResultFuture; |
37 | 35 | import org.apache.flink.table.runtime.types.CRow; |
38 | 36 | import org.apache.flink.table.typeutils.TimeIndicatorTypeInfo; |
39 | 37 | import org.apache.flink.types.Row; |
40 | 38 | import org.slf4j.Logger; |
41 | 39 | import org.slf4j.LoggerFactory; |
42 | | -import scala.Int; |
43 | 40 |
|
44 | 41 | import java.sql.Timestamp; |
45 | | -import java.util.Collection; |
46 | 42 | import java.util.List; |
47 | 43 | import java.util.Map; |
48 | 44 | import java.util.concurrent.CountDownLatch; |
49 | | -import java.util.concurrent.ExecutionException; |
50 | | -import java.util.concurrent.Future; |
51 | 45 | import java.util.concurrent.ScheduledFuture; |
52 | 46 | import java.util.concurrent.atomic.AtomicBoolean; |
53 | | -import java.util.concurrent.atomic.AtomicInteger; |
54 | 47 | import java.util.concurrent.atomic.AtomicLong; |
55 | | -import java.util.concurrent.atomic.AtomicReference; |
56 | 48 |
|
57 | 49 | /** |
58 | 50 | * Date: 2018/11/26 |
|
0 commit comments