org.apache.drill.exec.store.mapr.db

Class RestrictedMapRDBSubScanSpec

java.lang.Object

org.apache.drill.exec.store.mapr.db.MapRDBSubScanSpec

org.apache.drill.exec.store.mapr.db.RestrictedMapRDBSubScanSpec

All Implemented Interfaces:

Comparable<MapRDBSubScanSpec>

public class RestrictedMapRDBSubScanSpec
extends MapRDBSubScanSpec

A RestrictedMapRDBSubScanSpec encapsulates a join instance which contains the ValueVectors of row keys and is associated with this sub-scan and also exposes an iterator type interface over the row key vectors.

Field Summary

Fields inherited from class org.apache.drill.exec.store.mapr.db.MapRDBSubScanSpec

indexDesc, regionServer, serializedFilter, startRow, stopRow, tableName, userName

Constructor Summary

Constructors

Constructor and Description
RestrictedMapRDBSubScanSpec(String tableName, String regionServer, byte[] serializedFilter, String userName)

Method Summary

Modifier and Type	Method and Description
RowKeyJoin	getJoinForSubScan()
int	getMaxRowKeysToBeRead()
ByteBuffer[]	getRowKeyIdsToRead(int numRowKeysToRead) Returns ids of rowKeys to be read.
boolean	hasRowKey() Returns true if the iteration has more row keys.
int	hasRowKeys(int numRowKeysToRead) Returns number of rowKeys that can be read.
boolean	isBuildSchemaPhase() Return true if the row key join is in the build schema phase
boolean	readyToGetRowKey() Return true if a valid rowkey batch is available, false otherwise
void	setJoinForSubScan(RowKeyJoin rjbatch)
void	updateRowKeysRead(int numKeys) updates the index to reflect number of keys read.

Methods inherited from class org.apache.drill.exec.store.mapr.db.MapRDBSubScanSpec

compareTo, getIndexDesc, getRegionServer, getSerializedFilter, getStartRow, getStopRow, getTableName, getUserName, setRegionServer, setSerializedFilter, setStartRow, setStopRow, setTableName, setUserName, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

RestrictedMapRDBSubScanSpec

public RestrictedMapRDBSubScanSpec(String tableName,
                                   String regionServer,
                                   byte[] serializedFilter,
                                   String userName)

Method Detail

setJoinForSubScan

public void setJoinForSubScan(RowKeyJoin rjbatch)

getJoinForSubScan

public RowKeyJoin getJoinForSubScan()

readyToGetRowKey

public boolean readyToGetRowKey()

Return true if a valid rowkey batch is available, false otherwise

isBuildSchemaPhase

public boolean isBuildSchemaPhase()

Return true if the row key join is in the build schema phase

hasRowKey

public boolean hasRowKey()

Returns true if the iteration has more row keys. (In other words, returns true if #nextRowKey would return a non-null row key)

Returns:

true if the iteration has more row keys

getMaxRowKeysToBeRead

public int getMaxRowKeysToBeRead()

hasRowKeys

public int hasRowKeys(int numRowKeysToRead)

Returns number of rowKeys that can be read. Number of rowKeys returned will be numRowKeysToRead at the most i.e. it will be less than numRowKeysToRead if only that many exist in the currentBatch.

getRowKeyIdsToRead

public ByteBuffer[] getRowKeyIdsToRead(int numRowKeysToRead)

Returns ids of rowKeys to be read. Number of rowKey ids returned will be numRowKeysToRead at the most i.e. it will be less than numRowKeysToRead if only that many exist in the currentBatch.

updateRowKeysRead

public void updateRowKeysRead(int numKeys)

updates the index to reflect number of keys read.