Package | Description |
---|---|
org.apache.flink.connector.file.sink.compactor.operator |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<CompactorRequest>> |
CompactCoordinatorFactory.createStreamOperator(StreamOperatorParameters<CompactorRequest> parameters) |
<T extends StreamOperator<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>>> |
CompactCoordinatorStateHandlerFactory.createStreamOperator(StreamOperatorParameters<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>> parameters) |
Modifier and Type | Method and Description |
---|---|
CompactorRequest |
CompactorRequestSerializer.deserialize(int version,
byte[] serialized) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<CompactorRequest> |
CompactorRequestTypeInfo.createSerializer(ExecutionConfig config) |
Class<CompactorRequest> |
CompactorRequestTypeInfo.getTypeClass() |
Modifier and Type | Method and Description |
---|---|
byte[] |
CompactorRequestSerializer.serialize(CompactorRequest request) |
void |
CompactService.submit(CompactorRequest request,
CompletableFuture<Iterable<FileSinkCommittable>> resultFuture) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<CompactorRequest>> |
CompactCoordinatorFactory.createStreamOperator(StreamOperatorParameters<CompactorRequest> parameters) |
<T extends StreamOperator<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>>> |
CompactCoordinatorStateHandlerFactory.createStreamOperator(StreamOperatorParameters<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>> parameters) |
void |
CompactorOperator.processElement(StreamRecord<CompactorRequest> element) |
void |
CompactorOperatorStateHandler.processElement(StreamRecord<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>> element) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.