ScanManager, GenericScanController, GroupFetchScanController, RowCountable, ScanController, ScanInfoMergeScanRowSourcepublic class MergeScan extends SortScan
| Modifier and Type | Field | Description |
|---|---|---|
protected java.util.Vector<java.lang.Long> |
mergeRuns |
The merge runs.
|
protected StreamContainerHandle[] |
openScans |
Array of scan controllers for the merge runs.
|
protected SortBuffer |
sortBuffer |
The sort buffer we will use.
|
private SortObserver |
sortObserver |
GE, GT, NA| Constructor | Description |
|---|---|
MergeScan(MergeSort sort,
TransactionManager tran,
SortBuffer sortBuffer,
java.util.Vector<java.lang.Long> mergeRuns,
SortObserver sortObserver,
boolean hold) |
| Modifier and Type | Method | Description |
|---|---|---|
void |
close() |
Close the scan.
|
boolean |
closeForEndTransaction(boolean closeHeldScan) |
Close the scan.
|
boolean |
init(TransactionManager tran) |
Initialize the scan, returning false if there
was some error.
|
(package private) void |
mergeARow(int scanindex) |
Insert rows while we keep getting duplicates
from the merge run whose scan is in the
open scan array entry indexed by scanindex.
|
boolean |
next() |
Move to the next position in the scan.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitdelete, didNotQualify, doesCurrentPositionQualify, fetchLocation, fetchNextGroup, fetchNextGroup, fetchSet, getAllScanInfo, getEstimatedRowCount, getScanInfo, isCurrentPositionDeleted, isHeldAfterCommit, isKeyed, isTableLocked, newRowLocationTemplate, positionAtRowLocation, reopenScan, reopenScanByRowLocation, replace, setEstimatedRowCountfetch, fetchNext, fetchWithoutQualifyprotected SortBuffer sortBuffer
protected java.util.Vector<java.lang.Long> mergeRuns
protected StreamContainerHandle[] openScans
private SortObserver sortObserver
MergeScan(MergeSort sort, TransactionManager tran, SortBuffer sortBuffer, java.util.Vector<java.lang.Long> mergeRuns, SortObserver sortObserver, boolean hold)
public boolean next()
throws StandardException
StandardException - Standard exception policy.ScanController.next()public void close()
close in interface GenericScanControllerclose in class SortScanGenericScanController.close()public boolean closeForEndTransaction(boolean closeHeldScan)
closeHeldScan - If true, means to close scan even if it has been
opened to be kept opened across commit. This is
used to close these scans on abort.ScanManager.closeForEndTransaction(boolean)public boolean init(TransactionManager tran) throws StandardException
StandardExceptionvoid mergeARow(int scanindex)
throws StandardException
StandardExceptionApache Derby V10.14 Internals - Copyright © 2004,2018 The Apache Software Foundation. All Rights Reserved.