alluxio.job.plan.transform

Class CompactConfig

java.lang.Object

alluxio.job.plan.transform.CompactConfig

All Implemented Interfaces:

JobConfig, PlanConfig, Serializable

@ThreadSafe
public final class CompactConfig
extends Object
implements PlanConfig

Configuration for a job to compact files directly under a directory. Files will be compacted into a certain number of files, if the number of existing files is less than the specified number, then no compaction happens, otherwise, assume we want to compact 100 files to 10 files, then every 10 files will be compacted into one file. The original order of rows is preserved.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CompactConfig(PartitionInfo inputPartitionInfo, String input, PartitionInfo outputPartitionInfo, String output, Integer maxNumFiles, Long minFileSize)

Method Summary

Modifier and Type	Method and Description
Collection<String>	affectedPaths()
boolean	equals(Object obj)
String	getInput()
PartitionInfo	getInputPartitionInfo()
int	getMaxNumFiles()
long	getMinFileSize()
String	getName()
String	getOutput()
PartitionInfo	getOutputPartitionInfo()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

CompactConfig

public CompactConfig(PartitionInfo inputPartitionInfo,
                     String input,
                     PartitionInfo outputPartitionInfo,
                     String output,
                     Integer maxNumFiles,
                     Long minFileSize)

Parameters:

inputPartitionInfo - the input partition info

input - the input directory

outputPartitionInfo - the output partition info

output - the output directory

maxNumFiles - the maximum number of files after compaction

minFileSize - the minimum file size for coalescing

Method Detail

getInputPartitionInfo

public PartitionInfo getInputPartitionInfo()

Returns:

the input partition info

getOutputPartitionInfo

public PartitionInfo getOutputPartitionInfo()

Returns:

the output partition info

getInput

public String getInput()

Returns:

the input directory

getOutput

public String getOutput()

Returns:

the output directory

getMaxNumFiles

public int getMaxNumFiles()

Returns:

the number of files after compaction

getMinFileSize

public long getMinFileSize()

Returns:

the file size

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

getName

public String getName()

Specified by:

getName in interface JobConfig

Returns:

the name of the job

affectedPaths

public Collection<String> affectedPaths()

Specified by:

affectedPaths in interface JobConfig

Returns:

list of affected paths