org.bluedb.disk

Class BatchUtils

java.lang.Object

org.bluedb.disk.BatchUtils

public class BatchUtils
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
BatchUtils()

Method Summary

Modifier and Type	Method and Description
static <T extends java.io.Serializable> void	apply(SegmentManager<T> segmentManager, java.util.List<IndividualChange<T>> sortedChanges)
protected static <T extends java.io.Serializable> Segment<T>	getFirstSegmentAffected(SegmentManager<T> segmentManager, java.util.LinkedList<IndividualChange<T>> sortedChanges)
static <T extends java.io.Serializable> java.util.LinkedList<IndividualChange<T>>	pollChangesInSegment(java.util.LinkedList<IndividualChange<T>> sortedChanges, Segment<T> segment)
protected static <T extends java.io.Serializable> void	removeChangesThatEndInOrBeforeSegment(java.util.List<IndividualChange<T>> sortedChanges, Segment<T> segment)

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchUtils

public BatchUtils()

Method Detail

apply

public static <T extends java.io.Serializable> void apply(SegmentManager<T> segmentManager,
                                                          java.util.List<IndividualChange<T>> sortedChanges)
                                                   throws BlueDbException

Throws:

BlueDbException

pollChangesInSegment

public static <T extends java.io.Serializable> java.util.LinkedList<IndividualChange<T>> pollChangesInSegment(java.util.LinkedList<IndividualChange<T>> sortedChanges,
                                                                                                              Segment<T> segment)

getFirstSegmentAffected

protected static <T extends java.io.Serializable> Segment<T> getFirstSegmentAffected(SegmentManager<T> segmentManager,
                                                                                     java.util.LinkedList<IndividualChange<T>> sortedChanges)

removeChangesThatEndInOrBeforeSegment

protected static <T extends java.io.Serializable> void removeChangesThatEndInOrBeforeSegment(java.util.List<IndividualChange<T>> sortedChanges,
                                                                                             Segment<T> segment)