Uses of Class
org.apache.flink.connector.file.sink.FileSinkCommittable

Packages that use FileSinkCommittable

Package	Description
org.apache.flink.connector.file.sink
org.apache.flink.connector.file.sink.committer
org.apache.flink.connector.file.sink.compactor.operator
org.apache.flink.connector.file.sink.writer

Uses of FileSinkCommittable in org.apache.flink.connector.file.sink

Methods in org.apache.flink.connector.file.sink that return FileSinkCommittable

Modifier and Type	Method	Description
FileSinkCommittable	FileSinkCommittableSerializer.deserialize(int version, byte[] serialized)

Methods in org.apache.flink.connector.file.sink that return types with arguments of type FileSinkCommittable

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>>	FileSink.addPreCommitTopology(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> committableStream)
org.apache.flink.api.connector.sink2.Committer<FileSinkCommittable>	FileSink.createCommitter(org.apache.flink.api.connector.sink2.CommitterInitContext context)
org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>	FileSink.getCommittableSerializer()
org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>	FileSink.getWriteResultSerializer()

Methods in org.apache.flink.connector.file.sink with parameters of type FileSinkCommittable

Modifier and Type	Method	Description
byte[]	FileSinkCommittableSerializer.serialize(FileSinkCommittable committable)

Method parameters in org.apache.flink.connector.file.sink with type arguments of type FileSinkCommittable

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>>	FileSink.addPreCommitTopology(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> committableStream)

Uses of FileSinkCommittable in org.apache.flink.connector.file.sink.committer

Method parameters in org.apache.flink.connector.file.sink.committer with type arguments of type FileSinkCommittable

Modifier and Type	Method	Description
void	FileCommitter.commit(Collection<org.apache.flink.api.connector.sink2.Committer.CommitRequest<FileSinkCommittable>> requests)

Uses of FileSinkCommittable in org.apache.flink.connector.file.sink.compactor.operator

Methods in org.apache.flink.connector.file.sink.compactor.operator with type parameters of type FileSinkCommittable

Modifier and Type	Method	Description
<T extends org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,CompactorRequest>>> T	CompactCoordinatorStateHandlerFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,CompactorRequest>> parameters)
<T extends org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>>> T	CompactorOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> parameters)
<T extends org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>>> T	CompactorOperatorStateHandlerFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> parameters)

Methods in org.apache.flink.connector.file.sink.compactor.operator that return types with arguments of type FileSinkCommittable

Modifier and Type	Method	Description
List<FileSinkCommittable>	CompactorRequest.getCommittableToCompact()
List<FileSinkCommittable>	CompactorRequest.getCommittableToPassthrough()

Methods in org.apache.flink.connector.file.sink.compactor.operator with parameters of type FileSinkCommittable

Modifier and Type	Method	Description
void	CompactorRequest.addToCompact(FileSinkCommittable committable)
void	CompactorRequest.addToPassthrough(FileSinkCommittable committable)

Method parameters in org.apache.flink.connector.file.sink.compactor.operator with type arguments of type FileSinkCommittable

Modifier and Type	Method	Description
<T extends org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,CompactorRequest>>> T	CompactCoordinatorStateHandlerFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,CompactorRequest>> parameters)
<T extends org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>>> T	CompactorOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> parameters)
<T extends org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>>> T	CompactorOperatorStateHandlerFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> parameters)
void	CompactCoordinator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> element)
void	CompactCoordinatorStateHandler.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> element)
void	CompactorOperatorStateHandler.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,CompactorRequest>> element)
void	CompactService.submit(CompactorRequest request, CompletableFuture<Iterable<FileSinkCommittable>> resultFuture)

Constructor parameters in org.apache.flink.connector.file.sink.compactor.operator with type arguments of type FileSinkCommittable

Constructor	Description
CompactCoordinator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<CompactorRequest> parameters, FileCompactStrategy strategy, org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable> committableSerializer)
CompactCoordinatorFactory(FileCompactStrategy strategy, org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier)
CompactCoordinatorStateHandler(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,CompactorRequest>> parameters, org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable> committableSerializer)
CompactCoordinatorStateHandler(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,CompactorRequest>> parameters, org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable> committableSerializer)
CompactCoordinatorStateHandlerFactory(org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier)
CompactorOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> parameters, FileCompactStrategy strategy, org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable> committableSerializer, FileCompactor fileCompactor, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,String> bucketWriter)
CompactorOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> parameters, FileCompactStrategy strategy, org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable> committableSerializer, FileCompactor fileCompactor, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,String> bucketWriter)
CompactorOperatorFactory(FileCompactStrategy strategy, FileCompactor fileCompactor, org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier, org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,String>,IOException> bucketWriterProvider)
CompactorOperatorStateHandler(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> parameters, org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable> committableSerializer, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,String> bucketWriter)
CompactorOperatorStateHandler(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> parameters, org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable> committableSerializer, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,String> bucketWriter)
CompactorOperatorStateHandlerFactory(org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier, org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,String>,IOException> bucketWriterProvider)
CompactorRequest(String bucketId, List<FileSinkCommittable> committableToCompact, List<FileSinkCommittable> committableToPassthrough)
CompactorRequestSerializer(org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable> committableSerializer)
CompactorRequestTypeInfo(org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier)

Uses of FileSinkCommittable in org.apache.flink.connector.file.sink.writer

Methods in org.apache.flink.connector.file.sink.writer that return types with arguments of type FileSinkCommittable

Modifier and Type	Method	Description
Collection<FileSinkCommittable>	FileWriter.prepareCommit()