io.druid.indexer

Class Bucket

java.lang.Object

io.druid.indexer.Bucket

public class Bucket
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
int	partitionNum Partition number of this bucket within our time window (other Buckets may occupy the same window).
static int	PREAMBLE_BYTES
org.joda.time.DateTime	time Start time of this bucket's time window.

Constructor Summary

Constructors

Constructor and Description
Bucket(int shardNum, org.joda.time.DateTime time, int partitionNum)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
static Pair<Bucket,byte[]>	fromGroupKey(byte[] keyBytes)
protected int	getShardNum()
int	hashCode()
byte[]	toGroupKey(byte[]... parts)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

PREAMBLE_BYTES

public static final int PREAMBLE_BYTES

See Also:

Constant Field Values

time

public final org.joda.time.DateTime time

Start time of this bucket's time window. End time can be determined by our GranularitySpec.

partitionNum

public final int partitionNum

Partition number of this bucket within our time window (other Buckets may occupy the same window).

Constructor Detail

Bucket

public Bucket(int shardNum,
              org.joda.time.DateTime time,
              int partitionNum)

Method Detail

toGroupKey

public byte[] toGroupKey(byte[]... parts)

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

fromGroupKey

public static final Pair<Bucket,byte[]> fromGroupKey(byte[] keyBytes)

getShardNum

protected int getShardNum()