|
Oracle Fusion Middleware Java API Reference for Oracle Real-Time Decisions 11g Release 1 (11.1.1) E17787-01 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object
com.sigmadynamics.server.DataServices.DatabaseProvider.BatchUpdater
public class BatchUpdater
Field Summary | |
---|---|
protected boolean |
autoFlush |
protected boolean |
autoGrowBuffer |
protected int |
batchCount |
protected int |
batchSize |
protected BatchUpdaterClient |
buClient |
protected static SDCategory |
log |
protected static java.text.NumberFormat |
numberFormat |
protected int |
numberOfPlacemarkers |
protected ValueSetter |
setter |
protected static int |
TYPE_BYTE_ARRAY |
protected static int |
TYPE_DATE |
protected static int |
TYPE_DATECALENDAR |
protected static int |
TYPE_DOUBLE |
protected static int |
TYPE_INPUTSTREAM |
protected static int |
TYPE_INTEGER |
protected static int |
TYPE_LONG |
protected static int |
TYPE_NULL |
protected static int |
TYPE_STRING |
Constructor Summary | |
---|---|
BatchUpdater(DatabaseSettings ds, BatchUpdaterClient owner, int numPlacemarkers, int batchSize, int maxQueueLength, boolean autoFlush, boolean autoGrowBuffer) |
Method Summary | |
---|---|
void |
close() |
int |
discard() For a manual-flush BatchUpdater only, discards all records in the buffer. |
protected void |
finalize() |
void |
flush() |
protected void |
flush(boolean evenWhileClosing) |
protected ValueSetter |
getValueSetter() |
protected void |
incrementPlacemarkers(int n) |
boolean |
isThrottling() Returns the throttling mode. |
void |
operation() Submission of new work. |
protected java.sql.PreparedStatement |
prepareStatement(java.sql.Connection conn) |
void |
saveDateValue(int index, DateWrapper value) |
void |
saveDateValue(int index, long value) |
void |
saveNullValue(int index, int sqlType) |
void |
saveValue(int index, byte[] value) |
void |
saveValue(int index, double value) |
void |
saveValue(int index, java.io.InputStream value, int length) |
void |
saveValue(int index, int value) |
void |
saveValue(int index, long value) |
void |
saveValue(int index, java.lang.String value) |
void |
setBatchSize(int n) |
void |
setThrottling(boolean throttling) Sets throttling mode. |
static void |
shutdown(long totalShutdownTimeoutMSec) Stop all the batch updaters in a controlled manner. |
static void |
start(DatabaseSettings ds, TimerProviderAndJobRunner tpjr) |
protected void |
timedFlush(long now) Flush the buffer if things have been waiting for a given amount of time. |
Methods inherited from class java.lang.Object |
---|
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected static final int TYPE_NULL
protected static final int TYPE_STRING
protected static final int TYPE_DOUBLE
protected static final int TYPE_LONG
protected static final int TYPE_BYTE_ARRAY
protected static final int TYPE_INPUTSTREAM
protected static final int TYPE_DATE
protected static final int TYPE_DATECALENDAR
protected static final int TYPE_INTEGER
protected int batchSize
protected int batchCount
protected BatchUpdaterClient buClient
protected int numberOfPlacemarkers
protected ValueSetter setter
protected final boolean autoFlush
protected final boolean autoGrowBuffer
protected static final SDCategory log
protected static final java.text.NumberFormat numberFormat
Constructor Detail |
---|
public BatchUpdater(DatabaseSettings ds, BatchUpdaterClient owner, int numPlacemarkers, int batchSize, int maxQueueLength, boolean autoFlush, boolean autoGrowBuffer)
Method Detail |
---|
protected ValueSetter getValueSetter()
public boolean isThrottling()
true
if throttling is enabled, otherwise false
.public void setThrottling(boolean throttling)
throttling
- throttling mode.java.lang.IllegalArgumentException
- if the method is called on a synchronous updater with false
as an argument.public void operation()
protected java.sql.PreparedStatement prepareStatement(java.sql.Connection conn)
public void flush()
public int discard()
protected void flush(boolean evenWhileClosing)
public void close()
protected void incrementPlacemarkers(int n)
public void saveValue(int index, java.lang.String value)
public void saveValue(int index, double value)
public void saveValue(int index, long value)
public void saveValue(int index, int value)
public void saveDateValue(int index, long value)
public void saveDateValue(int index, DateWrapper value)
public void saveValue(int index, byte[] value)
public void saveValue(int index, java.io.InputStream value, int length)
public void saveNullValue(int index, int sqlType)
public static void start(DatabaseSettings ds, TimerProviderAndJobRunner tpjr)
public static void shutdown(long totalShutdownTimeoutMSec)
protected void timedFlush(long now)
This method is called by the BatchFlusher. The BatchUpdater will do a flush operation if there have been data in the buffer that has been waiting for a specified amount of time.
now
- the approximate current timeprotected void finalize()
finalize
in class java.lang.Object
public void setBatchSize(int n)
|
Oracle Fusion Middleware Java API Reference for Oracle Real-Time Decisions 11g Release 1 (11.1.1) E17787-01 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |