org.apache.nifi.serialization.record

Class PushBackRecordSet

java.lang.Object

org.apache.nifi.serialization.record.PushBackRecordSet

All Implemented Interfaces:

RecordSet

public class PushBackRecordSet
extends java.lang.Object
implements RecordSet

Constructor Summary

Constructors

Constructor and Description
PushBackRecordSet(RecordSet original)

Method Summary

Modifier and Type	Method and Description
RecordSchema	getSchema()
boolean	isAnotherRecord()
Record	next()
void	pushback(Record record)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.nifi.serialization.record.RecordSet

limit, of

Constructor Detail

PushBackRecordSet

public PushBackRecordSet(RecordSet original)

Method Detail

getSchema

public RecordSchema getSchema()
                       throws java.io.IOException

Specified by:

getSchema in interface RecordSet

Returns:

the RecordSchema that applies to the records in this RecordSet

Throws:

java.io.IOException

next

public Record next()
            throws java.io.IOException

Specified by:

next in interface RecordSet

Returns:

the next Record in the set or null if there are no more records

Throws:

java.io.IOException

pushback

public void pushback(Record record)

isAnotherRecord

public boolean isAnotherRecord()
                        throws java.io.IOException

Throws:

java.io.IOException