public class HiveIcebergOutputFormat<T> extends java.lang.Object implements org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.NullWritable,Container<Record>>, org.apache.hadoop.hive.ql.io.HiveOutputFormat<org.apache.hadoop.io.NullWritable,Container<Record>>
Constructor and Description |
---|
HiveIcebergOutputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkOutputSpecs(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job) |
org.apache.hadoop.hive.ql.exec.FileSinkOperator.RecordWriter |
getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jc,
org.apache.hadoop.fs.Path finalOutPath,
java.lang.Class valueClass,
boolean isCompressed,
java.util.Properties tableAndSerDeProperties,
org.apache.hadoop.util.Progressable progress) |
org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.NullWritable,Container<Record>> |
getRecordWriter(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job,
java.lang.String name,
org.apache.hadoop.util.Progressable progress) |
public org.apache.hadoop.hive.ql.exec.FileSinkOperator.RecordWriter getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jc, org.apache.hadoop.fs.Path finalOutPath, java.lang.Class valueClass, boolean isCompressed, java.util.Properties tableAndSerDeProperties, org.apache.hadoop.util.Progressable progress)
public org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.NullWritable,Container<Record>> getRecordWriter(org.apache.hadoop.fs.FileSystem ignored, org.apache.hadoop.mapred.JobConf job, java.lang.String name, org.apache.hadoop.util.Progressable progress)