public class GroupedAggMR extends Object
Modifier and Type | Method and Description |
---|---|
static JobReturn |
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) |
public static JobReturn 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) throws Exception
Exception
Copyright © 2018 The Apache Software Foundation. All rights reserved.