This is an automated email from the ASF dual-hosted git repository.
sivabalan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 1d9a0ce8e71b [HUDI-8385] Keep ColumnStats consistent during Restore
(#13664)
add 928d603f8fa9 perf: Lazy deserialization of Avro indexed record (#13987)
No new revisions were added by this update.
Summary of changes:
.../hudi/io/FileGroupReaderBasedMergeHandle.java | 3 +-
.../org/apache/hudi/io/TestHoodieWriteHandle.java | 2 +-
.../hudi/client/model/HoodieFlinkRecord.java | 2 +-
.../hudi/BaseSparkInternalRecordContext.java | 2 +-
.../SparkClientFunctionalTestHarness.java | 3 +-
.../org/apache/hudi/avro/AvroRecordContext.java | 2 +-
.../apache/hudi/avro/HoodieAvroReaderContext.java | 2 +-
.../hudi/common/engine/HoodieReaderContext.java | 2 +-
.../apache/hudi/common/model/BaseAvroPayload.java | 2 +-
.../hudi/common/model/HoodieAvroIndexedRecord.java | 20 +++++----
.../apache/hudi/common/model/HoodieAvroRecord.java | 2 +-
.../org/apache/hudi/common/model/HoodieRecord.java | 3 ++
.../common/model/SerializableIndexedRecord.java | 38 ++++++++++++++---
.../debezium/PostgresDebeziumAvroPayload.java | 8 ++--
.../hudi/common/table/read/BufferedRecords.java | 5 ---
.../table/read/FileGroupReaderSchemaHandler.java | 16 ++++++++
.../SortedKeyBasedFileGroupRecordBuffer.java | 12 +++---
.../StreamingFileGroupRecordBufferLoader.java | 19 ++-------
.../apache/hudi/common/util/HoodieRecordUtils.java | 18 ++++----
.../util/collection/ExternalSpillableMap.java | 3 +-
.../table/read/TestHoodieFileGroupReaderBase.java | 13 ++++--
.../common/table/read/TestUpdateProcessor.java | 9 ++--
.../read/buffer/BaseTestFileGroupRecordBuffer.java | 10 +++++
.../buffer/TestKeyBasedFileGroupRecordBuffer.java | 7 +++-
.../TestSortedKeyBasedFileGroupRecordBuffer.java | 4 +-
...TestStreamingKeyBasedFileGroupRecordBuffer.java | 7 +++-
.../common/testutils/HoodieTestDataGenerator.java | 2 +-
.../hudi/common/testutils/HoodieTestUtils.java | 2 +-
.../common/functional/TestHoodieLogFormat.java | 48 ++++++++++++++--------
.../org/apache/hudi/HoodieCreateRecordUtils.scala | 19 +++++----
.../org/apache/hudi/HoodieSparkSqlWriter.scala | 5 ++-
.../hudi/command/payload/ExpressionPayload.scala | 10 +----
.../SparkFullBootstrapDataProviderBase.java | 2 +-
.../hudi/TestHoodieMergeHandleWithSparkMerger.java | 3 +-
.../java/org/apache/hudi/io/TestMergeHandle.java | 21 ++++++----
.../scala/org/apache/hudi/SparkDatasetMixin.scala | 16 ++++++--
.../model/TestHoodieRecordSerialization.scala | 6 ++-
.../read/TestHoodieFileGroupReaderOnSpark.scala | 10 +++--
.../benchmark/CreateHandleBenchmark.scala | 2 +-
.../utilities/streamer/HoodieStreamerUtils.java | 8 +++-
.../apache/hudi/utilities/streamer/StreamSync.java | 9 ++--
.../testutils/sources/AbstractBaseTestSource.java | 3 +-
42 files changed, 239 insertions(+), 141 deletions(-)
