Package org.apache.druid.segment.incremental

Interface FactsHolder

public interface FactsHolder

IncrementalIndexRow storage interface, a mutable data structure for building up a set or rows to eventually persist into an immutable segment

See Also:

• for the data processor which constructs IncrementalIndexRow to store here

Method Summary

Modifier and Type	Method	Description
void	clear()	Clear all rows present in the facts holder
long	getMaxTimeMillis()	Get maximum IncrementalIndexRow.getTimestamp() present in the facts holder
long	getMinTimeMillis()	Get minimum IncrementalIndexRow.getTimestamp() present in the facts holder
int	getPriorIndex(IncrementalIndexRow key)
Iterator<IncrementalIndexRow>	iterator(boolean descending)	Get all IncrementalIndex, depending on the implementation, these rows may or may not be ordered in the same order they will be persisted in.
Iterable<IncrementalIndexRow>	keySet()	Get all row IncrementalIndexRow 'keys', which is distinct groups if this is an aggregating facts holder or just every row present if not
Iterable<IncrementalIndexRow>	persistIterable()	Get all IncrementalIndexRow to persist, ordered with
int	putIfAbsent(IncrementalIndexRow key, int rowIndex)
Iterable<IncrementalIndexRow>	timeRangeIterable(boolean descending, long timeStart, long timeEnd)	Get all IncrementalIndexRow with IncrementalIndexRow.getTimestamp() between the start and end timestamps specified

Method Details

getPriorIndex

int getPriorIndex(IncrementalIndexRow key)

Returns:

the previous rowIndex associated with the specified key, or IncrementalIndexRow.EMPTY_ROW_INDEX if there was no mapping for the key.

getMinTimeMillis

long getMinTimeMillis()

Get minimum IncrementalIndexRow.getTimestamp() present in the facts holder

getMaxTimeMillis

long getMaxTimeMillis()

Get maximum IncrementalIndexRow.getTimestamp() present in the facts holder

iterator

Iterator<IncrementalIndexRow> iterator(boolean descending)

Get all IncrementalIndex, depending on the implementation, these rows may or may not be ordered in the same order they will be persisted in. Use persistIterable() if this is required.

timeRangeIterable

Iterable<IncrementalIndexRow> timeRangeIterable(boolean descending,
 long timeStart,
 long timeEnd)

Get all IncrementalIndexRow with IncrementalIndexRow.getTimestamp() between the start and end timestamps specified

keySet

Iterable<IncrementalIndexRow> keySet()

Get all row IncrementalIndexRow 'keys', which is distinct groups if this is an aggregating facts holder or just every row present if not

persistIterable

Iterable<IncrementalIndexRow> persistIterable()

Get all IncrementalIndexRow to persist, ordered with

putIfAbsent

int putIfAbsent(IncrementalIndexRow key,
 int rowIndex)

Returns:

the previous rowIndex associated with the specified key, or IncrementalIndexRow.EMPTY_ROW_INDEX if there was no mapping for the key.

clear

void clear()

Clear all rows present in the facts holder