org.apache.hadoop.chukwa

Class ChukwaArchiveKey

java.lang.Object

org.apache.hadoop.record.Record

org.apache.hadoop.chukwa.ChukwaArchiveKey

All Implemented Interfaces:

Cloneable, Comparable, org.apache.hadoop.io.Writable, org.apache.hadoop.io.WritableComparable

public class ChukwaArchiveKey
extends org.apache.hadoop.record.Record

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ChukwaArchiveKey.Comparator

Constructor Summary

Constructors

Constructor and Description
ChukwaArchiveKey()
ChukwaArchiveKey(long timePartition, String dataType, String streamName, long seqId)

Method Summary

Methods

Modifier and Type	Method and Description
Object	clone()
int	compareTo(Object _rio_peer_)
void	deserialize(org.apache.hadoop.record.RecordInput _rio_a, String _rio_tag)
boolean	equals(Object _rio_peer_)
String	getDataType()
long	getSeqId()
String	getStreamName()
long	getTimePartition()
static org.apache.hadoop.record.meta.RecordTypeInfo	getTypeInfo()
int	hashCode()
void	serialize(org.apache.hadoop.record.RecordOutput _rio_a, String _rio_tag)
void	setDataType(String dataType)
void	setSeqId(long seqId)
void	setStreamName(String streamName)
void	setTimePartition(long timePartition)
static void	setTypeFilter(org.apache.hadoop.record.meta.RecordTypeInfo rti)
static String	signature()

Methods inherited from class org.apache.hadoop.record.Record

deserialize, readFields, serialize, toString, write

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ChukwaArchiveKey

public ChukwaArchiveKey()

ChukwaArchiveKey

public ChukwaArchiveKey(long timePartition,
                String dataType,
                String streamName,
                long seqId)

Method Detail

getTypeInfo

public static org.apache.hadoop.record.meta.RecordTypeInfo getTypeInfo()

setTypeFilter

public static void setTypeFilter(org.apache.hadoop.record.meta.RecordTypeInfo rti)

getTimePartition

public long getTimePartition()

setTimePartition

public void setTimePartition(long timePartition)

getDataType

public String getDataType()

setDataType

public void setDataType(String dataType)

getStreamName

public String getStreamName()

setStreamName

public void setStreamName(String streamName)

getSeqId

public long getSeqId()

setSeqId

public void setSeqId(long seqId)

serialize

public void serialize(org.apache.hadoop.record.RecordOutput _rio_a,
             String _rio_tag)
               throws IOException

Specified by:

serialize in class org.apache.hadoop.record.Record

Throws:

IOException

deserialize

public void deserialize(org.apache.hadoop.record.RecordInput _rio_a,
               String _rio_tag)
                 throws IOException

Specified by:

deserialize in class org.apache.hadoop.record.Record

Throws:

IOException

compareTo

public int compareTo(Object _rio_peer_)
              throws ClassCastException

Specified by:

compareTo in interface Comparable

Specified by:

compareTo in class org.apache.hadoop.record.Record

Throws:

ClassCastException

equals

public boolean equals(Object _rio_peer_)

Overrides:

equals in class Object

clone

public Object clone()
             throws CloneNotSupportedException

Overrides:

clone in class Object

Throws:

CloneNotSupportedException

hashCode

public int hashCode()

Overrides:

hashCode in class Object

signature

public static String signature()