org.apache.lens.cube.metadata.timeline

Class EndsAndHolesPartitionTimeline

java.lang.Object

org.apache.lens.cube.metadata.timeline.PartitionTimeline

org.apache.lens.cube.metadata.timeline.EndsAndHolesPartitionTimeline

All Implemented Interfaces:

Iterable<TimePartition>

public class EndsAndHolesPartitionTimeline
extends PartitionTimeline

One implementation of PartitionTimeline that stores first partition, latest partition and a collection of holes in between them, excluding the edges(start and end values). This is the default Timeline for tables that don't specify which Timeline Class to use in it's params.

Constructor Summary

Constructors

Constructor and Description
EndsAndHolesPartitionTimeline(String storageTableName, UpdatePeriod updatePeriod, String partCol)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	add(TimePartition partition) Add partition to timeline
boolean	drop(TimePartition toDrop) drop partition.
boolean	equals(Object o)
boolean	exists(TimePartition toCheck) Checks partition existance
TimePartition	getFirst()
TreeSet<TimePartition>	getHoles()
TimePartition	getLatest()
int	hashCode()
boolean	initFromProperties(Map<String,String> properties) deserialize member variables from given map
boolean	isConsistent() whether timeline is in consistent state
boolean	isEmpty() Whether No partitions have been registered
Iterator<TimePartition>	iterator()
TimePartition	latest() latest partition.
void	setFirst(TimePartition first)
void	setHoles(TreeSet<TimePartition> holes)
void	setLatest(TimePartition latest)
Map<String,String>	toProperties() serialize member objects as map
String	toString()

Methods inherited from class org.apache.lens.cube.metadata.timeline.PartitionTimeline

add, addForBatchAddition, commitBatchAdditions, getAll, getLatestDate, getPartCol, getStorageTableName, getUpdatePeriod, init, setAll, updateTableParams

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

EndsAndHolesPartitionTimeline

public EndsAndHolesPartitionTimeline(String storageTableName,
                             UpdatePeriod updatePeriod,
                             String partCol)

Method Detail

add

public boolean add(@NonNull
          TimePartition partition)
            throws LensException

Description copied from class: PartitionTimeline

Add partition to timeline

Specified by:

add in class PartitionTimeline

Returns:

whether add was successful

Throws:

LensException

drop

public boolean drop(@NonNull
           TimePartition toDrop)
             throws LensException

Description copied from class: PartitionTimeline

drop partition.

Specified by:

drop in class PartitionTimeline

Returns:

whether drop was successful

Throws:

LensException

latest

public TimePartition latest()

Description copied from class: PartitionTimeline

latest partition. will be null if no partitions exist.

Specified by:

latest in class PartitionTimeline

Returns:

toProperties

public Map<String,String> toProperties()

Description copied from class: PartitionTimeline

serialize member objects as map

Specified by:

toProperties in class PartitionTimeline

Returns:

initFromProperties

public boolean initFromProperties(Map<String,String> properties)
                           throws LensException

Description copied from class: PartitionTimeline

deserialize member variables from given map

Specified by:

initFromProperties in class PartitionTimeline

Returns:

true if after deserializing, the timeline is in consistent state

Throws:

LensException

See Also:

PartitionTimeline.isConsistent()

isEmpty

public boolean isEmpty()

Description copied from class: PartitionTimeline

Whether No partitions have been registered

Specified by:

isEmpty in class PartitionTimeline

Returns:

isConsistent

public boolean isConsistent()

Description copied from class: PartitionTimeline

whether timeline is in consistent state

Specified by:

isConsistent in class PartitionTimeline

Returns:

exists

public boolean exists(TimePartition toCheck)

Description copied from class: PartitionTimeline

Checks partition existance

Specified by:

exists in class PartitionTimeline

Returns:

iterator

public Iterator<TimePartition> iterator()

getFirst

@Generated(value="lombok")
public TimePartition getFirst()

getHoles

@Generated(value="lombok")
public TreeSet<TimePartition> getHoles()

getLatest

@Generated(value="lombok")
public TimePartition getLatest()

setFirst

@Generated(value="lombok")
public void setFirst(TimePartition first)

setHoles

@Generated(value="lombok")
public void setHoles(TreeSet<TimePartition> holes)

setLatest

@Generated(value="lombok")
public void setLatest(TimePartition latest)

equals

@Generated(value="lombok")
public boolean equals(Object o)

Overrides:

equals in class PartitionTimeline

hashCode

@Generated(value="lombok")
public int hashCode()

Overrides:

hashCode in class PartitionTimeline

toString

@Generated(value="lombok")
public String toString()

Overrides:

toString in class PartitionTimeline