com.feedzai.commons.sql.abstraction.batch

Class DefaultBatch

java.lang.Object

com.feedzai.commons.sql.abstraction.batch.AbstractBatch

com.feedzai.commons.sql.abstraction.batch.DefaultBatch

All Implemented Interfaces:

Runnable

public class DefaultBatch
extends AbstractBatch

The default batch implementation.

Behind the scenes, it will periodically flush pending statements. It has auto recovery and will never thrown any exception.

Since:

2.0.0

Author:

Rui Vilao (rui.vilao@feedzai.com)

See Also:

AbstractBatch

Field Summary

Fields inherited from class com.feedzai.commons.sql.abstraction.batch.AbstractBatch

batch, batchSize, batchTimeout, buffer, de, dev, lastFlush, logger, maxAwaitTimeShutdown, name, salt, scheduler

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DefaultBatch(DatabaseEngine de, String name, int batchSize, long batchTimeout, long maxAwaitTimeShutdown) Creates a new instance of DefaultBatch.

Method Summary

Methods

Modifier and Type	Method and Description
static DefaultBatch	create(DatabaseEngine de, String name, int batchSize, long batchTimeout, long maxAwaitTimeShutdown) Creates a new instance of DefaultBatch.

Methods inherited from class com.feedzai.commons.sql.abstraction.batch.AbstractBatch

add, add, destroy, flush, onFlushFailure, run, start

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultBatch

protected DefaultBatch(DatabaseEngine de,
            String name,
            int batchSize,
            long batchTimeout,
            long maxAwaitTimeShutdown)

Creates a new instance of DefaultBatch.

Parameters:

de - The database engine reference.

name - The batch name.

batchSize - The batch size.

batchTimeout - The timeout.

maxAwaitTimeShutdown - The maximum await time for the batch to shutdown.

Method Detail

create

public static DefaultBatch create(DatabaseEngine de,
                  String name,
                  int batchSize,
                  long batchTimeout,
                  long maxAwaitTimeShutdown)

Creates a new instance of DefaultBatch.

Starts the timertask.

Parameters:

de - The database engine.

name - The batch name.

batchSize - The batch size.

batchTimeout - The batch timeout.

maxAwaitTimeShutdown - The maximum await time for the batch to shutdown.

Returns:

The Batch.