public class SimpleHashBucketAssigner extends Object implements BucketAssigner
| Constructor and Description |
|---|
SimpleHashBucketAssigner(int numAssigners,
int assignId,
long targetBucketRowNumber) |
| Modifier and Type | Method and Description |
|---|---|
int |
assign(BinaryRow partition,
int hash) |
void |
prepareCommit(long commitIdentifier) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcomputeAssigner, computeHashKey, isMyBucketpublic SimpleHashBucketAssigner(int numAssigners,
int assignId,
long targetBucketRowNumber)
public int assign(BinaryRow partition, int hash)
assign in interface BucketAssignerpublic void prepareCommit(long commitIdentifier)
prepareCommit in interface BucketAssignerCopyright © 2023–2024 The Apache Software Foundation. All rights reserved.