manojpec commented on a change in pull request #3968:
URL: https://github.com/apache/hudi/pull/3968#discussion_r749896878
##########
File path:
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieAvroDataBlock.java
##########
@@ -58,22 +59,27 @@
private ThreadLocal<BinaryDecoder> decoderCache = new ThreadLocal<>();
public HoodieAvroDataBlock(@Nonnull Map<HeaderMetadataType, String>
logBlockHeader,
- @Nonnull Map<HeaderMetadataType, String> logBlockFooter,
- @Nonnull Option<HoodieLogBlockContentLocation> blockContentLocation,
@Nonnull Option<byte[]> content,
- FSDataInputStream inputStream, boolean readBlockLazily) {
+ @Nonnull Map<HeaderMetadataType, String>
logBlockFooter,
+ @Nonnull Option<HoodieLogBlockContentLocation>
blockContentLocation, @Nonnull Option<byte[]> content,
+ FSDataInputStream inputStream, boolean
readBlockLazily) {
super(logBlockHeader, logBlockFooter, blockContentLocation, content,
inputStream, readBlockLazily);
}
public HoodieAvroDataBlock(HoodieLogFile logFile, FSDataInputStream
inputStream, Option<byte[]> content,
- boolean readBlockLazily, long position, long blockSize, long
blockEndpos, Schema readerSchema,
- Map<HeaderMetadataType, String> header, Map<HeaderMetadataType, String>
footer) {
+ boolean readBlockLazily, long position, long
blockSize, long blockEndpos, Schema readerSchema,
+ Map<HeaderMetadataType, String> header,
Map<HeaderMetadataType, String> footer, String keyField) {
Review comment:
HoodieAvroBlock is derived from HoodieDataBlock and making sure the user
provided key fields are sent to the parent classes properly.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
