public abstract class ManagerBase extends Object
Modifier and Type | Field and Description |
---|---|
static int |
BATCH_SIZE |
static int |
MAX_QUEUE |
static int |
MIN_QUEUE |
BlockingQueue<Batch> |
queue |
Constructor and Description |
---|
ManagerBase() |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
void |
close() |
void |
flush() |
protected void |
flush(Batch batch) |
BlockingQueue<Batch> |
getQueue() |
protected void |
optimize() |
public static int BATCH_SIZE
public static int MIN_QUEUE
public static int MAX_QUEUE
public final BlockingQueue<Batch> queue
public BlockingQueue<Batch> getQueue()
public void close() throws SQLException
SQLException
public void flush() throws SQLException, InterruptedException
SQLException
InterruptedException
public void clear()
protected void optimize() throws SQLException
SQLException
protected void flush(Batch batch) throws SQLException
SQLException
Copyright © 2001-2016 Aduna. All Rights Reserved.