Class FlushedScanHandle
- java.lang.Object
-
- org.apache.derby.impl.store.raw.log.FlushedScanHandle
-
- All Implemented Interfaces:
ScanHandle
public class FlushedScanHandle extends java.lang.Object implements ScanHandle
-
-
Field Summary
Fields Modifier and Type Field Description (package private) StreamLogScanfs(package private) intgroupsIWant(package private) LogFactorylf(package private) LogRecordlr(package private) ArrayInputStreamrawInput(package private) booleanreadOptionalData
-
Constructor Summary
Constructors Constructor Description FlushedScanHandle(LogToFile lf, DatabaseInstant start, int groupsIWant)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()Close this scan.intgetGroup()Get the group for the current log record.DatabaseInstantgetInstant()Get the DatabaseInstant for the current log record.LoggablegetLoggable()Get the Loggable associated with the currentLogRecordjava.io.InputStreamgetOptionalData()Get an InputStream for reading the optional data associated with the current log record.java.lang.ObjectgetTransactionId()Get the TransactionId for the current log record.booleannext()Position to the next log record.
-
-
-
Field Detail
-
lf
LogFactory lf
-
fs
StreamLogScan fs
-
lr
LogRecord lr
-
readOptionalData
boolean readOptionalData
-
groupsIWant
int groupsIWant
-
rawInput
ArrayInputStream rawInput
-
-
Constructor Detail
-
FlushedScanHandle
FlushedScanHandle(LogToFile lf, DatabaseInstant start, int groupsIWant) throws StandardException
- Throws:
StandardException
-
-
Method Detail
-
next
public boolean next() throws StandardExceptionDescription copied from interface:ScanHandlePosition to the next log record.- Specified by:
nextin interfaceScanHandle- Returns:
- true if the log contains a next flushed log record and false otherwise. If this returns false it is incorrect to make any of the other calls on this interface.
- Throws:
StandardException- Oops
-
getGroup
public int getGroup() throws StandardExceptionGet the group for the current log record.- Specified by:
getGroupin interfaceScanHandle- Throws:
StandardException- Oops
-
getLoggable
public Loggable getLoggable() throws StandardException
Get the Loggable associated with the currentLogRecord- Specified by:
getLoggablein interfaceScanHandle- Throws:
StandardException- Oops
-
getOptionalData
public java.io.InputStream getOptionalData() throws StandardExceptionDescription copied from interface:ScanHandleGet an InputStream for reading the optional data associated with the current log record. This may only be called once per log record.- Specified by:
getOptionalDatain interfaceScanHandle- Throws:
StandardException- Oops
-
getInstant
public DatabaseInstant getInstant() throws StandardException
Description copied from interface:ScanHandleGet the DatabaseInstant for the current log record.- Specified by:
getInstantin interfaceScanHandle- Throws:
StandardException- Oops
-
getTransactionId
public java.lang.Object getTransactionId() throws StandardExceptionDescription copied from interface:ScanHandleGet the TransactionId for the current log record.- Specified by:
getTransactionIdin interfaceScanHandle- Throws:
StandardException- Oops
-
close
public void close()
Description copied from interface:ScanHandleClose this scan.- Specified by:
closein interfaceScanHandle
-
-