org.apache.hive.hcatalog.streaming.mutate.worker

Class BucketIdResolverImpl

java.lang.Object

org.apache.hive.hcatalog.streaming.mutate.worker.BucketIdResolverImpl

All Implemented Interfaces:

BucketIdResolver

Deprecated.

as of Hive 3.0.0

@Deprecated
public class BucketIdResolverImpl
extends Object
implements BucketIdResolver

Implementation of a 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 Summary

Constructors

Constructor and Description
BucketIdResolverImpl(ObjectInspector objectInspector, int recordIdColumn, int totalBuckets, int[] bucketColumns) Deprecated. Note that all column indexes are with respect to your record structure, not the Hive table structure.

Method Summary

Modifier and Type	Method and Description
Object	attachBucketIdToRecord(Object record) Deprecated.
int	computeBucketId(Object record) Deprecated. See: ReduceSinkOperator.computeBucketNumber(Object, int).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BucketIdResolverImpl

public BucketIdResolverImpl(ObjectInspector objectInspector,
                            int recordIdColumn,
                            int totalBuckets,
                            int[] bucketColumns)

Deprecated.

Note that all column indexes are with respect to your record structure, not the Hive table structure. Bucket column indexes must be presented in the same order as they are in the Hive table definition.

Method Detail

attachBucketIdToRecord

public Object attachBucketIdToRecord(Object record)

Deprecated.

Specified by:

attachBucketIdToRecord in interface BucketIdResolver

computeBucketId

public int computeBucketId(Object record)

Deprecated.

Description copied from interface: BucketIdResolver

See: ReduceSinkOperator.computeBucketNumber(Object, int).

Specified by:

computeBucketId in interface BucketIdResolver