Package | Description |
---|---|
org.apache.flink.connector.file.sink.compactor |
Modifier and Type | Class and Description |
---|---|
static class |
DecoderBasedReader.Factory<T>
Factory for
DecoderBasedReader . |
static class |
InputFormatBasedReader.Factory<T>
Factory for
InputFormatBasedReader . |
Constructor and Description |
---|
RecordWiseFileCompactor(RecordWiseFileCompactor.Reader.Factory<IN> readerFactory) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.