oracle.spatial.hadoop.vector.join

Class JoinGroupWritable

java.lang.Object

oracle.spatial.hadoop.vector.join.JoinGroupWritable

All Implemented Interfaces:

java.lang.Comparable<JoinGroupWritable>, org.apache.hadoop.io.Writable, org.apache.hadoop.io.WritableComparable<JoinGroupWritable>

public class JoinGroupWritable
extends java.lang.Object
implements org.apache.hadoop.io.WritableComparable<JoinGroupWritable>

Contains the source data set and assigned partition information for a record . It is used as a key once a record from some data set is assigned to a partition.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	EXTRA_FIELD_DS_ID

Constructor Summary

Constructors

Constructor and Description
JoinGroupWritable() Creates a new empty instance
JoinGroupWritable(PartitionInfoWritable partition, int dataSetId, long dataSetLength) Creates a new instance

Method Summary

Methods

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)

Methods inherited from class java.lang.Object

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

Field Detail

EXTRA_FIELD_DS_ID

public static final java.lang.String EXTRA_FIELD_DS_ID

See Also:

Constant Field Values

Constructor Detail

JoinGroupWritable

public JoinGroupWritable()

Creates a new empty instance

JoinGroupWritable

public JoinGroupWritable(PartitionInfoWritable partition,
                         int dataSetId,
                         long dataSetLength)

Creates a new instance

Parameters:

partition - a partition object

dataSetId - a data set id

dataSetLength - the approximate length of the data set

Method Detail

getPartition

public PartitionInfoWritable getPartition()

Gets the partition object containing the partition information

Returns:

setPartition

public void setPartition(PartitionInfoWritable partition)

Sets the partition object containing the partition information

Parameters:

partition -

getDataSetId

public int getDataSetId()

Gets the id of the data set associated to the current partition

Returns:

setDataSetId

public void setDataSetId(int dataSetId)

Sets the id of the data set associated to the current partition

Parameters:

dataSetId -

getDataSetLength

public long getDataSetLength()

Gets the approximate length of the current data set

Returns:

setDataSetLength

public void setDataSetLength(long dataSetLength)

Sets the approximate length of the current data set

Parameters:

dataSetLength -

readFields

public void readFields(java.io.DataInput in)
                throws java.io.IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

java.io.IOException

write

public void write(java.io.DataOutput out)
           throws java.io.IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

java.io.IOException

compareTo

public int compareTo(JoinGroupWritable dsp)

Specified by:

compareTo in interface java.lang.Comparable<JoinGroupWritable>