org.apache.sysml.runtime.matrix

Class SortMR

java.lang.Object

org.apache.sysml.runtime.matrix.SortMR

public class SortMR
extends Object

TODO fix issues sortindex mappers

Field Summary

Fields

Modifier and Type	Field and Description
static String	COMBINE_INSTRUCTION
static String	NUM_VALUES_PREFIX
static String	SORT_DECREASING
static String	SORT_INDEXES_OFFSETS
static String	SORT_INSTRUCTION
static String	VALUE_IS_WEIGHT

Method Summary

Modifier and Type	Method and Description
static org.apache.sysml.runtime.instructions.mr.MRInstruction	parseSortInstruction(String str)
static JobReturn	runJob(MRJobInstruction inst, String input, InputInfo inputInfo, long rlen, long clen, int brlen, int bclen, String combineInst, String sortInst, int numReducers, int replication, String output, OutputInfo outputInfo, boolean valueIsWeight)

Methods inherited from class java.lang.Object

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

Field Detail

NUM_VALUES_PREFIX

public static final String NUM_VALUES_PREFIX

See Also:

Constant Field Values

COMBINE_INSTRUCTION

public static final String COMBINE_INSTRUCTION

See Also:

Constant Field Values

SORT_INSTRUCTION

public static final String SORT_INSTRUCTION

See Also:

Constant Field Values

VALUE_IS_WEIGHT

public static final String VALUE_IS_WEIGHT

See Also:

Constant Field Values

SORT_INDEXES_OFFSETS

public static final String SORT_INDEXES_OFFSETS

See Also:

Constant Field Values

SORT_DECREASING

public static final String SORT_DECREASING

See Also:

Constant Field Values

Method Detail

runJob

public static JobReturn runJob(MRJobInstruction inst,
                               String input,
                               InputInfo inputInfo,
                               long rlen,
                               long clen,
                               int brlen,
                               int bclen,
                               String combineInst,
                               String sortInst,
                               int numReducers,
                               int replication,
                               String output,
                               OutputInfo outputInfo,
                               boolean valueIsWeight)
                        throws Exception

Throws:

Exception

parseSortInstruction

public static org.apache.sysml.runtime.instructions.mr.MRInstruction parseSortInstruction(String str)
                                                                                   throws DMLRuntimeException

Throws:

DMLRuntimeException