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