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
SQLExceptionpublic void flush()
throws SQLException,
InterruptedException
SQLExceptionInterruptedExceptionpublic void clear()
protected void optimize()
throws SQLException
SQLExceptionprotected void flush(Batch batch) throws SQLException
SQLExceptionCopyright © 2001–2015 Aduna. All rights reserved.