Package org.apache.iceberg.spark

Class PositionDeletesRewriteCoordinator

java.lang.Object

org.apache.iceberg.spark.PositionDeletesRewriteCoordinator

public class PositionDeletesRewriteCoordinator
extends Object

Method Summary

Modifier and Type	Method	Description
void	clearRewrite(Table table, String fileSetId)
Set<DeleteFile>	fetchNewFiles(Table table, String fileSetId)
Set<String>	fetchSetIds(Table table)
static PositionDeletesRewriteCoordinator	get()
void	stageRewrite(Table table, String fileSetId, Set<DeleteFile> 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 PositionDeletesRewriteCoordinator get()

stageRewrite

public void stageRewrite(Table table,
 String fileSetId,
 Set<DeleteFile> 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<DeleteFile> fetchNewFiles(Table table,
 String fileSetId)

clearRewrite

public void clearRewrite(Table table,
 String fileSetId)

fetchSetIds

public Set<String> fetchSetIds(Table table)