Package | Description |
---|---|
org.apache.hadoop.hive.ql.io | |
org.apache.hadoop.hive.ql.io.orc |
The Optimized Row Columnar (ORC) File Format.
|
org.apache.hive.hcatalog.streaming.mutate.worker | |
org.apache.hive.streaming |
HCatalog Streaming API -- high level description
|
Modifier and Type | Method and Description |
---|---|
static RecordUpdater |
HiveFileFormatUtils.getAcidRecordUpdater(org.apache.hadoop.mapred.JobConf jc,
TableDesc tableInfo,
int bucket,
FileSinkDesc conf,
org.apache.hadoop.fs.Path outPath,
ObjectInspector inspector,
org.apache.hadoop.mapred.Reporter reporter,
int rowIdColNum) |
RecordUpdater |
AcidOutputFormat.getRecordUpdater(org.apache.hadoop.fs.Path path,
AcidOutputFormat.Options options)
Create a RecordUpdater for inserting, updating, or deleting records.
|
Modifier and Type | Class and Description |
---|---|
class |
OrcRecordUpdater
A RecordUpdater where the files are stored as ORC.
|
Modifier and Type | Method and Description |
---|---|
RecordUpdater |
OrcOutputFormat.getRecordUpdater(org.apache.hadoop.fs.Path path,
AcidOutputFormat.Options options) |
Modifier and Type | Method and Description |
---|---|
protected RecordUpdater |
MutatorImpl.createRecordUpdater(AcidOutputFormat<?,?> outputFormat)
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
protected Map<String,List<RecordUpdater>> |
AbstractRecordWriter.updaters |
Modifier and Type | Method and Description |
---|---|
protected RecordUpdater |
AbstractRecordWriter.createRecordUpdater(org.apache.hadoop.fs.Path partitionPath,
int bucketId,
Long minWriteId,
Long maxWriteID) |
protected RecordUpdater |
AbstractRecordWriter.getRecordUpdater(List<String> partitionValues,
int bucketId) |
Modifier and Type | Method and Description |
---|---|
protected List<RecordUpdater> |
AbstractRecordWriter.initializeBuckets() |
Copyright © 2022 The Apache Software Foundation. All rights reserved.