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 int
compareTo(ResultMergeTaggedMatrixIndexes that)
boolean
equals(Object other)
MatrixIndexes
getIndexes()
byte
getTag()
int
hashCode()
void
readFields(DataInput in)
void
setTag(byte tag)
void
write(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:
readFields
in interfaceorg.apache.hadoop.io.Writable
- Throws:
IOException
-
write
public void write(DataOutput out) throws IOException
- Specified by:
write
in interfaceorg.apache.hadoop.io.Writable
- Throws:
IOException
-
compareTo
public int compareTo(ResultMergeTaggedMatrixIndexes that)
- Specified by:
compareTo
in interfaceComparable<ResultMergeTaggedMatrixIndexes>
-
-