Constructor and Description |
---|
CompactService(int numCompactThreads,
FileCompactor fileCompactor,
BucketWriter<?,String> bucketWriter) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
open() |
void |
submit(CompactorRequest request,
CompletableFuture<Iterable<FileSinkCommittable>> resultFuture) |
public CompactService(int numCompactThreads, FileCompactor fileCompactor, BucketWriter<?,String> bucketWriter)
public void open()
public void submit(CompactorRequest request, CompletableFuture<Iterable<FileSinkCommittable>> resultFuture)
public void close()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.