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.IOException
public 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.IOException
Copyright © 2017 Oracle and/or its affiliates. All Rights Reserved.