Modifier and Type | Method and Description |
---|---|
OutputInfo[] |
MRJobInstruction.getOutputInfos() |
Modifier and Type | Method and Description |
---|---|
protected void |
WriteSPInstruction.processFrameWriteInstruction(org.apache.sysml.runtime.controlprogram.context.SparkExecutionContext sec,
String fname,
OutputInfo oi,
org.apache.sysml.parser.Expression.ValueType[] schema) |
protected void |
WriteSPInstruction.processMatrixWriteInstruction(org.apache.sysml.runtime.controlprogram.context.SparkExecutionContext sec,
String fname,
OutputInfo oi) |
Modifier and Type | Method and Description |
---|---|
OutputInfo |
MatrixFormatMetaData.getOutputInfo() |
Modifier and Type | Method and Description |
---|---|
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 |
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) |
Constructor and Description |
---|
JobReturn(MatrixCharacteristics[] sts,
OutputInfo[] infos,
boolean success) |
JobReturn(MatrixCharacteristics sts,
OutputInfo info,
boolean success) |
MatrixFormatMetaData(MatrixCharacteristics mc,
OutputInfo oinfo_,
InputInfo iinfo_) |
Modifier and Type | Field and Description |
---|---|
static OutputInfo |
OutputInfo.BinaryBlockFrameOutputInfo |
static OutputInfo |
OutputInfo.BinaryBlockOutputInfo |
static OutputInfo |
OutputInfo.BinaryCellOutputInfo |
static OutputInfo |
OutputInfo.CSVOutputInfo |
static OutputInfo |
OutputInfo.MatrixMarketOutputInfo |
static OutputInfo |
OutputInfo.OutputInfoForSortInput |
static OutputInfo |
OutputInfo.OutputInfoForSortOutput |
static OutputInfo |
OutputInfo.TextCellOutputInfo |
static OutputInfo |
OutputInfo.WeightedPairOutputInfo |
Modifier and Type | Method and Description |
---|---|
static OutputInfo |
InputInfo.getMatchingOutputInfo(InputInfo ii) |
static OutputInfo |
OutputInfo.stringToOutputInfo(String str) |
Modifier and Type | Method and Description |
---|---|
static InputInfo |
OutputInfo.getMatchingInputInfo(OutputInfo oi) |
static String |
OutputInfo.outputInfoToString(OutputInfo oi) |
static String |
OutputInfo.outputInfoToStringExternal(OutputInfo oinfo) |
Modifier and Type | Method and Description |
---|---|
void |
Matrix.setMatrixDoubleArray(MatrixBlock mb,
OutputInfo oinfo,
InputInfo iinfo)
Method to set matrix as double array.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.