public class StoreAllPartitionTimeline extends PartitionTimeline
Constructor and Description |
---|
StoreAllPartitionTimeline(String storageTableName,
UpdatePeriod updatePeriod,
String partCol) |
Modifier and Type | Method and Description |
---|---|
boolean |
add(Collection<TimePartition> partitions)
Add multiple partitions to timeline
|
boolean |
add(TimePartition partition)
Add partition to timeline
|
boolean |
drop(TimePartition toDrop)
drop partition.
|
boolean |
equals(Object o) |
boolean |
exists(TimePartition partition)
Checks partition existance
|
TreeSet<TimePartition> |
getAllPartitions() |
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 |
setAllPartitions(TreeSet<TimePartition> allPartitions) |
Map<String,String> |
toProperties()
serialize member objects as map
|
String |
toString() |
addForBatchAddition, commitBatchAdditions, getAll, getLatestDate, getPartCol, getStorageTableName, getUpdatePeriod, init, setAll, updateTableParams
public StoreAllPartitionTimeline(String storageTableName, UpdatePeriod updatePeriod, String partCol)
public boolean add(@NonNull TimePartition partition) throws LensException
PartitionTimeline
add
in class PartitionTimeline
LensException
public boolean add(@NonNull Collection<TimePartition> partitions) throws LensException
PartitionTimeline
add
in class PartitionTimeline
LensException
public boolean drop(@NonNull TimePartition toDrop) throws LensException
PartitionTimeline
drop
in class PartitionTimeline
LensException
public TimePartition latest()
PartitionTimeline
latest
in class PartitionTimeline
public Map<String,String> toProperties()
PartitionTimeline
toProperties
in class PartitionTimeline
public boolean initFromProperties(Map<String,String> properties) throws LensException
PartitionTimeline
initFromProperties
in class PartitionTimeline
LensException
PartitionTimeline.isConsistent()
public boolean isEmpty()
PartitionTimeline
isEmpty
in class PartitionTimeline
public boolean isConsistent()
PartitionTimeline
isConsistent
in class PartitionTimeline
public boolean exists(TimePartition partition)
PartitionTimeline
exists
in class PartitionTimeline
public Iterator<TimePartition> iterator()
@Generated(value="lombok") public TreeSet<TimePartition> getAllPartitions()
@Generated(value="lombok") public void setAllPartitions(TreeSet<TimePartition> allPartitions)
@Generated(value="lombok") public boolean equals(Object o)
equals
in class PartitionTimeline
@Generated(value="lombok") public int hashCode()
hashCode
in class PartitionTimeline
@Generated(value="lombok") public String toString()
toString
in class PartitionTimeline
Copyright © 2014–2016 Apache Software Foundation. All rights reserved.