|
|||||||||
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 RecordWriter
startRecordStream
in class AbstractRecordFilter
public void endRecordStream(ServiceContext context, Flow flow)
endRecordStream
in interface RecordWriter
endRecordStream
in class AbstractRecordFilter
public void close()
close
in interface RecordWriter
close
in class AbstractRecordFilter
public void writeRecord(ServiceContext context, Flow flow)
writeRecord
in interface RecordWriter
writeRecord
in class AbstractRecordFilter
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |