org.bluedb.disk.segment

Class SegmentBatch<T extends java.io.Serializable>

java.lang.Object

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

public class SegmentBatch<T extends java.io.Serializable>
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
java.util.List<ChunkBatch<T>>	breakIntoChunks(java.util.List<Range> existingChunkRanges, Segment<T> segment)
protected static <T extends java.io.Serializable> Range	chooseSmallestRangeContainingChanges(java.util.List<Range> rangeOptions, java.util.List<IndividualChange<T>> nonEmptyChangeList)
protected static Range	findMatchingRange(java.util.List<Range> options, java.util.Set<Range> ranges)
protected static Range	getLargestEmptyRange(java.util.List<Range> rangeOptions, java.util.Set<Range> existingChunkRanges)
protected static <T extends java.io.Serializable> Range	getNextRangeToUse(java.util.LinkedList<IndividualChange<T>> changeQueue, java.util.Set<Range> existingChunkRanges, Segment<T> segment)
static <T extends java.io.Serializable> java.util.LinkedList<IndividualChange<T>>	pollChangesBeforeOrAt(java.util.LinkedList<IndividualChange<T>> sortedChanges, long maxGroupingNumber)
protected static <T extends java.io.Serializable> boolean	rangeContainsAll(Range range, java.util.List<IndividualChange<T>> changes)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

breakIntoChunks

public java.util.List<ChunkBatch<T>> breakIntoChunks(java.util.List<Range> existingChunkRanges,
                                                     Segment<T> segment)

getNextRangeToUse

protected static <T extends java.io.Serializable> Range getNextRangeToUse(java.util.LinkedList<IndividualChange<T>> changeQueue,
                                                                          java.util.Set<Range> existingChunkRanges,
                                                                          Segment<T> segment)

getLargestEmptyRange

protected static Range getLargestEmptyRange(java.util.List<Range> rangeOptions,
                                            java.util.Set<Range> existingChunkRanges)

chooseSmallestRangeContainingChanges

protected static <T extends java.io.Serializable> Range chooseSmallestRangeContainingChanges(java.util.List<Range> rangeOptions,
                                                                                             java.util.List<IndividualChange<T>> nonEmptyChangeList)

rangeContainsAll

protected static <T extends java.io.Serializable> boolean rangeContainsAll(Range range,
                                                                           java.util.List<IndividualChange<T>> changes)

findMatchingRange

protected static Range findMatchingRange(java.util.List<Range> options,
                                         java.util.Set<Range> ranges)

pollChangesBeforeOrAt

public static <T extends java.io.Serializable> java.util.LinkedList<IndividualChange<T>> pollChangesBeforeOrAt(java.util.LinkedList<IndividualChange<T>> sortedChanges,
                                                                                                               long maxGroupingNumber)