org.eclipse.smila.bulkbuilder.helper
Class MicroBulkbuilder

java.lang.Object
  org.eclipse.smila.bulkbuilder.helper.MicroBulkbuilder

public class MicroBulkbuilder
extends java.lang.Object

Helper for creating and administrating micro bulks.

Constructor Summary

MicroBulkbuilder(long limitOfParallelBulks)

Method Summary

void	addToMicroBulk(java.lang.String microBulkId, Record record) add record to the micro bulk identified by the given id.
byte[]	finishMicroBulk(java.lang.String microBulkId) This also removes the micro bulk and its counter entry.
java.lang.Integer	getNumberOfRecords(java.lang.String microBulkId) Returns number of records for given micro bulk id.

Methods inherited from class java.lang.Object

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

Constructor Detail

MicroBulkbuilder

public MicroBulkbuilder(long limitOfParallelBulks)

Parameters:

limitOfParallelBulks - the maximum number of parallel micro bulks to process. (-1 = unlimited)

Method Detail

addToMicroBulk

public void addToMicroBulk(java.lang.String microBulkId,
                           Record record)
                    throws BulkbuilderException

add record to the micro bulk identified by the given id.

Throws:

BulkbuilderException

finishMicroBulk

public byte[] finishMicroBulk(java.lang.String microBulkId)

This also removes the micro bulk and its counter entry.

Returns:

the micro bulk that was finished with this call.

getNumberOfRecords

public java.lang.Integer getNumberOfRecords(java.lang.String microBulkId)

Returns number of records for given micro bulk id.

Parameters:

microBulkId - The micro bulk id