Class BufferedRecordPipe

java.lang.Object

com.kingsrook.qqq.backend.core.actions.reporting.RecordPipe

com.kingsrook.qqq.backend.core.actions.reporting.BufferedRecordPipe

Direct Known Subclasses:

RecordPipeBufferedWrapper

public class BufferedRecordPipe
extends RecordPipe

Subclass of RecordPipe, which uses a buffer in the addRecord method, to avoid sending single-records at a time through postRecordActions and to consumers.

Field Summary

Fields

Modifier and Type	Field	Description
protected List<QRecord>	buffer

Constructor Summary

Constructors

Constructor	Description
BufferedRecordPipe()	Constructor - uses default buffer size
BufferedRecordPipe(Integer bufferSize)	Constructor - customize buffer size.

Method Summary

Modifier and Type	Method	Description
void	addRecord(QRecord record)	Add a record to the pipe.
void	addRecords(List<QRecord> records)	Add a list of records to the pipe.
void	finalFlush()
protected void	flush()

Methods inherited from class com.kingsrook.qqq.backend.core.actions.reporting.RecordPipe

consumeAvailableRecords, countAvailableRecords, getCapacity, getTotalRecordCount, setPostRecordActions, terminate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

buffer

protected List<QRecord> buffer

Constructor Details

BufferedRecordPipe

public BufferedRecordPipe()

Constructor - uses default buffer size

BufferedRecordPipe

public BufferedRecordPipe(Integer bufferSize)

Constructor - customize buffer size.

Method Details

addRecord

public void addRecord(QRecord record)
               throws QException

Description copied from class: RecordPipe

Add a record to the pipe. Will block if the pipe is full. Will noop if pipe is terminated.

Overrides:

addRecord in class RecordPipe

Throws:

QException

addRecords

public void addRecords(List<QRecord> records)
                throws QException

Description copied from class: RecordPipe

Add a list of records to the pipe. Will block if the pipe is full. Will noop if pipe is terminated.

Overrides:

addRecords in class RecordPipe

Throws:

QException

flush

protected void flush()
              throws QException

Throws:

QException

finalFlush

public void finalFlush()
                throws QException

Throws:

QException