We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 10c01d1 commit 0d170e7Copy full SHA for 0d170e7
rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/all/AbstractRdbAllReqRow.java
@@ -32,8 +32,10 @@
32
import org.apache.commons.lang3.StringUtils;
33
import org.apache.flink.api.common.typeinfo.TypeInformation;
34
import org.apache.flink.configuration.Configuration;
35
+import org.apache.flink.table.dataformat.BaseRow;
36
import org.apache.flink.table.typeutils.TimeIndicatorTypeInfo;
37
import org.apache.flink.types.Row;
38
+import org.apache.flink.util.Collector;
39
import org.slf4j.Logger;
40
import org.slf4j.LoggerFactory;
41
0 commit comments