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

Class JsonTableRangePartitionFunction

java.lang.Object

org.apache.drill.exec.planner.physical.AbstractRangePartitionFunction

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

All Implemented Interfaces:

PartitionFunction

public class JsonTableRangePartitionFunction
extends AbstractRangePartitionFunction

Field Summary

Fields

Modifier and Type	Field and Description
protected ValueVector	partitionKeyVector
protected List<FieldReference>	refList
protected List<byte[]>	startKeys
protected List<byte[]>	stopKeys
protected String	tableName
protected String	userName

Fields inherited from class org.apache.drill.exec.planner.physical.AbstractRangePartitionFunction

RANGE_PARTITION_EXPR_NAME

Constructor Summary

Constructors

Constructor and Description
JsonTableRangePartitionFunction(List<FieldReference> refList, String tableName, List<byte[]> startKeys, List<byte[]> stopKeys)
JsonTableRangePartitionFunction(List<FieldReference> refList, String tableName, String userName, MapRDBFormatPlugin formatPlugin)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
int	eval(int index, int numPartitions) Evaluate a partitioning function for a particular row index and return the partition id
List<FieldReference>	getPartitionRefList() Return the list of FieldReferences that participate in the partitioning function
int	hashCode()
void	initialize(MapRDBFormatPlugin plugin)
void	setup(List<VectorWrapper<?>> partitionKeys) Setup method for the partitioning function

Methods inherited from class org.apache.drill.exec.planner.physical.AbstractRangePartitionFunction

getPartitionFieldRef

Methods inherited from class java.lang.Object

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

Field Detail

refList

protected List<FieldReference> refList

tableName

protected String tableName

userName

protected String userName

partitionKeyVector

protected ValueVector partitionKeyVector

startKeys

protected List<byte[]> startKeys

stopKeys

protected List<byte[]> stopKeys

Constructor Detail

JsonTableRangePartitionFunction

public JsonTableRangePartitionFunction(List<FieldReference> refList,
                                       String tableName,
                                       List<byte[]> startKeys,
                                       List<byte[]> stopKeys)

JsonTableRangePartitionFunction

public JsonTableRangePartitionFunction(List<FieldReference> refList,
                                       String tableName,
                                       String userName,
                                       MapRDBFormatPlugin formatPlugin)

Method Detail

getPartitionRefList

public List<FieldReference> getPartitionRefList()

Description copied from interface: PartitionFunction

Return the list of FieldReferences that participate in the partitioning function

Specified by:

getPartitionRefList in interface PartitionFunction

Specified by:

getPartitionRefList in class AbstractRangePartitionFunction

Returns:

list of FieldReferences

setup

public void setup(List<VectorWrapper<?>> partitionKeys)

Description copied from interface: PartitionFunction

Setup method for the partitioning function

Specified by:

setup in interface PartitionFunction

Specified by:

setup in class AbstractRangePartitionFunction

Parameters:

partitionKeys - a list of partition columns on which range partitioning is needed

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

eval

public int eval(int index,
                int numPartitions)

Description copied from interface: PartitionFunction

Evaluate a partitioning function for a particular row index and return the partition id

Specified by:

eval in interface PartitionFunction

Specified by:

eval in class AbstractRangePartitionFunction

Parameters:

index - the integer index into the partition keys vector for a specific 'row' of values

numPartitions - the max number of partitions that are allowed

Returns:

partition id, an integer value

initialize

public void initialize(MapRDBFormatPlugin plugin)