org.apache.sysml.runtime.matrix

Class WriteCSVMR

java.lang.Object

org.apache.sysml.runtime.matrix.WriteCSVMR

public class WriteCSVMR
extends Object

Method Summary

Modifier and Type	Method and Description
static int	determineNumReducers(long[] rlen, long[] clen, int defaultNumRed, long numRedGroups)
static JobReturn	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)

Methods inherited from class java.lang.Object

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

Method Detail

runJob

public static JobReturn 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)
                        throws Exception

Throws:

Exception

determineNumReducers

public static int determineNumReducers(long[] rlen,
                                       long[] clen,
                                       int defaultNumRed,
                                       long numRedGroups)