public class RecordInspectorImpl extends Object implements RecordInspector
RecordInspector
implementation that uses the supplied ObjectInspector
and
record id column
to extract RecordIdentifiers
, and calculate bucket ids from records.Constructor and Description |
---|
RecordInspectorImpl(ObjectInspector objectInspector,
int recordIdColumn)
Note that all column indexes are with respect to your record structure, not the Hive table structure.
|
Modifier and Type | Method and Description |
---|---|
RecordIdentifier |
extractRecordIdentifier(Object record)
Get the
RecordIdentifier from the record - to be used for updates and deletes only. |
String |
toString() |
public RecordInspectorImpl(ObjectInspector objectInspector, int recordIdColumn)
public RecordIdentifier extractRecordIdentifier(Object record)
RecordInspector
RecordIdentifier
from the record - to be used for updates and deletes only.extractRecordIdentifier
in interface RecordInspector
Copyright © 2016 The Apache Software Foundation. All rights reserved.