Package | Description |
---|---|
org.apache.hive.hcatalog.data | |
org.apache.hive.hcatalog.data.transfer | |
org.apache.hive.hcatalog.data.transfer.impl | |
org.apache.hive.hcatalog.mapreduce |
Modifier and Type | Class and Description |
---|---|
class |
DefaultHCatRecord |
class |
LazyHCatRecord
An implementation of HCatRecord that wraps an Object returned by a SerDe
and an ObjectInspector.
|
Modifier and Type | Method and Description |
---|---|
HCatRecord |
LazyHCatRecord.getWritable()
Convert this LazyHCatRecord to a DefaultHCatRecord.
|
Modifier and Type | Method and Description |
---|---|
void |
LazyHCatRecord.copy(HCatRecord r) |
abstract void |
HCatRecord.copy(HCatRecord r) |
void |
DefaultHCatRecord.copy(HCatRecord r) |
Modifier and Type | Method and Description |
---|---|
abstract Iterator<HCatRecord> |
HCatReader.read()
This should be called at slave nodes to read
HCatRecord s |
Modifier and Type | Method and Description |
---|---|
abstract void |
HCatWriter.write(Iterator<HCatRecord> recordItr)
This method should be used at slave needs to perform writes.
|
Modifier and Type | Method and Description |
---|---|
Iterator<HCatRecord> |
HCatInputFormatReader.read() |
Modifier and Type | Method and Description |
---|---|
void |
HCatOutputFormatWriter.write(Iterator<HCatRecord> recordItr) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.WritableComparable,HCatRecord> |
HCatBaseInputFormat.createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
Create the RecordReader for the given InputSplit.
|
protected org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.WritableComparable<?>,HCatRecord> |
HCatBaseOutputFormat.getOutputFormat(org.apache.hadoop.mapreduce.JobContext context)
Gets the output format instance.
|
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable<?>,HCatRecord> |
HCatOutputFormat.getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
Get the record writer for the job.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.