V
- the row type of the filepublic interface AcidOutputFormat<K extends org.apache.hadoop.io.WritableComparable,V> extends HiveOutputFormat<K,V>
Modifier and Type | Interface and Description |
---|---|
static class |
AcidOutputFormat.Options
Options to control how the files are written
|
Modifier and Type | Method and Description |
---|---|
FileSinkOperator.RecordWriter |
getRawRecordWriter(org.apache.hadoop.fs.Path path,
AcidOutputFormat.Options options)
Create a raw writer for ACID events.
|
RecordUpdater |
getRecordUpdater(org.apache.hadoop.fs.Path path,
AcidOutputFormat.Options options)
Create a RecordUpdater for inserting, updating, or deleting records.
|
getHiveRecordWriter
RecordUpdater getRecordUpdater(org.apache.hadoop.fs.Path path, AcidOutputFormat.Options options) throws IOException
path
- the partition directory nameoptions
- the options for the writerIOException
FileSinkOperator.RecordWriter getRawRecordWriter(org.apache.hadoop.fs.Path path, AcidOutputFormat.Options options) throws IOException
path
- the root directoryoptions
- options for writing the fileIOException
Copyright © 2019 The Apache Software Foundation. All rights reserved.