org.bluedb.disk.segment

Class Segment<T extends java.io.Serializable>

java.lang.Object

org.bluedb.disk.segment.Segment<T>

All Implemented Interfaces:

java.lang.Comparable<Segment<T>>

public class Segment<T extends java.io.Serializable>
extends java.lang.Object
implements java.lang.Comparable<Segment<T>>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Segment()
	Segment(java.nio.file.Path segmentPath, Range segmentRange, Rollupable rollupable, FileManager fileManager, java.util.List<java.lang.Long> rollupLevels)

Method Summary

Modifier and Type	Method and Description
void	applyChanges(java.util.LinkedList<IndividualChange<T>> changeQueueForSegment)
java.util.List<Range>	calculatePossibleChunkRanges(long groupingNumber)
int	compareTo(Segment<T> other)
boolean	contains(BlueKey key)
void	delete(BlueKey key)
static java.util.List<Range>	determineRangesRequiringRollup(java.util.List<Range> existingChunkRanges, long minimumChunkSize)
boolean	equals(java.lang.Object obj)
protected java.util.List<java.io.File>	filterAndDeleteEmptyFiles(java.util.List<java.io.File> orderedFiles)
T	get(BlueKey key)
protected static <T extends java.io.Serializable> T	get(BlueKey key, BlueObjectInput<BlueEntity<T>> inputStream)
static java.util.List<Range>	getAllFileRangesInOrder(java.nio.file.Path segmentPath)
SegmentEntityIterator<T>	getIterator(long min, long max)
SegmentEntityIterator<T>	getIterator(long highestGroupingNumberCompleted, long rangeMin, long rangeMax)
SegmentEntityIterator<T>	getIterator(long highestGroupingNumberCompleted, Range range)
long	getMinimumRollupSizeBeforeBatch()
protected BlueObjectInput<BlueEntity<T>>	getObjectInputFor(long groupingNumber)
protected BlueObjectInput<BlueEntity<T>>	getObjectInputFor(java.nio.file.Path path)
protected BlueObjectOutput<BlueEntity<T>>	getObjectOutputFor(java.nio.file.Path path)
java.util.List<java.io.File>	getOrderedFilesEnclosedInRange(Range range)
java.util.List<java.io.File>	getOrderedFilesInRange(Range range)
java.nio.file.Path	getPath()
Range	getRange()
BlueReadLock<java.nio.file.Path>	getReadLockFor(long groupingNumber)
protected java.util.List<Range>	getRollupRanges(Range currentChunkRange)
protected java.util.List<RollupTarget>	getRollupTargets(Range currentChunkRange)
protected static <T extends java.io.Serializable> Segment<T>	getTestSegment()
int	hashCode()
void	insert(BlueKey newKey, T newValue)
boolean	isValidRollupRange(Range timeRange)
void	modifyChunk(long groupingNumber, StreamingWriter<T> processor)
void	modifyChunk(java.nio.file.Path targetPath, StreamingWriter<T> processor)
protected void	reportRead(java.nio.file.Path path)
protected void	reportWrite(java.nio.file.Path path)
void	rollup(Range timeRange)
protected RollupTarget	toRollupTarget(Range range)
java.lang.String	toString()
void	update(BlueKey newKey, T newValue)

Methods inherited from class java.lang.Object

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

Constructor Detail

Segment

public Segment(java.nio.file.Path segmentPath,
               Range segmentRange,
               Rollupable rollupable,
               FileManager fileManager,
               java.util.List<java.lang.Long> rollupLevels)

Segment

protected Segment()

Method Detail

getTestSegment

protected static <T extends java.io.Serializable> Segment<T> getTestSegment()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

contains

public boolean contains(BlueKey key)
                 throws BlueDbException

Throws:

BlueDbException

update

public void update(BlueKey newKey,
                   T newValue)
            throws BlueDbException

Throws:

BlueDbException

insert

public void insert(BlueKey newKey,
                   T newValue)
            throws BlueDbException

Throws:

BlueDbException

delete

public void delete(BlueKey key)
            throws BlueDbException

Throws:

BlueDbException

modifyChunk

public void modifyChunk(long groupingNumber,
                        StreamingWriter<T> processor)
                 throws BlueDbException

Throws:

BlueDbException

get

public T get(BlueKey key)
      throws BlueDbException

Throws:

BlueDbException

getRange

public Range getRange()

getIterator

public SegmentEntityIterator<T> getIterator(long highestGroupingNumberCompleted,
                                            Range range)

getIterator

public SegmentEntityIterator<T> getIterator(long highestGroupingNumberCompleted,
                                            long rangeMin,
                                            long rangeMax)

getIterator

public SegmentEntityIterator<T> getIterator(long min,
                                            long max)

applyChanges

public void applyChanges(java.util.LinkedList<IndividualChange<T>> changeQueueForSegment)
                  throws BlueDbException

Throws:

BlueDbException

getMinimumRollupSizeBeforeBatch

public long getMinimumRollupSizeBeforeBatch()

determineRangesRequiringRollup

public static java.util.List<Range> determineRangesRequiringRollup(java.util.List<Range> existingChunkRanges,
                                                                   long minimumChunkSize)

modifyChunk

public void modifyChunk(java.nio.file.Path targetPath,
                        StreamingWriter<T> processor)
                 throws BlueDbException

Throws:

BlueDbException

rollup

public void rollup(Range timeRange)
            throws BlueDbException

Throws:

BlueDbException

filterAndDeleteEmptyFiles

protected java.util.List<java.io.File> filterAndDeleteEmptyFiles(java.util.List<java.io.File> orderedFiles)

isValidRollupRange

public boolean isValidRollupRange(Range timeRange)

getAllFileRangesInOrder

public static java.util.List<Range> getAllFileRangesInOrder(java.nio.file.Path segmentPath)

getOrderedFilesEnclosedInRange

public java.util.List<java.io.File> getOrderedFilesEnclosedInRange(Range range)

getOrderedFilesInRange

public java.util.List<java.io.File> getOrderedFilesInRange(Range range)

getObjectOutputFor

protected BlueObjectOutput<BlueEntity<T>> getObjectOutputFor(java.nio.file.Path path)
                                                      throws BlueDbException

Throws:

BlueDbException

getObjectInputFor

protected BlueObjectInput<BlueEntity<T>> getObjectInputFor(java.nio.file.Path path)
                                                    throws BlueDbException

Throws:

BlueDbException

getObjectInputFor

protected BlueObjectInput<BlueEntity<T>> getObjectInputFor(long groupingNumber)
                                                    throws BlueDbException

Throws:

BlueDbException

getReadLockFor

public BlueReadLock<java.nio.file.Path> getReadLockFor(long groupingNumber)
                                                throws BlueDbException

Throws:

BlueDbException

getPath

public java.nio.file.Path getPath()

reportWrite

protected void reportWrite(java.nio.file.Path path)

reportRead

protected void reportRead(java.nio.file.Path path)

getRollupTargets

protected java.util.List<RollupTarget> getRollupTargets(Range currentChunkRange)

toRollupTarget

protected RollupTarget toRollupTarget(Range range)

getRollupRanges

protected java.util.List<Range> getRollupRanges(Range currentChunkRange)

calculatePossibleChunkRanges

public java.util.List<Range> calculatePossibleChunkRanges(long groupingNumber)

get

protected static <T extends java.io.Serializable> T get(BlueKey key,
                                                        BlueObjectInput<BlueEntity<T>> inputStream)

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

compareTo

public int compareTo(Segment<T> other)

Specified by:

compareTo in interface java.lang.Comparable<Segment<T extends java.io.Serializable>>