org.eclipse.smila.bulkbuilder.internal

Class Bulkbuilder

java.lang.Object

org.eclipse.smila.bulkbuilder.helper.BulkbuilderBase

org.eclipse.smila.bulkbuilder.internal.Bulkbuilder

All Implemented Interfaces:

BulkTrackerCallback

public class Bulkbuilder
extends BulkbuilderBase

BulkBuilder implementation. Creates bulks from the pushed records on a time and size limit.

Constructor Summary

Constructors

Constructor and Description
Bulkbuilder(BulkbuilderConfig config, ObjectStoreService objectStore, BulkbuilderTaskProvider taskProvider) Creates a new BulkBuilder instance.

Method Summary

Methods

Modifier and Type	Method and Description
protected long	getBulkSizeLimit(BulkType bulkType, AnyMap taskParameters)
protected long	getCommitTimeoutMillis(AnyMap taskParameters)

Methods inherited from class org.eclipse.smila.bulkbuilder.helper.BulkbuilderBase

addRecord, addResultCounters, addToMicroBulk, checkBulks, commitBulk, createBulk, deleteRecord, finishMicroBulk, getActiveBulk, getBulkInfo, getMicroBulkbuilder, getObjectStore, getResultCounters, getTaskProvider, removeMicroBulk, setActiveBulk, shutdown, writeMicroBulkWithRetry, writeRecordWithRetry

Methods inherited from class java.lang.Object

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

Constructor Detail

Bulkbuilder

public Bulkbuilder(BulkbuilderConfig config,
           ObjectStoreService objectStore,
           BulkbuilderTaskProvider taskProvider)
            throws BlackboardAccessException

Creates a new BulkBuilder instance.

Parameters:

objectStore - a reference to the objectStore the object store service.

taskProvider - the task provider that generates tasks for the bulkbuilder

Throws:

BlackboardAccessException - cannot access blackboard

Method Detail

getCommitTimeoutMillis

protected long getCommitTimeoutMillis(AnyMap taskParameters)

Specified by:

getCommitTimeoutMillis in class BulkbuilderBase

Returns:

the timeout for committing bulks either from task parameter or from bulkbuilder configuration for bulk mode.

getBulkSizeLimit

protected long getBulkSizeLimit(BulkType bulkType,
                    AnyMap taskParameters)

Specified by:

getBulkSizeLimit in class BulkbuilderBase

Returns:

the maximum bulk size either from task parameter or from bulkbuilder configuration.