|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectcom.servingxml.components.recordio.AbstractRecordFilter
com.servingxml.components.sql.SqlBatchWriter
public class SqlBatchWriter
| Nested Class Summary |
|---|
| Nested classes/interfaces inherited from interface com.servingxml.components.recordio.RecordWriter |
|---|
RecordWriter.DefaultDiscardWriter, RecordWriter.NullRecordWriter |
| Nested classes/interfaces inherited from interface com.servingxml.components.recordio.RecordReader |
|---|
RecordReader.NullRecordReader |
| Field Summary |
|---|
| Fields inherited from interface com.servingxml.components.recordio.RecordWriter |
|---|
DEFAULT_DISCARD_WRITER, NULL |
| Fields inherited from interface com.servingxml.components.recordio.RecordFilter |
|---|
NULL |
| Constructor Summary | |
|---|---|
SqlBatchWriter(JdbcConnectionPool connectionPool,
SqlBatchUpdateOperation sqlUpdater,
int batchSize)
|
|
| Method Summary | |
|---|---|
void |
close()
|
void |
endRecordStream(ServiceContext context,
Flow flow)
|
void |
startRecordStream(ServiceContext context,
Flow flow)
|
void |
writeRecord(ServiceContext context,
Flow flow)
|
| Methods inherited from class com.servingxml.components.recordio.AbstractRecordFilter |
|---|
discardRecord, getDiscardWriter, getExpirable, getKey, getRecordReader, getRecordWriter, readRecords, setDiscardWriter, setRecordReader, setRecordWriter |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public SqlBatchWriter(JdbcConnectionPool connectionPool,
SqlBatchUpdateOperation sqlUpdater,
int batchSize)
| Method Detail |
|---|
public void startRecordStream(ServiceContext context,
Flow flow)
startRecordStream in interface RecordWriterstartRecordStream in class AbstractRecordFilter
public void endRecordStream(ServiceContext context,
Flow flow)
endRecordStream in interface RecordWriterendRecordStream in class AbstractRecordFilterpublic void close()
close in interface RecordWriterclose in class AbstractRecordFilter
public void writeRecord(ServiceContext context,
Flow flow)
writeRecord in interface RecordWriterwriteRecord in class AbstractRecordFilter
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||