org.apache.sysml.runtime.matrix

Class CombineMR.InnerReducer

java.lang.Object

org.apache.hadoop.mapred.MapReduceBase

org.apache.sysml.runtime.matrix.mapred.MRBaseForCommonInstructions

org.apache.sysml.runtime.matrix.mapred.ReduceBase

org.apache.sysml.runtime.matrix.CombineMR.InnerReducer

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Reducer<MatrixIndexes,TaggedMatrixValue,MatrixIndexes,WeightedPair>

Enclosing class:

CombineMR

public static class CombineMR.InnerReducer
extends org.apache.sysml.runtime.matrix.mapred.ReduceBase
implements org.apache.hadoop.mapred.Reducer<MatrixIndexes,TaggedMatrixValue,MatrixIndexes,WeightedPair>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.sysml.runtime.matrix.mapred.ReduceBase

org.apache.sysml.runtime.matrix.mapred.ReduceBase.Counters

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.sysml.runtime.instructions.mr.MRInstruction[]	comb_instructions

Fields inherited from class org.apache.sysml.runtime.matrix.mapred.ReduceBase

agg_instructions, cachedReporter, collectFinalMultipleOutputs, correctionCache, DEFAULT_AGG_OP, defaultAggIns, dimsUnknownFilePrefix, firsttime, mixed_instructions, reducerID, resultDimsUnknown, resultIndexes, resultsMaxColDims, resultsMaxRowDims, resultsNonZeros

Fields inherited from class org.apache.sysml.runtime.matrix.mapred.MRBaseForCommonInstructions

cachedValues, dcValues, dimensions, isJobLocal, tempValue, valueClass, zeroInput

Constructor Summary

Constructors

Constructor and Description
InnerReducer()

Method Summary

Modifier and Type	Method and Description
void	configure(org.apache.hadoop.mapred.JobConf job)
void	reduce(MatrixIndexes indexes, Iterator<TaggedMatrixValue> values, org.apache.hadoop.mapred.OutputCollector<MatrixIndexes,WeightedPair> out, org.apache.hadoop.mapred.Reporter reporter)

Methods inherited from class org.apache.sysml.runtime.matrix.mapred.ReduceBase

close, collectOutput_N_Increase_Counter, commonSetup, containsTernaryInstruction, dimsKnownForTernaryInstructions, getOutputIndexes, getOutputIndexes, outputInCombinerFromCachedValues, outputResultsFromCachedValues, prepareMatrixCharacteristicsTernaryInstruction, processAggregateInstructions, processAggregateInstructions, processReducerInstructions

Methods inherited from class org.apache.sysml.runtime.matrix.mapred.MRBaseForCommonInstructions

collectOutput_N_Increase_Counter, processMixedInstructions, processOneInstruction, resetDistCache, setupDistCacheFiles

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Field Detail

comb_instructions

protected org.apache.sysml.runtime.instructions.mr.MRInstruction[] comb_instructions

Constructor Detail

InnerReducer

public InnerReducer()

Method Detail

reduce

public void reduce(MatrixIndexes indexes,
                   Iterator<TaggedMatrixValue> values,
                   org.apache.hadoop.mapred.OutputCollector<MatrixIndexes,WeightedPair> out,
                   org.apache.hadoop.mapred.Reporter reporter)
            throws IOException

Specified by:

reduce in interface org.apache.hadoop.mapred.Reducer<MatrixIndexes,TaggedMatrixValue,MatrixIndexes,WeightedPair>

Throws:

IOException

configure

public void configure(org.apache.hadoop.mapred.JobConf job)

Specified by:

configure in interface org.apache.hadoop.mapred.JobConfigurable

Overrides:

configure in class org.apache.sysml.runtime.matrix.mapred.ReduceBase