public class FileRewriteCoordinator
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
void |
clearRewrite(Table table,
java.lang.String fileSetId) |
java.util.Set<F> |
fetchNewFiles(Table table,
java.lang.String fileSetId) |
java.util.Set<java.lang.String> |
fetchSetIds(Table table) |
static FileRewriteCoordinator |
get() |
void |
stageRewrite(Table table,
java.lang.String fileSetId,
java.util.Set<F> newFiles)
Called to persist the output of a rewrite action for a specific group.
|
public static FileRewriteCoordinator get()
public void stageRewrite(Table table, java.lang.String fileSetId, java.util.Set<F> newFiles)
table
- table where the rewrite is occurringfileSetId
- the id used to identify the source set of files being rewrittennewFiles
- the new files which have been writtenpublic java.util.Set<F> fetchNewFiles(Table table, java.lang.String fileSetId)
public void clearRewrite(Table table, java.lang.String fileSetId)
public java.util.Set<java.lang.String> fetchSetIds(Table table)