Top Description Fields Constructors Methods
org.apache.derby.impl.store.access.sort

public Class MergeScanRowSource

extends MergeScan
implements ScanControllerRowSource
Class Inheritance
All Implemented Interfaces
org.apache.derby.iapi.store.access.conglomerate.ScanControllerRowSource, org.apache.derby.iapi.store.access.RowLocationRetRowSource, org.apache.derby.iapi.store.access.RowSource, org.apache.derby.iapi.store.access.ScanController, org.apache.derby.iapi.store.access.GenericScanController, org.apache.derby.iapi.store.access.RowCountable
Imports
org.apache.derby.shared.common.reference.SQLState, org.apache.derby.iapi.services.io.FormatableBitSet, org.apache.derby.shared.common.sanity.SanityManager, org.apache.derby.shared.common.error.StandardException, org.apache.derby.iapi.store.access.conglomerate.ScanControllerRowSource, .TransactionManager, org.apache.derby.iapi.store.access.SortObserver, .RowLocationRetRowSource, org.apache.derby.iapi.types.DataValueDescriptor, .RowLocation, java.util.Vector

Wrapping the output of a MergeScan in a RowSource for the benefit of the createAndLoadConglomerate and loadConglomerate interface. The output of a MergeScan is written to a file when we need more than one level of merge runs. MergeScan implements ScanController, this class just implements the RowSource interface.

Field Summary

Inherited from org.apache.derby.impl.store.access.sort.MergeScan:
mergeRunsopenScanssortBuffer

Constructor Summary

AccessConstructor and Description
pack-priv
MergeScanRowSource(MergeSort sort, TransactionManager tran, SortBuffer sortBuffer, Vector<Long> mergeRuns, SortObserver sortObserver, boolean hold)

Method Summary

Modifier and TypeMethod and Description
public void
closeRowSource()

Implements org.apache.derby.iapi.store.access.RowSource.closeRowSource.

Close the row source - implemented by MergeScan already

public DataValueDescriptor[]
getNextRowFromRowSource()

Implements org.apache.derby.iapi.store.access.RowSource.getNextRowFromRowSource.

Get the next row as an array of column objects.

public FormatableBitSet
getValidColumns()

Implements org.apache.derby.iapi.store.access.RowSource.getValidColumns.

All columns are always set from a sorter

public boolean
needsRowLocation()

Implements org.apache.derby.iapi.store.access.RowLocationRetRowSource.needsRowLocation.

needsRowLocation returns true iff this the row source expects the drainer of the row source to call rowLocation after getting a row from getNextRowFromRowSource.

public boolean
public boolean
needsToClone()

Implements org.apache.derby.iapi.store.access.RowSource.needsToClone.

Does the caller of getNextRowFromRowSource() need to clone the row in order to keep a reference to the row past the getNextRowFromRowSource() call which returned the row.

public boolean
public void
public void
rowLocation(RowLocation rl)

Implements org.apache.derby.iapi.store.access.RowLocationRetRowSource.rowLocation.

rowLocation is a callback for the drainer of the row source to return the rowLocation of the current row, i.e, the row that is being returned by getNextRowFromRowSource.

Inherited from org.apache.derby.impl.store.access.sort.MergeScan:
closecloseForEndTransactioninitmergeARow

Constructor Detail

MergeScanRowSourceback to summary
pack-priv MergeScanRowSource(MergeSort sort, TransactionManager tran, SortBuffer sortBuffer, Vector<Long> mergeRuns, SortObserver sortObserver, boolean hold)

Method Detail

closeRowSourceback to summary
public void closeRowSource()

Implements org.apache.derby.iapi.store.access.RowSource.closeRowSource.

Close the row source - implemented by MergeScan already

getNextRowFromRowSourceback to summary
public DataValueDescriptor[] getNextRowFromRowSource() throws StandardException

Implements org.apache.derby.iapi.store.access.RowSource.getNextRowFromRowSource.

Doc from org.apache.derby.iapi.store.access.RowSource.getNextRowFromRowSource.

Get the next row as an array of column objects. The column objects can be a JBMS Storable or any Serializable/Externalizable/Formattable/Streaming type.
A return of null indicates that the complete set of rows has been read.

A null column can be specified by leaving the object null, or indicated by returning a non-null getValidColumns. On streaming columns, it can be indicated by returning a non-null get FieldStates.

If RowSource.needToClone() is true then the returned row (the DataValueDescriptor[]) is guaranteed not to be modified by drainer of the RowSource (except that the input stream will be read, of course) and drainer will keep no reference to it before making the subsequent nextRow call. So it is safe to return the same DataValueDescriptor[] in subsequent nextRow calls if that is desirable for performance reasons.

If RowSource.needToClone() is false then the returned row (the DataValueDescriptor[]) may be be modified by drainer of the RowSource, and the drainer may keep a reference to it after making the subsequent nextRow call. In this case the client should severe all references to the row after returning it from getNextRowFromRowSource().

Exceptions
StandardException:
Standard Derby Error Policy
getValidColumnsback to summary
public FormatableBitSet getValidColumns()

Implements org.apache.derby.iapi.store.access.RowSource.getValidColumns.

All columns are always set from a sorter

needsRowLocationback to summary
public boolean needsRowLocation()

Implements org.apache.derby.iapi.store.access.RowLocationRetRowSource.needsRowLocation.

Doc from org.apache.derby.iapi.store.access.RowLocationRetRowSource.needsRowLocation.

needsRowLocation returns true iff this the row source expects the drainer of the row source to call rowLocation after getting a row from getNextRowFromRowSource.

Returns:boolean

true iff this row source expects some row location to be returned

See Also
RowLocationRetRowSource#needsRowLocation
needsRowLocationForDeferredCheckConstraintsback to summary
public boolean needsRowLocationForDeferredCheckConstraints()

Implements org.apache.derby.iapi.store.access.RowLocationRetRowSource.needsRowLocationForDeferredCheckConstraints.

needsToCloneback to summary
public boolean needsToClone()

Implements org.apache.derby.iapi.store.access.RowSource.needsToClone.

Doc from org.apache.derby.iapi.store.access.RowSource.needsToClone.

Does the caller of getNextRowFromRowSource() need to clone the row in order to keep a reference to the row past the getNextRowFromRowSource() call which returned the row. This call must always return the same for all rows in a RowSource (ie. the caller will call this once per scan from a RowSource and assume the behavior is true for all rows in the RowSource).

See Also
org.apache.derby.iapi.store.access.RowSource#needsToClone
nextback to summary
public boolean next() throws StandardException

Overrides org.apache.derby.impl.store.access.sort.MergeScan.next.

Implements org.apache.derby.iapi.store.access.ScanController.next, org.apache.derby.iapi.store.access.GroupFetchScanController.next.

Doc from org.apache.derby.iapi.store.access.ScanController.next.

Move to the next position in the scan. If this is the first call to next(), the position is set to the first row. Returns false if there is not a next row to move to. It is possible, but not guaranteed, that this method could return true again, after returning false, if some other operation in the same transaction appended a row to the underlying conglomerate.

Returns:boolean

True if there is a next position in the scan, false if there isn't.

Exceptions
StandardException:
Standard exception policy.
offendingRowLocationback to summary
public void offendingRowLocation(RowLocation rl, long containdId) throws StandardException

Implements org.apache.derby.iapi.store.access.RowLocationRetRowSource.offendingRowLocation.

rowLocationback to summary
public void rowLocation(RowLocation rl)

Implements org.apache.derby.iapi.store.access.RowLocationRetRowSource.rowLocation.

Doc from org.apache.derby.iapi.store.access.RowLocationRetRowSource.rowLocation.

rowLocation is a callback for the drainer of the row source to return the rowLocation of the current row, i.e, the row that is being returned by getNextRowFromRowSource. This interface is for the purpose of loading a base table with index. In that case, the indices can be built at the same time the base table is laid down once the row location of the base row is known. This is an example pseudo code on how this call is expected to be used:

		boolean needsRL = rowSource.needsRowLocation();
		DataValueDescriptor[] row;
		while((row = rowSource.getNextRowFromRowSource()) != null)
		{
			RowLocation rl = heapConglomerate.insertRow(row);
			if (needsRL)
				rowSource.rowLocation(rl);
		}
		

NeedsRowLocation and rowLocation will ONLY be called by a drainer of the row source which CAN return a row location. Drainer of row source which cannot return rowLocation will guarantee to not call either callbacks. Conversely, if NeedsRowLocation is called and it returns true, then for every row return by getNextRowFromRowSource, a rowLocation callback must also be issued with the row location of the row. Implementor of both the source and the drain of the row source must be aware of this protocol.
The RowLocation object is own by the caller of rowLocation, in other words, the drainer of the RowSource. This is so that we don't need to new a row location for every row. If the Row Source wants to keep the row location, it needs to clone it (RowLocation is a ClonableObject).
See Also
RowLocationRetRowSource#rowLocation