public class

ZNRecordBucketizer

extends Object
java.lang.Object
   ↳ org.apache.helix.ZNRecordBucketizer

Class Overview

Operations to divide a ZNRecord into specified buckets

Summary

Public Constructors
ZNRecordBucketizer(int bucketSize)
Instantiate a bucketizer with the number of buckets
Public Methods
Map<StringZNRecord> bucketize(ZNRecord record)
Bucketize a ZNRecord
String getBucketName(String key)
Calculate bucketName in form of "resourceName_p{startPartition}-p{endPartition}
[Expand]
Inherited Methods
From class java.lang.Object

Public Constructors

public ZNRecordBucketizer (int bucketSize)

Instantiate a bucketizer with the number of buckets

Public Methods

public Map<StringZNRecord> bucketize (ZNRecord record)

Bucketize a ZNRecord

Returns
  • A map of bucket names to bucketized records

public String getBucketName (String key)

Calculate bucketName in form of "resourceName_p{startPartition}-p{endPartition}

Returns
  • the bucket name