Class MergeInserter

java.lang.Object

org.apache.derby.impl.store.access.sort.MergeInserter

All Implemented Interfaces:

SortController

final class MergeInserter
extends Object
implements SortController

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	avoidMergeRun
private long	beginMemoryUsage	Information about memory usage to dynamically tune the in-memory sort buffer size.
private Vector<Long>	mergeRuns	A vector of the conglomerate ids of the merge runs.
private int	runSize
private MergeSort	sort	The sort this inserter is for.
private SortBuffer	sortBuffer	An in-memory ordered set that is used to sort rows before they're sent to merge runs.
(package private) Vector<Integer>	stat_mergeRunsSize
(package private) int	stat_numMergeRuns
(package private) int	stat_numRowsInput
(package private) int	stat_numRowsOutput
(package private) String	stat_sortType
private int	totalRunSize
private TransactionManager	tran	The transaction this inserter is in.

Constructor Summary

Constructors

Constructor	Description
MergeInserter()

Method Summary

Modifier and Type	Method	Description
void	completedInserts()	Called when the caller has completed inserting rows into the sorter.
SortInfo	getSortInfo()	Return SortInfo object which contains information about the current sort.
(package private) boolean	initialize(MergeSort sort, TransactionManager tran)	Initialize this inserter.
void	insert(DataValueDescriptor[] row)	Insert a row into the sort.

Methods inherited from class Object

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

Field Details

sort

private MergeSort sort

The sort this inserter is for.

tran

private TransactionManager tran

The transaction this inserter is in.

mergeRuns

private Vector<Long> mergeRuns

A vector of the conglomerate ids of the merge runs.

sortBuffer

private SortBuffer sortBuffer

An in-memory ordered set that is used to sort rows before they're sent to merge runs.

beginMemoryUsage

private long beginMemoryUsage

Information about memory usage to dynamically tune the in-memory sort buffer size.

avoidMergeRun

private boolean avoidMergeRun

runSize

private int runSize

totalRunSize

private int totalRunSize

stat_sortType

String stat_sortType

stat_numRowsInput

int stat_numRowsInput

stat_numRowsOutput

int stat_numRowsOutput

stat_numMergeRuns

int stat_numMergeRuns

stat_mergeRunsSize

Vector<Integer> stat_mergeRunsSize

Constructor Details

MergeInserter

MergeInserter()

Method Details

insert

public void insert(DataValueDescriptor[] row)
            throws StandardException

Insert a row into the sort.

Specified by:

insert in interface SortController

Parameters:

row - The row to insert into the SortController. The stored representations of the row's columns are copied into a new row somewhere in the sort.

Throws:

StandardException - Standard exception policy.

See Also:

• SortController.insert(DataValueDescriptor[])

completedInserts

public void completedInserts()

Called when the caller has completed inserting rows into the sorter.

Specified by:

completedInserts in interface SortController

See Also:

• SortController.completedInserts()

getSortInfo

public SortInfo getSortInfo()
                     throws StandardException

Return SortInfo object which contains information about the current sort.

Specified by:

getSortInfo in interface SortController

Returns:

The SortInfo object which contains info about current sort.

Throws:

StandardException - Standard exception policy.

See Also:

• SortInfo

initialize

boolean initialize(MergeSort sort,
 TransactionManager tran)

Initialize this inserter.

Returns:

true if initialization was successful