public class JoinGroupWritable
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
EXTRA_FIELD_DS_ID |
| Constructor and Description |
|---|
JoinGroupWritable()
Creates a new empty instance
|
JoinGroupWritable(PartitionInfoWritable partition, int dataSetId, long dataSetLength)
Creates a new instance
|
| Modifier and Type | Method and Description |
|---|---|
int |
compareTo(JoinGroupWritable dsp) |
int |
getDataSetId()
Gets the id of the data set associated to the current partition
|
long |
getDataSetLength()
Gets the approximate length of the current data set
|
PartitionInfoWritable |
getPartition()
Gets the partition object containing the partition information
|
void |
readFields(java.io.DataInput in) |
void |
setDataSetId(int dataSetId)
Sets the id of the data set associated to the current partition
|
void |
setDataSetLength(long dataSetLength)
Sets the approximate length of the current data set
|
void |
setPartition(PartitionInfoWritable partition)
Sets the partition object containing the partition information
|
void |
write(java.io.DataOutput out) |
public static final java.lang.String EXTRA_FIELD_DS_ID
public JoinGroupWritable()
public JoinGroupWritable(PartitionInfoWritable partition, int dataSetId, long dataSetLength)
partition - a partition objectdataSetId - a data set iddataSetLength - the approximate length of the data setpublic int compareTo(JoinGroupWritable dsp)
public int getDataSetId()
public long getDataSetLength()
public PartitionInfoWritable getPartition()
public void readFields(java.io.DataInput in)
throws java.io.IOException
java.io.IOExceptionpublic void setDataSetId(int dataSetId)
dataSetId -public void setDataSetLength(long dataSetLength)
dataSetLength -public void setPartition(PartitionInfoWritable partition)
partition -
public void write(java.io.DataOutput out)
throws java.io.IOException
java.io.IOExceptionCopyright © 2017 Oracle and/or its affiliates. All Rights Reserved.