edu.iu.dsc.tws.examples.batch.sortop

Class SortJob

java.lang.Object

edu.iu.dsc.tws.examples.batch.sortop.SortJob

All Implemented Interfaces:

IWorker

public class SortJob
extends java.lang.Object
implements IWorker

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ARG_INPUT_FILE
static java.lang.String	ARG_KEY_SEED
static java.lang.String	ARG_KEY_SIZE
static java.lang.String	ARG_OUTPUT_FOLDER
static java.lang.String	ARG_RESOURCE_CPU
static java.lang.String	ARG_RESOURCE_INSTANCES
static java.lang.String	ARG_RESOURCE_MEMORY
static java.lang.String	ARG_SIZE
static java.lang.String	ARG_TASKS_SINKS
static java.lang.String	ARG_TASKS_SOURCES
static java.lang.String	ARG_TUNE_MAX_BYTES_IN_MEMORY
static java.lang.String	ARG_TUNE_MAX_SHUFFLE_FILE_SIZE
static java.lang.String	ARG_VALUE_SIZE

Constructor Summary

Constructors

Constructor and Description
SortJob()

Method Summary

Modifier and Type	Method and Description
void	execute(Config cfg, JobAPI.Job job, IWorkerController workerController, IPersistentVolume persistentVolume, IVolatileVolume volatileVolume) Execute with the resources configured
static void	main(java.lang.String[] args)

Methods inherited from class java.lang.Object

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

Field Detail

ARG_INPUT_FILE

public static final java.lang.String ARG_INPUT_FILE

See Also:

Constant Field Values

ARG_OUTPUT_FOLDER

public static final java.lang.String ARG_OUTPUT_FOLDER

See Also:

Constant Field Values

ARG_SIZE

public static final java.lang.String ARG_SIZE

See Also:

Constant Field Values

ARG_KEY_SIZE

public static final java.lang.String ARG_KEY_SIZE

See Also:

Constant Field Values

ARG_VALUE_SIZE

public static final java.lang.String ARG_VALUE_SIZE

See Also:

Constant Field Values

ARG_KEY_SEED

public static final java.lang.String ARG_KEY_SEED

See Also:

Constant Field Values

ARG_RESOURCE_CPU

public static final java.lang.String ARG_RESOURCE_CPU

See Also:

Constant Field Values

ARG_RESOURCE_MEMORY

public static final java.lang.String ARG_RESOURCE_MEMORY

See Also:

Constant Field Values

ARG_RESOURCE_INSTANCES

public static final java.lang.String ARG_RESOURCE_INSTANCES

See Also:

Constant Field Values

ARG_TASKS_SOURCES

public static final java.lang.String ARG_TASKS_SOURCES

See Also:

Constant Field Values

ARG_TASKS_SINKS

public static final java.lang.String ARG_TASKS_SINKS

See Also:

Constant Field Values

ARG_TUNE_MAX_BYTES_IN_MEMORY

public static final java.lang.String ARG_TUNE_MAX_BYTES_IN_MEMORY

See Also:

Constant Field Values

ARG_TUNE_MAX_SHUFFLE_FILE_SIZE

public static final java.lang.String ARG_TUNE_MAX_SHUFFLE_FILE_SIZE

See Also:

Constant Field Values

Constructor Detail

SortJob

public SortJob()

Method Detail

execute

public void execute(Config cfg,
                    JobAPI.Job job,
                    IWorkerController workerController,
                    IPersistentVolume persistentVolume,
                    IVolatileVolume volatileVolume)

Description copied from interface: IWorker

Execute with the resources configured

Specified by:

execute in interface IWorker

Parameters:

cfg - configuration

job - the worker id

workerController - the worker controller

persistentVolume - information about persistent file system

volatileVolume - information about volatile file system

main

public static void main(java.lang.String[] args)
                 throws ParseException

Throws:

ParseException