腾讯音乐娱乐拥有海量的内容曲库，包括录制音乐、现场音乐、音频和视频等多种形式。通 过技术和数据的赋能，腾讯音乐娱乐持续创新产品，为用户带来更好的产品体验，提高用户 参与度，也为音乐人和合作伙伴在音乐的制作、发行和销售方面提供更大的支持。 在业务运营过程中我们需要对包括歌曲、词曲、专辑、艺人在内的内容对象进行全方位分析， 高效为业务赋能，内容库数据平台旨在集成各数据源的数据，整合形成内容数据资产（以指 标 修改，这与我们的需求十分匹配，后续我们也会及时升级到最新版本。 写入优化 接着我们在数据写入方面也进行了调整优化，这里几点小经验与大家分享：  Flink 预聚合：通过主键 ID 预聚合，减少写入压力。（前文已说明，此处不再赘述）  写入 Batch 大小自适应变更：为了不占用过多 Flink 资源，我们实现了从同一个 Kafka Topic 中消费数据写入到不同 Doris 表中的功能，并且可以根据数据的大小

的结果是true。 语法： 数据类型：通常expression的计算结果都是数字类型，该操作符也支持其他数据类型。如果必须要确保下界和上界都是可比较 的字符，可以使用cast()函数。 使用说明：如果操作数是string类型时使用时，应该小心些。起始部分为上界的长字符串将不会匹配上界，该字符串比上界要 大。between 'A' and 'M'不会匹配‘MJ’。如果需要确保表达式能够正常 Keywords 最佳实践 最佳实践 1. 关于指定消费的 Partition 和 Offset Doris 支持指定 Partition 和 Offset 开始消费，还支持了指定时间点进行消费的功能。这里说明下对应参数的配置关系。 有三个相关参数： ：指定待消费的 partition 列表，如："0, 1, 2, 3"。 ：指定每个分区的起始offset，必须和 列表个数对应。如："1000, 2GB 之间。超过这个大小的文件将会被切 分。 ：成功后是否产生一个空文件标识。文件名为 "my_file_file_name"。其中 是在 中指定的前缀， 为该参数的值。 返回结果说明： 如果正常导出并返回，则结果如下： ：最终生成的文件个数。 ：结果集行数。 file_path file_path bos://my_bucket/my_file_