Uses of Interface
org.apache.hadoop.hive.ql.exec.FileSinkOperator.RecordWriter

Packages that use FileSinkOperator.RecordWriter

org.apache.hadoop.hive.ql.exec	Hive QL execution tasks, operators, functions and other handlers.
org.apache.hadoop.hive.ql.exec.persistence
org.apache.hadoop.hive.ql.io
org.apache.hadoop.hive.ql.io.avro
org.apache.hadoop.hive.ql.io.orc	The Optimized Row Columnar (ORC) File Format.
org.apache.hadoop.hive.ql.io.parquet
org.apache.hadoop.hive.ql.io.parquet.write

Uses of FileSinkOperator.RecordWriter in org.apache.hadoop.hive.ql.exec

Methods in org.apache.hadoop.hive.ql.exec that return FileSinkOperator.RecordWriter

FileSinkOperator.RecordWriter[]

FileSinkOperator.FSPaths.getOutWriters()

Methods in org.apache.hadoop.hive.ql.exec with parameters of type FileSinkOperator.RecordWriter

void	FileSinkOperator.FSPaths.setOutWriters(FileSinkOperator.RecordWriter[] out)

Uses of FileSinkOperator.RecordWriter in org.apache.hadoop.hive.ql.exec.persistence

Methods in org.apache.hadoop.hive.ql.exec.persistence that return FileSinkOperator.RecordWriter

FileSinkOperator.RecordWriter

PTFRowContainer.PTFHiveSequenceFileOutputFormat.getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jc, org.apache.hadoop.fs.Path finalOutPath, Class<? extends org.apache.hadoop.io.Writable> valueClass, boolean isCompressed, Properties tableProperties, org.apache.hadoop.util.Progressable progress)

Uses of FileSinkOperator.RecordWriter in org.apache.hadoop.hive.ql.io

Subinterfaces of FileSinkOperator.RecordWriter in org.apache.hadoop.hive.ql.io

interface

StatsProvidingRecordWriter If a file format internally gathers statistics (like ORC) while writing then it can expose the statistics through this record writer interface.

Classes in org.apache.hadoop.hive.ql.io that implement FileSinkOperator.RecordWriter

class

HivePassThroughRecordWriter<K extends WritableComparable<?>,V extends Writable>

Methods in org.apache.hadoop.hive.ql.io that return FileSinkOperator.RecordWriter

FileSinkOperator.RecordWriter	HiveBinaryOutputFormat.getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jc, org.apache.hadoop.fs.Path outPath, Class<? extends org.apache.hadoop.io.Writable> valueClass, boolean isCompressed, Properties tableProperties, org.apache.hadoop.util.Progressable progress) create the final out file, and output row by row.
FileSinkOperator.RecordWriter	HiveIgnoreKeyTextOutputFormat.getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jc, org.apache.hadoop.fs.Path outPath, Class<? extends org.apache.hadoop.io.Writable> valueClass, boolean isCompressed, Properties tableProperties, org.apache.hadoop.util.Progressable progress) create the final out file, and output row by row.
FileSinkOperator.RecordWriter	HiveNullValueSequenceFileOutputFormat.getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jc, org.apache.hadoop.fs.Path finalOutPath, Class<? extends org.apache.hadoop.io.Writable> valueClass, boolean isCompressed, Properties tableProperties, org.apache.hadoop.util.Progressable progress)
FileSinkOperator.RecordWriter	HiveOutputFormat.getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jc, org.apache.hadoop.fs.Path finalOutPath, Class<? extends org.apache.hadoop.io.Writable> valueClass, boolean isCompressed, Properties tableProperties, org.apache.hadoop.util.Progressable progress) create the final out file and get some specific settings.
FileSinkOperator.RecordWriter	HivePassThroughOutputFormat.getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jc, org.apache.hadoop.fs.Path finalOutPath, Class<? extends org.apache.hadoop.io.Writable> valueClass, boolean isCompressed, Properties tableProperties, org.apache.hadoop.util.Progressable progress)
FileSinkOperator.RecordWriter	HiveSequenceFileOutputFormat.getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jc, org.apache.hadoop.fs.Path finalOutPath, Class<? extends org.apache.hadoop.io.Writable> valueClass, boolean isCompressed, Properties tableProperties, org.apache.hadoop.util.Progressable progress) create the final out file, and output an empty key as the key.
FileSinkOperator.RecordWriter	RCFileOutputFormat.getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jc, org.apache.hadoop.fs.Path finalOutPath, Class<? extends org.apache.hadoop.io.Writable> valueClass, boolean isCompressed, Properties tableProperties, org.apache.hadoop.util.Progressable progress) create the final out file.
static FileSinkOperator.RecordWriter	HiveFileFormatUtils.getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jc, TableDesc tableInfo, Class<? extends org.apache.hadoop.io.Writable> outputClass, FileSinkDesc conf, org.apache.hadoop.fs.Path outPath, org.apache.hadoop.mapred.Reporter reporter)
FileSinkOperator.RecordWriter	AcidOutputFormat.getRawRecordWriter(org.apache.hadoop.fs.Path path, AcidOutputFormat.Options options) Create a raw writer for ACID events.
static FileSinkOperator.RecordWriter	HiveFileFormatUtils.getRecordWriter(org.apache.hadoop.mapred.JobConf jc, HiveOutputFormat<?,?> hiveOutputFormat, Class<? extends org.apache.hadoop.io.Writable> valueClass, boolean isCompressed, Properties tableProp, org.apache.hadoop.fs.Path outPath, org.apache.hadoop.mapred.Reporter reporter)

Uses of FileSinkOperator.RecordWriter in org.apache.hadoop.hive.ql.io.avro

Classes in org.apache.hadoop.hive.ql.io.avro that implement FileSinkOperator.RecordWriter

class

AvroGenericRecordWriter Write an Avro GenericRecord to an Avro data file.

Methods in org.apache.hadoop.hive.ql.io.avro that return FileSinkOperator.RecordWriter

FileSinkOperator.RecordWriter

AvroContainerOutputFormat.getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.fs.Path path, Class<? extends org.apache.hadoop.io.Writable> valueClass, boolean isCompressed, Properties properties, org.apache.hadoop.util.Progressable progressable)

Uses of FileSinkOperator.RecordWriter in org.apache.hadoop.hive.ql.io.orc

Methods in org.apache.hadoop.hive.ql.io.orc that return FileSinkOperator.RecordWriter

FileSinkOperator.RecordWriter

OrcOutputFormat.getRawRecordWriter(org.apache.hadoop.fs.Path path, AcidOutputFormat.Options options)

Uses of FileSinkOperator.RecordWriter in org.apache.hadoop.hive.ql.io.parquet

Methods in org.apache.hadoop.hive.ql.io.parquet that return FileSinkOperator.RecordWriter

FileSinkOperator.RecordWriter

MapredParquetOutputFormat.getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.fs.Path finalOutPath, Class<? extends org.apache.hadoop.io.Writable> valueClass, boolean isCompressed, Properties tableProperties, org.apache.hadoop.util.Progressable progress) Create the parquet schema from the hive schema, and return the RecordWriterWrapper which contains the real output format

Uses of FileSinkOperator.RecordWriter in org.apache.hadoop.hive.ql.io.parquet.write

Classes in org.apache.hadoop.hive.ql.io.parquet.write that implement FileSinkOperator.RecordWriter

class

ParquetRecordWriterWrapper