BOS
更新时间:2021-06-24
BOS DDL
CREATE TABLE bos_table (
`field01` STRING,
`field02` BIGINT,
`field03` FLOAT,
`field04` BINARY,
`field05` INT,
`field06` TINYINT,
`field07` BOOLEAN,
`field08` DATA,
`field09` DOUBLE,
`field10` SMALLINT
) WITH (
'connector.type' = 'BOS',
'format.encode' = 'JSON',
'connector.emit' = 'BATCH',
'connector.path' = 'bos://asc-sandbox-su/bos-source/json/'
);
BOS 参数设置
名称 | 简称 | 是否必填 | 用例 | SPARK | FLINK | 说明 |
---|---|---|---|---|---|---|
connector.type | type | Y | BOS |
Y | Y | 服务类型 |
format.encode | encode | Y | JSON / CSV |
Y | Y | 数据编码 |
connector.scan | scan | STREAM / STATIC , 默认 STREAM |
Y | Y | 数据读取形式,仅用于STREAM类型的作业中,流表join时生效 | |
connector.path | path | Y | bos://bsc-sandbox/bos-source/json/ |
Y | Y | 输入/输出文件在BOS上的路径 |