用于支持从 Flume 中读取流数据。

<source type="flume"
        table_name="cust_id_agmt_id_t"
        duration="10"
        fields="test_id,test_name"
        data_type="STRING"
        delimiter=","
        host="localhost" port="8090" />

说明：

1. Data_type: STRING 固定分隔符的字符串，按照 delimiter 切分；JSON 则结果集为JSON类型，从JSON 中获得字段；
2. Host 和 port 分别为 Flume 的服务ip 和端口号；