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, wait
computeAssigner, computeHashKey, isMyBucket
public SimpleHashBucketAssigner(int numAssigners, int assignId, long targetBucketRowNumber)
public int assign(BinaryRow partition, int hash)
assign
in interface BucketAssigner
public void prepareCommit(long commitIdentifier)
prepareCommit
in interface BucketAssigner
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.