Bulk Operation

HUDI-1521 Read optimized query type for Flink batch reader

HUDI-1521 Flush as per data bucket for mini-batch write

HUDI-1521 Use PRIMARY KEY syntax to define record keys for Flink Hudi table

HUDI-1521 Implement HoodieTableSource.explainSource for all kinds of pushing down

HUDI-1521 Add document about HUDI Flink integration

HUDI-1521 Bounded source for stream writer

HUDI-1521 Tweak hudi-flink-bundle module pom and re-organize the pacakges for hudi-flink module

HUDI-1521 Support object storage for Flink writer

HUDI-1521 Row level delete for Flink sink

HUDI-1521 Avro schema inference for Flink SQL table

HUDI-1521 Streaming read for Flink MOR table

HUDI-1521 Supports snapshot read for Flink

HUDI-1521 Some improvements to BucketAssignFunction

HUDI-1521 Avoid to rename for bucket update when there is only one flush action during a checkpoint

HUDI-1521 Supports merge on read write mode for Flink writer

HUDI-1521 The state based index should bootstrap from existing base files

HUDI-1521 Write as minor batches during one checkpoint interval for the new writer

HUDI-1521 Refactor the BaseFlinkCommitActionExecutor to adapt to the new Flink writer

HUDI-1521 Make Flink write pipeline write task scalable

HUDI-1521 Add a new pipeline for Flink writer