FileSytem结果表 功能描述 FileSystem结果表用于将数据输出到分布式文件系统HDFS或者 对象存储服务 OBS等文件系统。数据生成后，可直接对生成的目录创建非 DLI 表，通过DLI SQL进行下一步处理分析，并且输出数据目录支持分区表结构。适用于数据转储、大数据分析、备份或活跃归档、深度或冷归档等场景。

查看更多 →

创建结果表 BlackHole结果表 ClickHouse结果表 DWS结果表 Elasticsearch结果表 Hbase结果表 JDBC结果表 Kafka结果表 Print结果表 Redis结果表 Upsert Kafka结果表 FileSystem结果表 父主题： 数据定义语句DDL

查看更多 →

通性分别根据HBase和Kafka的地址测试队列连通性。若能连通，则表示跨源已经绑定成功，否则表示未成功。 参考 MRS HBase的使用，通过HBase shell在HBase中创建相应的表，表名为order，表中只有一个列族detail，创建语句如下： create 'order'

查看更多 →

FileSystem结果表 功能描述 FileSystem sink用于将数据输出到分布式文件系统HDFS或者对象存储服务OBS等文件系统。适用于数据转储、大数据分析、备份或活跃归档、深度或冷归档等场景。 考虑到输入流可以是无界的，每个桶中的数据被组织成有限大小的Part文件。完

查看更多 →

设置Doris的安全组，添加入向规则使其对Flink的队列网段放通。分别根据Doris的地址测试队列连通性。如果能连通，则表示跨源已经绑定成功，否则表示未成功。 参考测试地址连通性。 参考MRS Doris使用指南，创建doris表，创建语句如下： CREATE TABLE IF NOT EXISTS dorisdemo

查看更多 →

te形式。 语法 concat: [args, {get_attribute：[…]}, {get_input: […]} ] 参数说明 表1 参数说明 参数 参数说明 args 用户自定义的任意字段，支持整型，布尔型，字符串型。 例如： concat：[“string example”

查看更多 →

BlackHole结果表 功能描述 BlackHole Connector允许接收所有输入记录，常用于高性能测试和UDF 输出，其不是实质性Sink。Blackhole结果表是系统内置的Connector。 例如，如果您在注册其他类型的Connector结果表时报错，但您不确定是

查看更多 →

要创建的ClickHouse的表名。 connector.driver 否 ru.yandex.clickhouse.ClickHouseDriver String 连接数据库所需要的驱动。 如果建表时不指定该参数，驱动会自动通过ClickHouse的url提取。 如果建表时指定该参数，则该参数值固定为“ru

查看更多 →

Redis结果表 功能描述 DLI将Flink作业的输出数据输出到Redis中。Redis是一种支持Key-Value等多种数据结构的存储系统。可用于缓存、事件发布或订阅、高速队列等场景，提供字符串、哈希、列表、队列、集合结构直接存取，基于内存，可持久化。有关Redis的详细信息

查看更多 →

"xxxx", "format.type" = 'csv' ); 创建ClickHouse结果表clickhouse，将disSource表数据插入到clickhouse结果表中。 create table clickhouse( attr0 string, attr1

查看更多 →

pe，表示使用两个array字段，第一个字段为set中的值，第二个字段表示相应值所对应的score。fields-scores用于sorted-set的data-type，表示从定义的字段中获取score，该类型表示除主键外的奇数字段表示set中的值，该字段的下一个字段表示该字段

查看更多 →

pe，表示使用两个array字段，第一个字段为set中的值，第二个字段表示相应值所对应的score。fields-scores用于sorted-set的data-type，表示从定义的字段中获取score，该类型表示除主键外的奇数字段表示set中的值，该字段的下一个字段表示该字段

查看更多 →

Upsert Kafka结果表 功能描述 DLI将Flink作业的输出数据以upsert的模式输出到Kafka中。 Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统，具有高吞吐量、内置分区、支持数据副本和容错的特性，适合在大规模消息处理场景中使用。

查看更多 →

.security.protocol' = 'SASL_PLAINTEXT' 示例 从Kafka源表获取Kafka source topic数据，通过Upsert Kafka结果表将Kafka source topic数据写入到Kafka sink topic中。 参考增强型跨源

查看更多 →

Sink将以append模式工作，该模式只能消费INSERT消息。 在Elasticsearch结果表中，主键用于计算Elasticsearch的文档ID。文档ID为最多512个字节不包含空格的字符串。Elasticsearch结果表通过使用“document-id.key-delimiter”参数指定的

查看更多 →

业务结果报表 以租户管理员角色登录AICC，选择“外呼任务 > 业务结果报表” 。 外呼任务：外呼任务的名称。 报表类型：包括日报、周报、月报。 报表时间：选择需要查询的报表时间。 日报：只能查询31天的数据。 周报：选择日期（时间选择器换算成对应的周数）。 月报：选择年份和月份。

查看更多 →

connector.flush-on-checkpoint 否 checkpoint时是否会等待所有阻塞请求完成。 默认为true，表示会等待阻塞请求完成，如果配置为false，则表示不会等待阻塞请求完成。 connector.bulk-flush.max-actions 否 批量写入时的每次最大写入记录数

查看更多 →

/*in包括两个值，其中第一个值为布尔型，为true或false，当true时表示插入或更新操作，为false时表示删除操作，若对接的sink端不支持删除等操作，当为false时，可不进行任何操作。第二个值表示实际的数据值*/ public void invoke(Tuple2<Boolean

查看更多 →

获取语句执行的时间，返回值类型为timestamptz。 操作符'^' 幂运算。 幂运算。 异或。 表达式greatest、least 返回所有非null入参的比较结果。 返回所有非null入参的比较结果。 入参中存在null时，返回结果为null。 表达式case、coalesce、if、ifnull入参类型不同 报错。

查看更多 →

如果在执行运算时发现类型不匹配，会跳过本次表达式的计算。以下是一些常见的不匹配场景 表2 常见类型不匹配场景 公式 原因 "hello" * "world" * 只能用于数字之间相乘，而"hello"和"world"都是字符串。 123 && a>b && 要求两个操作数均为布尔表达式，而123是整数类型。

查看更多 →

获取语句执行的时间，返回值类型为timestamptz。 操作符'^' 幂运算 幂运算 异或 表达式greatest、least 返回所有非null入参的比较结果 返回所有非null入参的比较结果 入参中存在null时，返回结果为null。 表达式case、coalesce、if、ifnull入参类型不同 报错

查看更多 →