Class BucketHasher

java.lang.Object

org.tasktide.mutex.bucketing.BucketHasher

public class BucketHasher
extends Object

Bucketing based on crc32

Constructor Summary

Constructors

Constructor	Description
BucketHasher(Path bucketPrefix, int bucketLimit)	Construct hasher

Method Summary

Modifier and Type	Method	Description
long	calculateBucketForKey(BucketKey key)	Calculate bucket for key
BucketKey	getBucketKey()	Fetch a BucketKey
BucketKey	getBucketKey(String hostLabel, String runId)	Fetch a BucketKey for hashing
Path	getBucketPath(BucketKey key)	Get bucket path for key

Methods inherited from class Object

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

Constructor Details

BucketHasher

public BucketHasher(Path bucketPrefix,
 int bucketLimit)

Construct hasher

Parameters:

bucketPrefix -

bucketLimit -

Method Details

calculateBucketForKey

public long calculateBucketForKey(BucketKey key)

Calculate bucket for key

Parameters:

key -

Returns:

long

getBucketKey

public BucketKey getBucketKey()

Fetch a BucketKey

Returns:

BucketKey

getBucketKey

public BucketKey getBucketKey(String hostLabel,
 String runId)

Fetch a BucketKey for hashing

Parameters:

hostLabel -

runId -

Returns:

BucketKey

getBucketPath

public Path getBucketPath(BucketKey key)

Get bucket path for key

Parameters:

key -

Returns:

Path