Uses of Class
org.apache.sysml.runtime.instructions.MRJobInstruction

Packages that use MRJobInstruction

Package	Description
org.apache.sysml.runtime.instructions
org.apache.sysml.runtime.matrix

Uses of MRJobInstruction in org.apache.sysml.runtime.instructions

Methods in org.apache.sysml.runtime.instructions with parameters of type MRJobInstruction

Modifier and Type	Method and Description
boolean	MRJobInstruction.isMergableMRJobInstruction(MRJobInstruction that)
void	MRJobInstruction.mergeMRJobInstruction(MRJobInstruction that)

Constructors in org.apache.sysml.runtime.instructions with parameters of type MRJobInstruction

Constructor and Description
MRJobInstruction(MRJobInstruction that) (deep) Copy constructor, primarily used in parfor.

Uses of MRJobInstruction in org.apache.sysml.runtime.matrix

Methods in org.apache.sysml.runtime.matrix with parameters of type MRJobInstruction

Modifier and Type	Method and Description
static JobReturn	DataPartitionMR.runJob(MRJobInstruction jobinst, org.apache.sysml.runtime.controlprogram.caching.MatrixObject[] inputMatrices, String shuffleInst, byte[] resultIndices, org.apache.sysml.runtime.controlprogram.caching.MatrixObject[] outputMatrices, int numReducers, int replication)
static JobReturn	GMR.runJob(MRJobInstruction inst, String[] inputs, InputInfo[] inputInfos, long[] rlens, long[] clens, int[] brlens, int[] bclens, boolean[] partitioned, org.apache.sysml.runtime.controlprogram.ParForProgramBlock.PDataPartitionFormat[] pformats, int[] psizes, String recordReaderInstruction, String instructionsInMapper, String aggInstructionsInReducer, String otherInstructionsInReducer, int numReducers, int replication, boolean jvmReuse, byte[] resultIndexes, String dimsUnknownFilePrefix, String[] outputs, OutputInfo[] outputInfos) Execute job.
static JobReturn	ReblockMR.runJob(MRJobInstruction inst, String[] inputs, InputInfo[] inputInfos, long[] rlens, long[] clens, int[] brlens, int[] bclens, long[] nnz, String instructionsInMapper, String reblockInstructions, String otherInstructionsInReducer, int numReducers, int replication, boolean jvmReuse, byte[] resultIndexes, String[] outputs, OutputInfo[] outputInfos)
static JobReturn	WriteCSVMR.runJob(MRJobInstruction inst, String[] inputs, InputInfo[] inputInfos, long[] rlens, long[] clens, int[] brlens, int[] bclens, String csvWriteInstructions, int numReducers, int replication, byte[] resultIndexes, String[] outputs)
static JobReturn	CombineMR.runJob(MRJobInstruction inst, String[] inputs, InputInfo[] inputInfos, long[] rlens, long[] clens, int[] brlens, int[] bclens, String combineInstructions, int numReducers, int replication, byte[] resultIndexes, String[] outputs, OutputInfo[] outputInfos)
static JobReturn	CSVReblockMR.runJob(MRJobInstruction inst, String[] inputs, InputInfo[] inputInfos, long[] rlens, long[] clens, int[] brlens, int[] bclens, String reblockInstructions, String otherInstructionsInReducer, int numReducers, int replication, byte[] resultIndexes, String[] outputs, OutputInfo[] outputInfos)
static JobReturn	CMCOVMR.runJob(MRJobInstruction inst, String[] inputs, InputInfo[] inputInfos, long[] rlens, long[] clens, int[] brlens, int[] bclens, String instructionsInMapper, String cmNcomInstructions, int numReducers, int replication, byte[] resultIndexes, String[] outputs, OutputInfo[] outputInfos)
static JobReturn	GroupedAggMR.runJob(MRJobInstruction inst, String[] inputs, InputInfo[] inputInfos, long[] rlens, long[] clens, int[] brlens, int[] bclens, String grpAggInstructions, String simpleReduceInstructions, int numReducers, int replication, byte[] resultIndexes, String dimsUnknownFilePrefix, String[] outputs, OutputInfo[] outputInfos)
static JobReturn	MMCJMR.runJob(MRJobInstruction inst, String[] inputs, InputInfo[] inputInfos, long[] rlens, long[] clens, int[] brlens, int[] bclens, String instructionsInMapper, String aggInstructionsInReducer, String aggBinInstrction, int numReducers, int replication, String output, OutputInfo outputinfo)
static JobReturn	MMRJMR.runJob(MRJobInstruction inst, String[] inputs, InputInfo[] inputInfos, long[] rlens, long[] clens, int[] brlens, int[] bclens, String instructionsInMapper, String aggInstructionsInReducer, String aggBinInstrctions, String otherInstructionsInReducer, int numReducers, int replication, byte[] resultIndexes, String[] outputs, OutputInfo[] outputInfos)
static JobReturn	DataGenMR.runJob(MRJobInstruction inst, String[] dataGenInstructions, String instructionsInMapper, String aggInstructionsInReducer, String otherInstructionsInReducer, int numReducers, int replication, byte[] resultIndexes, String dimsUnknownFilePrefix, String[] outputs, OutputInfo[] outputInfos) Starts a Rand MapReduce job which will produce one or more random objects.
static JobReturn	SortMR.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)