alluxio.job.plan.transform.format.tables

Class RowsCommitter

java.lang.Object

alluxio.job.plan.transform.format.tables.RowsCommitter

All Implemented Interfaces:

Committer

public class RowsCommitter
extends Object
implements Committer

Determines whether to commit based on the number of rows that have been written. Note that the last table file might contain rows fewer than the specified number.

Constructor Summary

Constructors

Constructor and Description
RowsCommitter(int rows)

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

RowsCommitter

public RowsCommitter(int rows)

Parameters:

rows - the number of rows in one table file

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