Package | Description |
---|---|
org.apache.hadoop.hive.ql.io | |
org.apache.hadoop.hive.ql.io.orc |
The Optimized Row Columnar (ORC) File Format.
|
Modifier and Type | Method and Description |
---|---|
AcidOutputFormat.Options |
AcidOutputFormat.Options.bucket(int bucket)
The bucket that is included in this file.
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.filesystem(org.apache.hadoop.fs.FileSystem fs)
Provide a file system to the writer.
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.inspector(ObjectInspector inspector)
Use the given ObjectInspector for each record written.
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.isCompressed(boolean isCompressed)
Should the output be compressed?
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.maximumTransactionId(long max)
The maximum transaction id that is included in this file.
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.minimumTransactionId(long min)
The minimum transaction id that is included in this file.
|
static AcidOutputFormat.Options |
AcidUtils.parseBaseBucketFilename(org.apache.hadoop.fs.Path bucketFile,
org.apache.hadoop.conf.Configuration conf)
Parse a bucket filename back into the options that would have created
the file.
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.recordIdColumn(int recIdCol)
Which column the row id field is in.
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.reporter(org.apache.hadoop.mapred.Reporter reporter)
Provide the MapReduce reporter.
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.tableProperties(Properties properties)
Provide the table properties for the table.
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.useDummy(PrintStream stream)
Temporary switch while we are in development that replaces the
implementation with a dummy one that just prints to stream.
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.writingBase(boolean val)
Is this writing a base directory? Should only be used by the compactor,
or when implementing insert overwrite.
|
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.fs.Path |
AcidUtils.createFilename(org.apache.hadoop.fs.Path directory,
AcidOutputFormat.Options options)
Create a filename for a bucket file.
|
FileSinkOperator.RecordWriter |
AcidOutputFormat.getRawRecordWriter(org.apache.hadoop.fs.Path path,
AcidOutputFormat.Options options)
Create a raw writer for ACID events.
|
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 |
---|---|
static class |
OrcRecordUpdater.OrcOptions
An extension to AcidOutputFormat that allows users to add additional
options.
|
Modifier and Type | Method and Description |
---|---|
FileSinkOperator.RecordWriter |
OrcOutputFormat.getRawRecordWriter(org.apache.hadoop.fs.Path path,
AcidOutputFormat.Options options) |
RecordUpdater |
OrcOutputFormat.getRecordUpdater(org.apache.hadoop.fs.Path path,
AcidOutputFormat.Options options) |
Copyright © 2017 The Apache Software Foundation. All rights reserved.