Flink compaction source supports the Source interface based on FLIP-27
Open
area:table-service
component:compaction
engine:flink
priority:low
type:improvement
- Dominant language
- Java
- Stars
- 6.2k
- Forks
- 2.5k
- Avg merge
- 2d 4h
- Merged PRs (30d)
- 112
Description
The CompactionPlanSourceFunction is the Flink hudi compaction source function which implements the SourceFunction interface. The new Source interface is introduced in Flink and the compaction source could support the Source based on the FLIP-27.
## JIRA info
- Link: https://issues.apache.org/jira/browse/HUDI-2545
- Type: Improvement
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.