RemoveDanglingDeleteFilesAction

java.lang.Object

org.apache.iceberg.actions.RemoveDanglingDeleteFilesAction

All Implemented Interfaces:: Action<RemoveDanglingDeleteFiles,RemoveDanglingDeleteFiles.Result>, RemoveDanglingDeleteFiles, SnapshotUpdateAction<RemoveDanglingDeleteFiles,RemoveDanglingDeleteFiles.Result>

public class RemoveDanglingDeleteFilesAction extends Object implements RemoveDanglingDeleteFiles

Nested Class Summary

Nested Classes

Modifier and Type

Class

Description

static final class

RemoveDanglingDeleteFilesAction.DeleteFileKey

Nested classes/interfaces inherited from interface org.apache.iceberg.actions.RemoveDanglingDeleteFiles
RemoveDanglingDeleteFiles.Result
Constructor Summary

Constructors

Constructor

Description

RemoveDanglingDeleteFilesAction(Table table)

RemoveDanglingDeleteFilesAction(Table table, BiFunction<Long,List<ManifestFile>,Collection<DeleteFile>> findDanglingDeletes)
Method Summary

Modifier and Type

Method

Description

protected void

commit(SnapshotUpdate<?> update)

RemoveDanglingDeleteFiles.Result

execute()

Executes this action.

protected String

metadataTableName(String tableName, MetadataTableType type)

protected String

metadataTableName(MetadataTableType type)

static ManifestReader<DeleteFile>

readDeleteManifest(ManifestFile manifest, FileIO io, Map<Integer,PartitionSpec> specsById)

protected RemoveDanglingDeleteFilesAction

self()

RemoveDanglingDeleteFiles

set(String property, String value)

protected Table

table()

RemoveDanglingDeleteFilesAction

toBranch(String targetBranch)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.iceberg.actions.Action
option, options

Constructor Details
- RemoveDanglingDeleteFilesAction
  
  public RemoveDanglingDeleteFilesAction(Table table)
- RemoveDanglingDeleteFilesAction
  
  public RemoveDanglingDeleteFilesAction(Table table, BiFunction<Long,List<ManifestFile>,Collection<DeleteFile>> findDanglingDeletes)
Method Details
- self
  
  protected RemoveDanglingDeleteFilesAction self()
- table
  
  protected Table table()
- toBranch
  
  public RemoveDanglingDeleteFilesAction toBranch(String targetBranch)
- execute
  
  public RemoveDanglingDeleteFiles.Result execute()
  
  Description copied from interface: Action
  
  Executes this action.
  
  Specified by:
  
  execute in interface Action<RemoveDanglingDeleteFiles,RemoveDanglingDeleteFiles.Result>
  
  Returns:
  
  the result of this action
- readDeleteManifest
  
  public static ManifestReader<DeleteFile> readDeleteManifest(ManifestFile manifest, FileIO io, Map<Integer,PartitionSpec> specsById)
- set
  
  public RemoveDanglingDeleteFiles set(String property, String value)
  
  Specified by:
  
  set in interface SnapshotUpdateAction<ThisT,R>
- commit
  
  protected void commit(SnapshotUpdate<?> update)
- metadataTableName
  
  protected String metadataTableName(MetadataTableType type)
- metadataTableName
  
  protected String metadataTableName(String tableName, MetadataTableType type)