io.druid.query.groupby.epinephelinae.column

Class LongGroupByColumnSelectorStrategy

java.lang.Object

io.druid.query.groupby.epinephelinae.column.LongGroupByColumnSelectorStrategy

All Implemented Interfaces:

ColumnSelectorStrategy, GroupByColumnSelectorStrategy

public class LongGroupByColumnSelectorStrategy
extends Object
implements GroupByColumnSelectorStrategy

Constructor Summary

Constructors

Constructor and Description
LongGroupByColumnSelectorStrategy()

Method Summary

Modifier and Type	Method and Description
boolean	checkRowIndexAndAddValueToGroupingKey(int keyBufferPosition, Object rowObj, int rowValIdx, ByteBuffer keyBuffer) If rowValIdx is less than the size of rowObj (haven't handled all of the row values): First, read the value at rowValIdx from a rowObj and write that value to the keyBuffer at keyBufferPosition.
int	getGroupingKeySize() Return the size, in bytes, of this dimension's values in the grouping key.
void	initColumnValues(ColumnValueSelector selector, int columnIndex, Object[] valuess) Retrieve a row object from the ColumnSelectorPlus and put it in valuess at columnIndex.
void	initGroupingKeyColumnValue(int keyBufferPosition, int columnIndex, Object rowObj, ByteBuffer keyBuffer, int[] stack) Read the first value within a row values object (IndexedInts, IndexedLongs, etc.) and write that value to the keyBuffer at keyBufferPosition.
void	processValueFromGroupingKey(GroupByColumnSelectorPlus selectorPlus, ByteBuffer key, Map<String,Object> resultMap) Read a value from a grouping key and add it to the group by query result map, using the output name specified in a DimensionSpec.

Methods inherited from class java.lang.Object

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

Constructor Detail

LongGroupByColumnSelectorStrategy

public LongGroupByColumnSelectorStrategy()

Method Detail

getGroupingKeySize

public int getGroupingKeySize()

Description copied from interface: GroupByColumnSelectorStrategy

Return the size, in bytes, of this dimension's values in the grouping key. For example, a String implementation would return 4, the size of an int.

Specified by:

getGroupingKeySize in interface GroupByColumnSelectorStrategy

Returns:

size, in bytes, of this dimension's values in the grouping key.

processValueFromGroupingKey

public void processValueFromGroupingKey(GroupByColumnSelectorPlus selectorPlus,
                                        ByteBuffer key,
                                        Map<String,Object> resultMap)

Description copied from interface: GroupByColumnSelectorStrategy

Read a value from a grouping key and add it to the group by query result map, using the output name specified in a DimensionSpec. An implementation may choose to not add anything to the result map (e.g., as the String implementation does for empty rows) selectorPlus provides access to: - the keyBufferPosition offset from which to read the value - the dimension value selector - the DimensionSpec for this dimension from the query

Specified by:

processValueFromGroupingKey in interface GroupByColumnSelectorStrategy

Parameters:

selectorPlus - dimension info containing the key offset, value selector, and dimension spec

key - grouping key

resultMap - result map for the group by query being served

initColumnValues

public void initColumnValues(ColumnValueSelector selector,
                             int columnIndex,
                             Object[] valuess)

Description copied from interface: GroupByColumnSelectorStrategy

Retrieve a row object from the ColumnSelectorPlus and put it in valuess at columnIndex.

Specified by:

initColumnValues in interface GroupByColumnSelectorStrategy

Parameters:

selector - Value selector for a column.

columnIndex - Index of the column within the row values array

valuess - Row values array, one index per column

initGroupingKeyColumnValue

public void initGroupingKeyColumnValue(int keyBufferPosition,
                                       int columnIndex,
                                       Object rowObj,
                                       ByteBuffer keyBuffer,
                                       int[] stack)

Description copied from interface: GroupByColumnSelectorStrategy

Read the first value within a row values object (IndexedInts, IndexedLongs, etc.) and write that value to the keyBuffer at keyBufferPosition. If rowSize is 0, write GROUP_BY_MISSING_VALUE instead. If the size of the row is > 0, write 1 to stack[] at columnIndex, otherwise write 0.

Specified by:

initGroupingKeyColumnValue in interface GroupByColumnSelectorStrategy

Parameters:

keyBufferPosition - Starting offset for this column's value within the grouping key.

columnIndex - Index of the column within the row values array

rowObj - Row value object for this column (e.g., IndexedInts)

keyBuffer - grouping key

stack - array containing the current within-row value index for each column

checkRowIndexAndAddValueToGroupingKey

public boolean checkRowIndexAndAddValueToGroupingKey(int keyBufferPosition,
                                                     Object rowObj,
                                                     int rowValIdx,
                                                     ByteBuffer keyBuffer)

Description copied from interface: GroupByColumnSelectorStrategy

If rowValIdx is less than the size of rowObj (haven't handled all of the row values): First, read the value at rowValIdx from a rowObj and write that value to the keyBuffer at keyBufferPosition. Then return true Otherwise, return false.

Specified by:

checkRowIndexAndAddValueToGroupingKey in interface GroupByColumnSelectorStrategy

Parameters:

keyBufferPosition - Starting offset for this column's value within the grouping key.

rowObj - Row value object for this column (e.g., IndexedInts)

rowValIdx - Index of the current value being grouped on within the row

keyBuffer - grouping key

Returns:

true if rowValIdx < size of rowObj, false otherwise