| Package | Description |
|---|---|
| org.apache.hadoop.hive.ql.io.parquet | |
| org.apache.hadoop.hive.ql.io.parquet.write |
| Modifier and Type | Field and Description |
|---|---|
protected parquet.hadoop.ParquetOutputFormat<ParquetHiveRecord> |
MapredParquetOutputFormat.realOutputFormat |
| Modifier and Type | Method and Description |
|---|---|
org.apache.hadoop.mapred.RecordWriter<Void,ParquetHiveRecord> |
MapredParquetOutputFormat.getRecordWriter(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job,
String name,
org.apache.hadoop.util.Progressable progress) |
| Modifier and Type | Method and Description |
|---|---|
protected ParquetRecordWriterWrapper |
MapredParquetOutputFormat.getParquerRecordWriterWrapper(parquet.hadoop.ParquetOutputFormat<ParquetHiveRecord> realOutputFormat,
org.apache.hadoop.mapred.JobConf jobConf,
String finalOutPath,
org.apache.hadoop.util.Progressable progress,
Properties tableProperties) |
| Constructor and Description |
|---|
MapredParquetOutputFormat(org.apache.hadoop.mapreduce.OutputFormat<Void,ParquetHiveRecord> mapreduceOutputFormat) |
| Modifier and Type | Method and Description |
|---|---|
void |
DataWritableWriteSupport.write(ParquetHiveRecord record) |
void |
DataWritableWriter.write(ParquetHiveRecord record)
It writes all record values to the Parquet RecordConsumer.
|
void |
ParquetRecordWriterWrapper.write(Void key,
ParquetHiveRecord value) |
| Constructor and Description |
|---|
ParquetRecordWriterWrapper(org.apache.hadoop.mapreduce.OutputFormat<Void,ParquetHiveRecord> realOutputFormat,
org.apache.hadoop.mapred.JobConf jobConf,
String name,
org.apache.hadoop.util.Progressable progress,
Properties tableProperties) |
Copyright © 2017 The Apache Software Foundation. All rights reserved.