alluxio.job.plan.transform.format.tables

Class BytesCommitter

java.lang.Object

alluxio.job.plan.transform.format.tables.BytesCommitter

All Implemented Interfaces:

Committer

public class BytesCommitter
extends Object
implements Committer

Determines whether to commit a table file based on the size of the file in bytes. The last committed table file might have fewer bytes than the specified size.

Constructor Summary

Constructors

Constructor and Description
BytesCommitter(long bytes)

Method Summary

Modifier and Type	Method and Description
boolean	shouldCommit(TableWriter writer)

Methods inherited from class java.lang.Object

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

Constructor Detail

BytesCommitter

public BytesCommitter(long bytes)

Parameters:

bytes - the size of a table file in bytes

Method Detail

shouldCommit

public boolean shouldCommit(TableWriter writer)

Specified by:

shouldCommit in interface Committer

Parameters:

writer - the current writer containing statistics about the data that has been written

Returns:

whether the current table file should commit/complete