tmgodinho commented on code in PR #6387:
URL: https://github.com/apache/ignite-3/pull/6387#discussion_r2268097392
##########
migration-tools/modules/migration-tools-persistence/src/main/java/org/apache/ignite/migrationtools/persistence/Ignite2PersistentCacheTools.java:
##########
@@ -206,6 +210,24 @@ public static void migrateCache(
schema,
columnToFieldMappings,
StaticTypeConverterFactory.DEFAULT_INSTANCE))
+ .map(itemPublisher -> {
+ var p = new
BasicProcessor<DataStreamerItem<Map.Entry<Tuple, Tuple>>,
+ DataStreamerItem<Map.Entry<Tuple,
Tuple>>>() {
+ @Override
+ public void
onNext(DataStreamerItem<Entry<Tuple, Tuple>> item) {
+ subscriber.onNext(item);
+ }
+
+ @Override
+ public void onError(Throwable throwable) {
+ super.onError(new
MigrateCacheException(cacheName, tableName, throwable));
+ }
+ };
+
Review Comment:
I think it preserves context in this case.
I'll change if some human complains about it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@ignite.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
