使用 VoltDB 中的 Kafka 导出连接器获取要导出的现有行

Getting existing rows to export using Kafka Export Connector in VoltDB

我正在研究一个解决方案,以便在两个 VoltDB 实例之间从旧模式迁移到新模式。我正在查看 The Kafka Export Connector 和 Kafka Import,编写过程以将数据从旧模式转换为新模式的能力正是我所需要的。唯一的问题是我有这个 - 每当在 VoltDB 分区内的导出 table 上执行 SQL INSERT 时,就会生成导出数据。如何让旧模式中的所有现有行开始导出?

您可以使用 INSERT INTO stream_name ... SELECT ... FROM table_name 来移动数据。有关此形式的 INSERT 的详细信息,请参阅 docs

披露:我为 VoltDB 工作。