数据现在只支持json格式 {"xx":"bb","cc":"dd"}
CREATE TABLE MyTable(
channel varchar,
pv int,
xctime date,
xtime date
)WITH(
type='serversocket',
host='127.0.0.1',
port='8888',
delimiter=';',
maxNumRetries='100'
);
| 参数名称 | 含义 | 是否必填 | 默认值 |
|---|---|---|---|
| type | serversocket | 是 | |
| host | server host | 是 | |
| port | server port | 是 | |
| delimiter | 每条json数据的分割符(比如：;) | 是 | |
| maxNumRetries | 最大重连次数 (大于0) | 是 |
String JsonStr = "{\"CHANNEL\":\"xc3\",\"pv\":1234567,\"xdate\":\"2018-12-07\",\"xtime\":\"2018-12-15\"};";