alluxio.job.plan.load

Class LoadConfig

java.lang.Object

alluxio.job.plan.load.LoadConfig

All Implemented Interfaces:

JobConfig, PlanConfig, Serializable

@ThreadSafe
public class LoadConfig
extends Object
implements PlanConfig

The configuration of loading a file.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAME

Constructor Summary

Constructors

Constructor and Description
LoadConfig(String filePath, Integer replication, Set<String> workerSet, Set<String> excludedWorkerSet, Set<String> localityIds, Set<String> excludedLocalityIds)

Method Summary

Modifier and Type	Method and Description
Collection<String>	affectedPaths()
boolean	equals(Object obj)
Set<String>	getExcludedLocalityIds()
Set<String>	getExcludedWorkerSet()
String	getFilePath()
Set<String>	getLocalityIds()
String	getName()
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

LoadConfig

public LoadConfig(String filePath,
                  Integer replication,
                  Set<String> workerSet,
                  Set<String> excludedWorkerSet,
                  Set<String> localityIds,
                  Set<String> excludedLocalityIds)

Parameters:

filePath - the file path

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

Method Detail

getFilePath

public String getFilePath()

Returns:

the file path

getReplication

public int getReplication()

Returns:

the number of workers to store each block on

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

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