Class ResultMergeTaggedMatrixIndexes
- java.lang.Object
-
- org.apache.sysds.runtime.controlprogram.parfor.ResultMergeTaggedMatrixIndexes
-
- All Implemented Interfaces:
Comparable<ResultMergeTaggedMatrixIndexes>,org.apache.hadoop.io.Writable,org.apache.hadoop.io.WritableComparable<ResultMergeTaggedMatrixIndexes>
public class ResultMergeTaggedMatrixIndexes extends Object implements org.apache.hadoop.io.WritableComparable<ResultMergeTaggedMatrixIndexes>
This class serves as composite key for the remote result merge job (for any data format) in order to sort on both matrix indexes and tag but group all blocks according to matrix indexes only. This prevents us from doing an 2pass out-of-core algorithm at the reducer since we can guarantee that the compare block (tag 0) will be the first element in the iterator.
-
-
Constructor Summary
Constructors Constructor Description ResultMergeTaggedMatrixIndexes()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intcompareTo(ResultMergeTaggedMatrixIndexes that)booleanequals(Object other)MatrixIndexesgetIndexes()bytegetTag()inthashCode()voidreadFields(DataInput in)voidsetTag(byte tag)voidwrite(DataOutput out)
-
-
-
Method Detail
-
getIndexes
public MatrixIndexes getIndexes()
-
getTag
public byte getTag()
-
setTag
public void setTag(byte tag)
-
readFields
public void readFields(DataInput in) throws IOException
- Specified by:
readFieldsin interfaceorg.apache.hadoop.io.Writable- Throws:
IOException
-
write
public void write(DataOutput out) throws IOException
- Specified by:
writein interfaceorg.apache.hadoop.io.Writable- Throws:
IOException
-
compareTo
public int compareTo(ResultMergeTaggedMatrixIndexes that)
- Specified by:
compareToin interfaceComparable<ResultMergeTaggedMatrixIndexes>
-
-