public class HashBucketAssigner extends Object implements BucketAssigner
Constructor and Description |
---|
HashBucketAssigner(SnapshotManager snapshotManager,
String commitUser,
IndexFileHandler indexFileHandler,
int numChannels,
int numAssigners,
int assignId,
long targetBucketRowNumber) |
Modifier and Type | Method and Description |
---|---|
int |
assign(BinaryRow partition,
int hash)
Assign a bucket for key hash of a record.
|
void |
prepareCommit(long commitIdentifier)
Prepare commit to clear outdated partition index.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
computeAssigner, computeHashKey, isMyBucket
public HashBucketAssigner(SnapshotManager snapshotManager, String commitUser, IndexFileHandler indexFileHandler, int numChannels, 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.