org.apache.iceberg.actions

Class RewriteDataFilesCommitManager.CommitService

java.lang.Object

org.apache.iceberg.actions.RewriteDataFilesCommitManager.CommitService

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

RewriteDataFilesCommitManager

public class RewriteDataFilesCommitManager.CommitService
extends java.lang.Object
implements java.io.Closeable

Method Summary

Modifier and Type	Method and Description
void	close()
void	offer(RewriteFileGroup group) Places a file group in the queue to be asynchronously committed either when the queue has enough elements to do a batch of size rewritesPerCommit or the service has been closed.
java.util.List<RewriteFileGroup>	results() Returns all File groups which have been committed
void	start() Starts a single threaded executor service for handling file group commits.

Methods inherited from class java.lang.Object

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

Method Detail

start

public void start()

Starts a single threaded executor service for handling file group commits.

offer

public void offer(RewriteFileGroup group)

Places a file group in the queue to be asynchronously committed either when the queue has enough elements to do a batch of size rewritesPerCommit or the service has been closed.

Parameters:

group - file group to eventually be committed

results

public java.util.List<RewriteFileGroup> results()

Returns all File groups which have been committed

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable