Package | Description |
---|---|
org.apache.flink.connector.file.sink | |
org.apache.flink.connector.file.sink.committer | |
org.apache.flink.connector.file.sink.writer |
Modifier and Type | Method and Description |
---|---|
FileSinkCommittable |
FileSinkCommittableSerializer.deserialize(int version,
byte[] serialized) |
Modifier and Type | Method and Description |
---|---|
Optional<Committer<FileSinkCommittable>> |
FileSink.createCommitter() |
Optional<GlobalCommitter<FileSinkCommittable,Void>> |
FileSink.createGlobalCommitter() |
SinkWriter<IN,FileSinkCommittable,FileWriterBucketState> |
FileSink.createWriter(Sink.InitContext context,
List<FileWriterBucketState> states) |
Optional<SimpleVersionedSerializer<FileSinkCommittable>> |
FileSink.getCommittableSerializer() |
Modifier and Type | Method and Description |
---|---|
byte[] |
FileSinkCommittableSerializer.serialize(FileSinkCommittable committable) |
Modifier and Type | Method and Description |
---|---|
List<FileSinkCommittable> |
FileCommitter.commit(List<FileSinkCommittable> committables) |
Modifier and Type | Method and Description |
---|---|
List<FileSinkCommittable> |
FileCommitter.commit(List<FileSinkCommittable> committables) |
Modifier and Type | Method and Description |
---|---|
List<FileSinkCommittable> |
FileWriter.prepareCommit(boolean flush) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.