alluxio.job.cmd.load

Class LoadCliConfig

java.lang.Object

alluxio.job.cmd.load.LoadCliConfig

All Implemented Interfaces:

CliConfig, CmdConfig, Serializable

@ThreadSafe
public class LoadCliConfig
extends Object
implements CliConfig

A config for a LoadCli job.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAME

Constructor Summary

Constructors

Constructor and Description
LoadCliConfig(String filePath, Integer batchSize, Integer replication, Set<String> workerSet, Set<String> excludedWorkerSet, Set<String> localityIds, Set<String> excludedLocalityIds, boolean directCache)

Method Summary

Modifier and Type	Method and Description
Collection<String>	affectedPaths()
boolean	equals(Object obj)
int	getBatchSize() Get batch size.
boolean	getDirectCache() Use direct cache or not.
Set<String>	getExcludedLocalityIds()
Set<String>	getExcludedWorkerSet()
String	getFilePath()
JobSource	getJobSource()
Set<String>	getLocalityIds()
String	getName()
OperationType	getOperationType()
int	getReplication()
Set<String>	getWorkerSet()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final String NAME

See Also:

Constant Field Values

Constructor Detail

LoadCliConfig

public LoadCliConfig(String filePath,
                     Integer batchSize,
                     Integer replication,
                     Set<String> workerSet,
                     Set<String> excludedWorkerSet,
                     Set<String> localityIds,
                     Set<String> excludedLocalityIds,
                     boolean directCache)

Parameters:

filePath - the file path

batchSize - the batch size

replication - the number of workers to store each block on, defaults to 1

workerSet - the worker set

excludedWorkerSet - the excluded worker set

localityIds - the locality identify set

excludedLocalityIds - the excluded locality identify set

directCache - direct cache

Method Detail

getName

public String getName()

Specified by:

getName in interface CmdConfig

Returns:

name of the Cmd job

getJobSource

public JobSource getJobSource()

Specified by:

getJobSource in interface CmdConfig

Returns:

JobSource of the Cmd job

getOperationType

public OperationType getOperationType()

Specified by:

getOperationType in interface CmdConfig

Returns:

OperationType of the Cmd job

affectedPaths

public Collection<String> affectedPaths()

Specified by:

affectedPaths in interface CmdConfig

Returns:

list of affected paths

getFilePath

public String getFilePath()

Returns:

file path

getReplication

public int getReplication()

Returns:

replication

getWorkerSet

public Set<String> getWorkerSet()

Returns:

worker set

getExcludedWorkerSet

public Set<String> getExcludedWorkerSet()

Returns:

excluded worker set

getLocalityIds

public Set<String> getLocalityIds()

Returns:

locality identify set

getExcludedLocalityIds

public Set<String> getExcludedLocalityIds()

Returns:

excluded locality identify set

getBatchSize

public int getBatchSize()

Get batch size.

Returns:

batch size

getDirectCache

public boolean getDirectCache()

Use direct cache or not.

Returns:

boolean flag

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