public class BucketIdResolverImpl extends Object implements BucketIdResolver
BucketIdResolver
that includes the logic required to calculate a bucket id from a record
that is consistent with Hive's own internal computation scheme.Constructor and Description |
---|
BucketIdResolverImpl(ObjectInspector objectInspector,
int recordIdColumn,
int totalBuckets,
int[] bucketColumns)
Note that all column indexes are with respect to your record structure, not the Hive table structure.
|
Modifier and Type | Method and Description |
---|---|
Object |
attachBucketIdToRecord(Object record) |
int |
computeBucketId(Object record)
|
public BucketIdResolverImpl(ObjectInspector objectInspector, int recordIdColumn, int totalBuckets, int[] bucketColumns)
public Object attachBucketIdToRecord(Object record)
attachBucketIdToRecord
in interface BucketIdResolver
public int computeBucketId(Object record)
BucketIdResolver
computeBucketId
in interface BucketIdResolver
Copyright © 2016 The Apache Software Foundation. All rights reserved.