org.finra.msd.containers

Class CmdLine

java.lang.Object

org.finra.msd.containers.CmdLine

public class CmdLine
extends Object

Runner class parsing command line arguments

Constructor Summary

Constructors

Constructor and Description
CmdLine(String[] args) Parse the command line to retrieve at least the necessary parameters

Method Summary

Modifier and Type	Method and Description
static SourceType	fileContains(File file, String dataName) Returns the source type if the file contains a query
String	getClusterId() Gets the cluster Id if the execution mode is EMR
String	getClusterName() Gets the cluster name is the execution mode is EMR
String	getControllerRAM() Gets controller RAM passed in the configuration file
String	getData1() Gets the data retrieval query for source 1
String	getData2() Gets the data retrieval query for source 2
String	getDataSourceFolder() Gets the location of source data
String	getDelimiter()
String	getExecutorMemory() Gets executor memory passed in the configuration file
String	getLowerBound() Gets the lower bound in case of partitioning
String	getNumExecutors() Gets the number of executors passed in the configuration file
String	getNumPartitions() Gets the number of partitions passed in the configuration file
String	getOutputDirectory() Gets location of output directory
String	getPartitionByColumn() Gets the the partition column name
String	getRunConfigName() Gets the file name of the configuration file
File	getSource1() Gets the file where the data retrieval queries can be found
File	getSource2() Gets the file where the data retrieval queries can be found
SourceType	getType1() Gets the type of source 1
SourceType	getType2() Gets the type of source 2
String	getUpperBound() Gets the upper bound in case of partitioning
boolean	isLocal() Returns true if the execution mode is local

Methods inherited from class java.lang.Object

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

Constructor Detail

CmdLine

public CmdLine(String[] args)

Parse the command line to retrieve at least the necessary parameters

Parameters:

args - Input/Output/Query parameters

Method Detail

getDataSourceFolder

public String getDataSourceFolder()

Gets the location of source data

Returns:

getOutputDirectory

public String getOutputDirectory()

Gets location of output directory

Returns:

getRunConfigName

public String getRunConfigName()

Gets the file name of the configuration file

Returns:

getData1

public String getData1()

Gets the data retrieval query for source 1

Returns:

getData2

public String getData2()

Gets the data retrieval query for source 2

Returns:

getSource1

public File getSource1()

Gets the file where the data retrieval queries can be found

Returns:

getSource2

public File getSource2()

Gets the file where the data retrieval queries can be found

Returns:

getType1

public SourceType getType1()

Gets the type of source 1

Returns:

getType2

public SourceType getType2()

Gets the type of source 2

Returns:

isLocal

public boolean isLocal()

Returns true if the execution mode is local

Returns:

getClusterId

public String getClusterId()

Gets the cluster Id if the execution mode is EMR

Returns:

getClusterName

public String getClusterName()

Gets the cluster name is the execution mode is EMR

Returns:

getNumExecutors

public String getNumExecutors()

Gets the number of executors passed in the configuration file

Returns:

getExecutorMemory

public String getExecutorMemory()

Gets executor memory passed in the configuration file

Returns:

getControllerRAM

public String getControllerRAM()

Gets controller RAM passed in the configuration file

Returns:

getNumPartitions

public String getNumPartitions()

Gets the number of partitions passed in the configuration file

Returns:

getPartitionByColumn

public String getPartitionByColumn()

Gets the the partition column name

Returns:

getLowerBound

public String getLowerBound()

Gets the lower bound in case of partitioning

Returns:

getUpperBound

public String getUpperBound()

Gets the upper bound in case of partitioning

Returns:

getDelimiter

public String getDelimiter()

fileContains

public static SourceType fileContains(File file,
                                      String dataName)

Returns the source type if the file contains a query

Parameters:

file - File Name

dataName - Query

Returns: