public interface BucketIdResolver
Object
attachBucketIdToRecord(Object record)
int
computeBucketId(Object record)
ReduceSinkOperator.computeBucketNumber(Object, int)
Object attachBucketIdToRecord(Object record)
int computeBucketId(Object record)
Copyright © 2021 The Apache Software Foundation. All rights reserved.