Package org.apache.iceberg.spark

Class FileRewriteCoordinator

java.lang.Object

org.apache.iceberg.spark.FileRewriteCoordinator

public class FileRewriteCoordinator
extends Object

Method Summary

Modifier and Type	Method	Description
void	clearRewrite(Table table, String fileSetId)
Set<DataFile>	fetchNewFiles(Table table, String fileSetId)
Set<String>	fetchSetIds(Table table)
static FileRewriteCoordinator	get()
void	stageRewrite(Table table, String fileSetId, Set<DataFile> newFiles)	Called to persist the output of a rewrite action for a specific group.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

get

public static FileRewriteCoordinator get()

stageRewrite

public void stageRewrite(Table table,
 String fileSetId,
 Set<DataFile> newFiles)

Called to persist the output of a rewrite action for a specific group. Since the write is done via a Spark Datasource, we have to propagate the result through this side-effect call.

Parameters:

table - table where the rewrite is occurring

fileSetId - the id used to identify the source set of files being rewritten

newFiles - the new files which have been written

fetchNewFiles

public Set<DataFile> fetchNewFiles(Table table,
 String fileSetId)

clearRewrite

public void clearRewrite(Table table,
 String fileSetId)

fetchSetIds

public Set<String> fetchSetIds(Table table)