• G
    [FLINK-17593][fs-connector] Support arbitrary recovery mechanism for PartFileWriter · 339f5d84
    GuoWei Ma 提交于
    This change includes two things:
    1. Make the PartFileWriter generic and decouple the PartFileWriter and RecoverableStream. According to different pre-commit / commit methods,
    this change allows us to extend different types of PartFileWriter.
    2. Make the Bucket/Buckets depends on the PartFileFactory instead of RecoverableWriter.
    
    This closes #12132
    339f5d84
.part-0-3.inprogress.23aa64c0-391d-47ee-a86b-cd04aec0aabe 12 字节