我正在使用 Kafka Streams 对 kafka 主题进行分组和减少。
如果针对给定键的所有值,键和值都相等,我想为该键生成一个输出;否则,不要为该键输出任何内容。
然而,要做到这一点,我需要访问key
,并且.reduce
方法只允许访问聚合/当前值。
调用 .reduce 时可以获取密钥吗?或者还有其他方法吗?
我正在使用 Kafka Streams 对 kafka 主题进行分组和减少。
如果针对给定键的所有值,键和值都相等,我想为该键生成一个输出;否则,不要为该键输出任何内容。
然而,要做到这一点,我需要访问key
,并且.reduce
方法只允许访问聚合/当前值。
调用 .reduce 时可以获取密钥吗?或者还有其他方法吗?
我正在使用官方的 Oracle 23 Docker 镜像。我有大量的测试数据需要运行到数据库中,以便开发人员可以使用该图像。
我知道我可以将 .sql 脚本放入/docker-entrypoint-initdb.d/startup
图像上,它们将通过 SQL Plus 自动在图像上运行。
问题是,我不想看到:
db_1 | 1 row created.
db_1 |
db_1 |
db_1 | 1 row created.
db_1 |
db_1 |
db_1 | 1 row created.
db_1 |
db_1 |
db_1 | 1 row created.
db_1 |
db_1 |
db_1 | 1 row created.
db_1 |
db_1 |
db_1 | 1 row created.
db_1 |
db_1 |
(etc...)
db_1 | Commit complete.
在我的控制台输出中。我宁愿只看到类似的东西:
db_1 | 10,000 rows created.
db_1 |
db_1 |
db_1 | Commit complete.
或者甚至以 100 个为一组进行批量处理,也会大大减少产量。
这可能吗?
我尝试过使用INSERT ALL...
,但这仍然单独打印每个插入。
如果可能的话,最终的脚本应该向后兼容 19c。