Package | Description |
---|---|
org.apache.hadoop.hive.ql.io | |
org.apache.hadoop.hive.ql.io.orc |
The Optimized Row Columnar (ORC) File Format.
|
org.apache.hadoop.hive.ql.txn.compactor |
Modifier and Type | Method and Description |
---|---|
AcidOutputFormat.Options |
AcidOutputFormat.Options.attemptId(Integer attemptId) |
AcidOutputFormat.Options |
AcidOutputFormat.Options.bucket(int bucket)
The bucketId that is included in this file.
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.clone()
shallow clone
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.filesystem(org.apache.hadoop.fs.FileSystem fs)
Provide a file system to the writer.
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.finalDestination(org.apache.hadoop.fs.Path p) |
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.maximumWriteId(long max)
The maximum write id that is included in this file.
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.maxStmtId(int maxStmtId) |
AcidOutputFormat.Options |
AcidOutputFormat.Options.minimumWriteId(long min)
The minimum write id that is included in this file.
|
static AcidOutputFormat.Options |
AcidUtils.parseBaseOrDeltaBucketFilename(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.statementId(int id) |
AcidOutputFormat.Options |
AcidOutputFormat.Options.tableProperties(Properties properties)
Provide the table properties for the table.
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.temporary(boolean temporary) |
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.visibilityTxnId(long visibilityTxnId) |
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.
|
AcidOutputFormat.Options |
AcidOutputFormat.Options.writingDeleteDelta(boolean val)
Is this writing a delete delta directory?
|
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.fs.Path |
AcidUtils.baseOrDeltaSubdirPath(org.apache.hadoop.fs.Path directory,
AcidOutputFormat.Options options)
Return a base or delta directory path according to the given "options".
|
static org.apache.hadoop.fs.Path |
AcidUtils.createFilename(org.apache.hadoop.fs.Path directory,
AcidOutputFormat.Options options)
Create a filename for a bucket file.
|
abstract int |
BucketCodec.encode(AcidOutputFormat.Options options) |
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 | 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) |
Modifier and Type | Method and Description |
---|---|
void |
CompactorMR.CompactorMap.cleanupTmpLocationOnTaskRetry(AcidOutputFormat.Options options,
org.apache.hadoop.fs.Path rootDir) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.