alluxio.job.transform.compact

Class SequentialCompactor

java.lang.Object

alluxio.job.transform.compact.SequentialCompactor

All Implemented Interfaces:

Compactor

public class SequentialCompactor
extends Object
implements Compactor

Sequentially read through files listed directly under the directory, complete a compacted file when the file reaches the expected size.

Constructor Summary

Constructors

Constructor and Description
SequentialCompactor()

Method Summary

Modifier and Type	Method and Description
void	compact(List<TableReader> inputs, TableWriter output) Compacts a list of inputs to the output.

Methods inherited from class java.lang.Object

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

Constructor Detail

SequentialCompactor

public SequentialCompactor()

Method Detail

compact

public void compact(List<TableReader> inputs,
                    TableWriter output)
             throws IOException

Description copied from interface: Compactor

Compacts a list of inputs to the output. Closing the readers and writer is the responsibility of the caller.

Specified by:

compact in interface Compactor

Parameters:

inputs - a list of table readers

output - a table writer, can be a TablesWriter

Throws:

IOException - when compaction fails