Skip to content

Commit c822d05

Browse files
committed
[feat-35406][docs] add http sink plugin doc
1 parent 61d8d2a commit c822d05

File tree

2 files changed

+67
-0
lines changed

2 files changed

+67
-0
lines changed

Diff for: docs/plugin/httpSink.md

+66
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,66 @@
1+
## 1.格式:
2+
```
3+
CREATE TABLE tableName(
4+
colName colType,
5+
...
6+
colNameX colType
7+
)WITH(
8+
type ='http',
9+
url ='http://xxx:8080/test/returnAll'
10+
,flag ='aa'
11+
,delay = '10'
12+
);
13+
14+
```
15+
16+
17+
## 3.表结构定义
18+
19+
|参数名称|含义|
20+
|----|---|
21+
| tableName| http表名称|
22+
| colName | 列名称|
23+
| colType | 列类型 [colType支持的类型](../colType.md)|
24+
25+
## 4.参数:
26+
27+
|参数名称|含义|是否必填|默认值|
28+
|----|----|----|----|
29+
|http |结果表插件类型,必须为http|||
30+
|url | 地址 |||
31+
|flag | 结果返回标识符|||
32+
|delay |每条结果数据之间延时时间 ||默认20毫秒|
33+
34+
35+
## 5.样例:
36+
37+
```
38+
39+
-- {"name":"maqi","id":1001}
40+
CREATE TABLE sourceIn (
41+
id int,
42+
name VARCHAR
43+
)WITH(
44+
type = 'kafka',
45+
bootstrapServers = 'localhost:9092',
46+
topic ='test1'
47+
);
48+
49+
CREATE TABLE sinkOut (
50+
id int
51+
, name varchar
52+
) WITH (
53+
type ='http',
54+
url ='http://xxx:8080/test/returnAll'
55+
,flag ='aa'
56+
,delay = '10'
57+
);
58+
59+
insert into sinkOut select id,name from sourceIn;
60+
61+
```
62+
63+
发送数据:{"name":"maqi","id":1001}
64+
</br>结果数据:
65+
</br>1.flag不填或者为空串:{"name":"maqi","id":1001}
66+
</br>2.flag有内容:{"flag":"11111111","name":"maqi","id":1001,"tableName":"sinkOut"}

Diff for: docs/pluginsInfo.md

+1
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
* [impala 结果表插件](plugin/impalaSink.md)
1818
* [db2 结果表插件](plugin/db2Sink.md)
1919
* [sqlserver 结果表插件](plugin/sqlserverSink.md)
20+
* [http 结果表插件](plugin/httpSink.md)
2021

2122
#### 1.3 维表插件
2223
* [hbase 维表插件](plugin/hbaseSide.md)

0 commit comments

Comments
 (0)