Package org.apache.druid.timeline.partition

Class PartitionHolder<T extends Overshadowable<T>>

java.lang.Object

org.apache.druid.timeline.partition.PartitionHolder<T>

All Implemented Interfaces:

Iterable<PartitionChunk<T>>

public class PartitionHolder<T extends Overshadowable<T>>
extends Object
implements Iterable<PartitionChunk<T>>

An object that clumps together multiple other objects which each represent a shard of some space.

Constructor Summary

Constructors

Modifier	Constructor	Description
	PartitionHolder(List<PartitionChunk<T>> initialChunks)
protected	PartitionHolder(org.apache.druid.timeline.partition.OvershadowableManager<T> overshadowableManager, short maxMinorVersion)
	PartitionHolder(PartitionChunk<T> initialChunk)

Method Summary

Modifier and Type	Method	Description
boolean	add(PartitionChunk<T> chunk)
static <T extends Overshadowable<T>> PartitionHolder<T>	copyWithOnlyVisibleChunks(PartitionHolder<T> partitionHolder)
static <T extends Overshadowable<T>> PartitionHolder<T>	deepCopy(PartitionHolder<T> partitionHolder)
boolean	equals(Object o)
PartitionChunk<T>	getChunk(int partitionNum)
short	getMaxMinorVersion()	Returns the maximum minor version across all the added segments.
List<PartitionChunk<T>>	getOvershadowed()
boolean	hasData()
int	hashCode()
boolean	isComplete()
boolean	isEmpty()
Iterator<PartitionChunk<T>>	iterator()
Iterable<T>	payloads()
PartitionChunk<T>	remove(PartitionChunk<T> chunk)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

PartitionHolder

public PartitionHolder(PartitionChunk<T> initialChunk)

PartitionHolder

public PartitionHolder(List<PartitionChunk<T>> initialChunks)

PartitionHolder

protected PartitionHolder(org.apache.druid.timeline.partition.OvershadowableManager<T> overshadowableManager,
 short maxMinorVersion)

Method Details

copyWithOnlyVisibleChunks

public static <T extends Overshadowable<T>>
PartitionHolder<T> copyWithOnlyVisibleChunks(PartitionHolder<T> partitionHolder)

deepCopy

public static <T extends Overshadowable<T>>
PartitionHolder<T> deepCopy(PartitionHolder<T> partitionHolder)

add

public boolean add(PartitionChunk<T> chunk)

getMaxMinorVersion

public short getMaxMinorVersion()

Returns the maximum minor version across all the added segments. We do not handle updates of this variable when segments are removed for the sake of simplicity.

remove

@Nullable
public PartitionChunk<T> remove(PartitionChunk<T> chunk)

isEmpty

public boolean isEmpty()

isComplete

public boolean isComplete()

getChunk

public PartitionChunk<T> getChunk(int partitionNum)

iterator

public Iterator<PartitionChunk<T>> iterator()

Specified by:

iterator in interface Iterable<T extends Overshadowable<T>>

getOvershadowed

public List<PartitionChunk<T>> getOvershadowed()

payloads

public Iterable<T> payloads()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

hasData

public boolean hasData()