当您需要检验作业是否可以正常运行、逻辑是否正确时,为了减少外部系统开销和避免干扰因素,可以选择使用一些调试专用的 Connector。
Blackhole 连接器是一个系统内置的调试专用结果表,主要用于高性能测试,但是不会在 Stdout 输出结果日志中打印数据。
CREATE TABLE blackhole_sink ( name String, score INT ) WITH ( 'connector' = 'blackhole' );
参数 | 是否必选 | 默认值 | 数据类型 | 描述 |
---|---|---|---|---|
connector | 是 | (none) | String | 指定使用的连接器,此处是 Blackhole 连接器。 |
以下示例表示:将 Datagen 连接器生成的随机数,选择部分数据输出,输出结果无日志打印。
CREATE TABLE datagen_source ( siteid INT, citycode SMALLINT, username STRING, pv BIGINT ) WITH ( 'connector' = 'datagen', 'rows-per-second' = '5', 'fields.username.length' = '30', 'fields.siteid.max' = '1000', 'fields.siteid.min' = '100' ); CREATE TABLE blackhole_sink ( citycode SMALLINT, username STRING, pv BIGINT ) WITH ( 'connector' = 'blackhole' ); insert into blackhole_sink select citycode, username, pv from datagen_source;