public class SegmentBatch<T extends java.io.Serializable>
extends java.lang.Object
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> |
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> |
getNextRangeToUse(java.util.LinkedList<IndividualChange<T>> changeQueue,
java.util.Set<Range> existingChunkRanges,
Segment<T> segment) |
static <T extends java.io.Serializable> |
pollChangesBeforeOrAt(java.util.LinkedList<IndividualChange<T>> sortedChanges,
long maxGroupingNumber) |
protected static <T extends java.io.Serializable> |
rangeContainsAll(Range range,
java.util.List<IndividualChange<T>> changes) |
public java.util.List<ChunkBatch<T>> breakIntoChunks(java.util.List<Range> existingChunkRanges, Segment<T> segment)
protected static <T extends java.io.Serializable> Range getNextRangeToUse(java.util.LinkedList<IndividualChange<T>> changeQueue, java.util.Set<Range> existingChunkRanges, Segment<T> segment)
protected static Range getLargestEmptyRange(java.util.List<Range> rangeOptions, java.util.Set<Range> existingChunkRanges)
protected static <T extends java.io.Serializable> Range chooseSmallestRangeContainingChanges(java.util.List<Range> rangeOptions, java.util.List<IndividualChange<T>> nonEmptyChangeList)
protected static <T extends java.io.Serializable> boolean rangeContainsAll(Range range, java.util.List<IndividualChange<T>> changes)
protected static Range findMatchingRange(java.util.List<Range> options, java.util.Set<Range> ranges)
public static <T extends java.io.Serializable> java.util.LinkedList<IndividualChange<T>> pollChangesBeforeOrAt(java.util.LinkedList<IndividualChange<T>> sortedChanges, long maxGroupingNumber)