CompactCoordinator(FileCompactStrategy strategy,
SimpleVersionedSerializer<FileSinkCommittable> committableSerializer) |
CompactCoordinatorFactory(FileCompactStrategy strategy,
SerializableSupplierWithException<SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier) |
CompactCoordinatorStateHandler(SimpleVersionedSerializer<FileSinkCommittable> committableSerializer) |
CompactCoordinatorStateHandlerFactory(SerializableSupplierWithException<SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier) |
CompactorOperator(FileCompactStrategy strategy,
SimpleVersionedSerializer<FileSinkCommittable> committableSerializer,
FileCompactor fileCompactor,
BucketWriter<?,String> bucketWriter) |
CompactorOperatorFactory(FileCompactStrategy strategy,
FileCompactor fileCompactor,
SerializableSupplierWithException<SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier,
SerializableSupplierWithException<BucketWriter<?,String>,IOException> bucketWriterProvider) |
CompactorOperatorStateHandler(SimpleVersionedSerializer<FileSinkCommittable> committableSerializer,
BucketWriter<?,String> bucketWriter) |
CompactorOperatorStateHandlerFactory(SerializableSupplierWithException<SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier,
SerializableSupplierWithException<BucketWriter<?,String>,IOException> bucketWriterProvider) |
CompactorRequest(String bucketId,
List<FileSinkCommittable> committableToCompact,
List<FileSinkCommittable> committableToPassthrough) |
CompactorRequest(String bucketId,
List<FileSinkCommittable> committableToCompact,
List<FileSinkCommittable> committableToPassthrough) |
CompactorRequestSerializer(SimpleVersionedSerializer<FileSinkCommittable> committableSerializer) |
CompactorRequestTypeInfo(SerializableSupplierWithException<SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier) |