Class ConstantVenicePartitioner

    • Field Detail

      • CONSTANT_PARTITION

        public static final java.lang.String CONSTANT_PARTITION
        See Also:
        Constant Field Values
    • Constructor Detail

      • ConstantVenicePartitioner

        public ConstantVenicePartitioner​(VeniceProperties properties)
      • ConstantVenicePartitioner

        public ConstantVenicePartitioner​(VeniceProperties properties,
                                         org.apache.avro.Schema schema)
    • Method Detail

      • 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​(java.nio.ByteBuffer keyByteBuffer,
                                  int numPartitions)
        Specified by:
        getPartitionId in class VenicePartitioner