java - 使用 DataStream 的 addData 点燃事务。可能的？

Question

我们想要将批量数据加载到ignite缓存中，因此我们使用了data Streamer(stmr.addData)而不是cache.put(相对较慢)。现在想要在我的批量加载操作上应用事务。这发生在我的数据流处理案例中，同时使用cache.put操作。

我的代码:

CacheConfiguration<String, Person> cacheConfiguration = new 
CacheConfiguration<>("PersonCache");
cacheConfiguration.setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL);
IgniteTransactions transactions = ignite.transactions();
Transaction tx = transactions.txStart();
while (resultSet.next()) {
Persion person = new Persion();
persion.setName(name);
persion.setAge(age);
dataStreamer.addData(personKey, person);
}
tx.commit();

//while cache.put(personKey, person) is giving me transnational output 

Answer 1

我认为不可能让 DataStreamer 以这种方式使用事务。 DataStreamer 的重点是批量发送数据，而不是逐个条目发送数据。

为什么您希望此操作是事务性的？我认为 StreamReceiver 或 allowOverwrite 更适合您的需求。