File tree 3 files changed +14
-15
lines changed
core/src/main/java/com/dtstack/flink/sql/util
3 files changed +14
-15
lines changed Original file line number Diff line number Diff line change @@ -139,9 +139,9 @@ sh submit.sh -sql D:\sideSql.txt -name xctest -remoteSqlPluginPath /opt/dtstack
139
139
140
140
```
141
141
CREATE TABLE MyTable(
142
- name string ,
143
- channel STRING ,
144
- pv INT ,
142
+ name varchar ,
143
+ channel varchar ,
144
+ pv int ,
145
145
xctime bigint,
146
146
CHARACTER_LENGTH(channel) AS timeLeng
147
147
)WITH(
@@ -154,8 +154,8 @@ CREATE TABLE MyTable(
154
154
);
155
155
156
156
CREATE TABLE MyResult(
157
- channel VARCHAR ,
158
- pv VARCHAR
157
+ channel varchar ,
158
+ pv varchar
159
159
)WITH(
160
160
type ='mysql',
161
161
url ='jdbc:mysql://172.16.8.104:3306/test?charset=utf8',
@@ -166,8 +166,8 @@ CREATE TABLE MyResult(
166
166
);
167
167
168
168
CREATE TABLE workerinfo(
169
- cast(logtime as TIMESTAMP)AS rtime,
170
- cast(logtime)AS rtime
169
+ cast(logtime as TIMESTAMP) AS rtime,
170
+ cast(logtime) AS rtime
171
171
)WITH(
172
172
type ='hbase',
173
173
zookeeperQuorum ='rdos1:2181',
@@ -178,8 +178,8 @@ CREATE TABLE workerinfo(
178
178
);
179
179
180
180
CREATE TABLE sideTable(
181
- cf:name String as name,
182
- cf:info String as info,
181
+ cf:name varchar as name,
182
+ cf:info varchar as info,
183
183
PRIMARY KEY(name),
184
184
PERIOD FOR SYSTEM_TIME
185
185
)WITH(
Original file line number Diff line number Diff line change @@ -66,7 +66,7 @@ public static Class<?> stringConvertClass(String str) {
66
66
case "timestamp" :
67
67
return Timestamp .class ;
68
68
69
- case "DECIMAL " :
69
+ case "decimal " :
70
70
return BigDecimal .class ;
71
71
72
72
}
Original file line number Diff line number Diff line change 2
2
| ------ | ----- |
3
3
| boolean | Boolean |
4
4
| int | Integer |
5
+ | integer| Integer |
5
6
| bigint | Long |
6
7
| tinyint | Byte |
7
- | byte | Byte |
8
- | short | Short |
9
8
| smallint | Short|
10
- | char | String|
11
9
| varchar | String |
12
- | string | String |
10
+ | real | Float |
13
11
| float | Float|
14
12
| double | Double|
15
13
| date | Date |
16
- | timestamp | Timestamp |
14
+ | timestamp | Timestamp |
15
+ | decimal | BigDecimal|
You can’t perform that action at this time.
0 commit comments