subject:"\[GitHub\] \[flink\-table\-store\] zjureel commented on a diff in pull request #418\: \[FLINK\-30273\] Introduce RecordReaderUtils.transform to transform RecordReader"

[GitHub] [flink-table-store] zjureel commented on a diff in pull request #418: [FLINK-30273] Introduce RecordReaderUtils.transform to transform RecordReader

2022-12-04 Thread GitBox

zjureel commented on code in PR #418: URL: https://github.com/apache/flink-table-store/pull/418#discussion_r1038979729 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/RecordReaderUtils.java: ## @@ -44,4 +45,49 @@ public static void

[GitHub] [flink-table-store] zjureel commented on a diff in pull request #418: [FLINK-30273] Introduce RecordReaderUtils.transform to transform RecordReader

2022-12-04 Thread GitBox

zjureel commented on code in PR #418: URL: https://github.com/apache/flink-table-store/pull/418#discussion_r1038979666 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/RecordReaderUtils.java: ## @@ -44,4 +45,49 @@ public static void