CommitSummary

java.lang.Object

org.apache.iceberg.flink.sink.CommitSummary

@Internal public class CommitSummary extends Object

Constructor Summary

Constructors

Constructor

Description

CommitSummary()

CommitSummary(NavigableMap<Long,WriteResult> pendingResults)
Method Summary

Modifier and Type

Method

Description

void

addAll(Collection<WriteResult> pendingResults)

void

addAll(NavigableMap<Long,List<WriteResult>> pendingResults)

long

dataFilesCount()

long

deleteFilesCount()

String

toString()

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

Constructor Details
- CommitSummary
  
  public CommitSummary()
- CommitSummary
  
  public CommitSummary(NavigableMap<Long,WriteResult> pendingResults)
Method Details
- addAll
  
  public void addAll(NavigableMap<Long,List<WriteResult>> pendingResults)
- addAll
  
  public void addAll(Collection<WriteResult> pendingResults)
- dataFilesCount
  
  public long dataFilesCount()
- deleteFilesCount
  
  public long deleteFilesCount()
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class Object