Package com.linkedin.venice.partitioner

Class ConstantVenicePartitioner

java.lang.Object

com.linkedin.venice.partitioner.VenicePartitioner

com.linkedin.venice.partitioner.ConstantVenicePartitioner

public class ConstantVenicePartitioner
extends VenicePartitioner

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONSTANT_PARTITION

Fields inherited from class com.linkedin.venice.partitioner.VenicePartitioner

props

Constructor Summary

Constructors

Constructor	Description
ConstantVenicePartitioner(VeniceProperties properties)
ConstantVenicePartitioner(VeniceProperties properties, org.apache.avro.Schema schema)

Method Summary

Modifier and Type	Method	Description
int	getPartitionId(byte[] keyBytes, int numPartitions)	A function that returns the partitionId based on the key and partition count.
int	getPartitionId(ByteBuffer keyByteBuffer, int numPartitions)

Methods inherited from class com.linkedin.venice.partitioner.VenicePartitioner

checkSchema, getPartitionId

Methods inherited from class java.lang.Object

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

Field Details

CONSTANT_PARTITION

public static final String CONSTANT_PARTITION

See Also:

• Constant Field Values

Constructor Details

ConstantVenicePartitioner

public ConstantVenicePartitioner(VeniceProperties properties)

ConstantVenicePartitioner

public ConstantVenicePartitioner(VeniceProperties properties,
 org.apache.avro.Schema schema)

Method Details

getPartitionId

public int getPartitionId(byte[] keyBytes,
 int numPartitions)

Description copied from class: VenicePartitioner

A function that returns the partitionId based on the key and partition count.

Specified by:

getPartitionId in class VenicePartitioner

Parameters:

keyBytes - - A key that will be mapped into a partition

numPartitions - - The number of total partitions available in Kafka/storage

Returns:

getPartitionId

public int getPartitionId(ByteBuffer keyByteBuffer,
 int numPartitions)

Specified by:

getPartitionId in class VenicePartitioner