hdfs-avro-table-writer.cc File Reference

#include "exec/hdfs-avro-table-writer.h"
#include <vector>
#include <hdfs.h>
#include <boost/scoped_ptr.hpp>
#include <stdlib.h>
#include <codec.h>
#include <gutil/strings/substitute.h>
#include "exec/exec-node.h"
#include "util/compress.h"
#include "util/hdfs-util.h"
#include "util/uid-util.h"
#include "exprs/expr.h"
#include "exprs/expr-context.h"
#include "runtime/raw-value.h"
#include "runtime/row-batch.h"
#include "runtime/runtime-state.h"
#include "runtime/hdfs-fs-cache.h"
#include "write-stream.inline.h"
#include "common/names.h"

Include dependency graph for hdfs-avro-table-writer.cc:

Go to the source code of this file.

Variables
const uint8_t	OBJ1 [4] = {'O', 'b', 'j', 1}
const char *	AVRO_SCHEMA_STR = "avro.schema"
const char *	AVRO_CODEC_STR = "avro.codec"
const THdfsCompression::type	AVRO_DEFAULT_CODEC = THdfsCompression::SNAPPY
const int	DEFAULT_AVRO_BLOCK_SIZE = 64 * 1024

Variable Documentation

const char* AVRO_CODEC_STR = "avro.codec"

Definition at line 43 of file hdfs-avro-table-writer.cc.

Referenced by impala::HdfsAvroTableWriter::WriteFileHeader().

const THdfsCompression::type AVRO_DEFAULT_CODEC = THdfsCompression::SNAPPY

Definition at line 44 of file hdfs-avro-table-writer.cc.

Referenced by impala::HdfsAvroTableWriter::Init().

const char* AVRO_SCHEMA_STR = "avro.schema"

Definition at line 42 of file hdfs-avro-table-writer.cc.

Referenced by impala::HdfsAvroTableWriter::WriteFileHeader().

const int DEFAULT_AVRO_BLOCK_SIZE = 64 * 1024

Definition at line 47 of file hdfs-avro-table-writer.cc.

Referenced by impala::HdfsAvroTableWriter::AppendRowBatch().

const uint8_t OBJ1[4] = {'O', 'b', 'j', 1}

Definition at line 41 of file hdfs-avro-table-writer.cc.

Referenced by impala::HdfsAvroTableWriter::WriteFileHeader().