You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by yu...@apache.org on 2022/10/06 13:07:58 UTC
[hudi] 02/07: [MINOR] Fix type casting in TestHoodieHFileReaderWriter
This is an automated email from the ASF dual-hosted git repository.
yuzhaojing pushed a commit to branch release-feature-rfc46
in repository https://gitbox.apache.org/repos/asf/hudi.git
commit e7e0830cf6a1f18eb2b6fff7b436b3f0f85df218
Author: Raymond Xu <xu...@gmail.com>
AuthorDate: Wed Jun 15 14:38:31 2022 +0800
[MINOR] Fix type casting in TestHoodieHFileReaderWriter
---
.../java/org/apache/hudi/io/storage/TestHoodieHFileReaderWriter.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/io/storage/TestHoodieHFileReaderWriter.java b/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/io/storage/TestHoodieHFileReaderWriter.java
index 6fb80c2d85..89e3a7738a 100644
--- a/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/io/storage/TestHoodieHFileReaderWriter.java
+++ b/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/io/storage/TestHoodieHFileReaderWriter.java
@@ -308,6 +308,7 @@ public class TestHoodieHFileReaderWriter extends TestHoodieReaderWriterBase {
hfileReader.getRecordsByKeyPrefixIterator(Arrays.asList("key50", "key1"), avroSchema);
recordsByPrefix =
StreamSupport.stream(Spliterators.spliteratorUnknownSize(iterator, Spliterator.ORDERED), false)
+ .map(r -> (GenericRecord)r)
.collect(Collectors.toList());
assertEquals(expectedKey50and1s, recordsByPrefix);
@@ -318,6 +319,7 @@ public class TestHoodieHFileReaderWriter extends TestHoodieReaderWriterBase {
hfileReader.getRecordsByKeyPrefixIterator(Arrays.asList("key50", "key0"), avroSchema);
recordsByPrefix =
StreamSupport.stream(Spliterators.spliteratorUnknownSize(iterator, Spliterator.ORDERED), false)
+ .map(r -> (GenericRecord)r)
.collect(Collectors.toList());
assertEquals(expectedKey50and0s, recordsByPrefix);
@@ -329,6 +331,7 @@ public class TestHoodieHFileReaderWriter extends TestHoodieReaderWriterBase {
hfileReader.getRecordsByKeyPrefixIterator(Arrays.asList("key1", "key0"), avroSchema);
recordsByPrefix =
StreamSupport.stream(Spliterators.spliteratorUnknownSize(iterator, Spliterator.ORDERED), false)
+ .map(r -> (GenericRecord)r)
.collect(Collectors.toList());
Collections.sort(recordsByPrefix, new Comparator<GenericRecord>() {
@Override