Package | Description |
---|---|
org.apache.flink.streaming.api.functions.sink.filesystem |
Modifier and Type | Class and Description |
---|---|
class |
OutputStreamBasedPartFileWriter<IN,BucketID>
The base class for all the part file writer that use
RecoverableFsDataOutputStream . |
class |
RowWisePartWriter<IN,BucketID>
A
InProgressFileWriter for row-wise formats that use an Encoder . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.