org.kitesdk.tools

Class CompactionTask<T>

java.lang.Object

org.kitesdk.tools.CompactionTask<T>

All Implemented Interfaces:

Configurable

public class CompactionTask<T>
extends Object
implements Configurable

Since:

1.1.0

Constructor Summary

Constructors

Constructor and Description
CompactionTask(View<T> view)

Method Summary

Methods

Modifier and Type	Method and Description
Configuration	getConf()
long	getCount()
PipelineResult	run()
void	setConf(Configuration configuration)
void	setFilesPerPartition(int filesPerPartition)
CompactionTask	setNumWriters(int numWriters)

Methods inherited from class java.lang.Object

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

Constructor Detail

CompactionTask

public CompactionTask(View<T> view)

Method Detail

getCount

public long getCount()

setNumWriters

public CompactionTask setNumWriters(int numWriters)

run

public PipelineResult run()
                   throws IOException

Throws:

IOException

setConf

public void setConf(Configuration configuration)

Specified by:

setConf in interface Configurable

getConf

public Configuration getConf()

Specified by:

getConf in interface Configurable

setFilesPerPartition

public void setFilesPerPartition(int filesPerPartition)