Package | Description |
---|---|
org.apache.flink.connector.file.sink.compactor |
Modifier and Type | Method and Description |
---|---|
void |
RecordWiseFileCompactor.compact(List<Path> inputFiles,
RecordWiseFileCompactor.Writer<IN> writer) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.