parquet.tools.read

Class SimpleReadSupport

java.lang.Object

parquet.hadoop.api.ReadSupport<SimpleRecord>

parquet.tools.read.SimpleReadSupport

public class SimpleReadSupport
extends ReadSupport<SimpleRecord>

Nested Class Summary

Nested classes/interfaces inherited from class parquet.hadoop.api.ReadSupport

ReadSupport.ReadContext

Field Summary

Fields inherited from class parquet.hadoop.api.ReadSupport

PARQUET_READ_SCHEMA

Constructor Summary

Constructors

Constructor and Description
SimpleReadSupport()

Method Summary

Modifier and Type	Method and Description
ReadSupport.ReadContext	init(InitContext context) called in InputFormat.getSplits(org.apache.hadoop.mapreduce.JobContext) in the front end
RecordMaterializer<SimpleRecord>	prepareForRead(org.apache.hadoop.conf.Configuration conf, Map<String,String> metaData, MessageType schema, ReadSupport.ReadContext context) called in RecordReader.initialize(org.apache.hadoop.mapreduce.InputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext) in the back end the returned RecordConsumer will materialize the records and add them to the destination

Methods inherited from class parquet.hadoop.api.ReadSupport

getSchemaForRead, getSchemaForRead, init

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleReadSupport

public SimpleReadSupport()

Method Detail

prepareForRead

public RecordMaterializer<SimpleRecord> prepareForRead(org.apache.hadoop.conf.Configuration conf,
                                                       Map<String,String> metaData,
                                                       MessageType schema,
                                                       ReadSupport.ReadContext context)

Description copied from class: ReadSupport

called in RecordReader.initialize(org.apache.hadoop.mapreduce.InputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext) in the back end the returned RecordConsumer will materialize the records and add them to the destination

Specified by:

prepareForRead in class ReadSupport<SimpleRecord>

Parameters:

conf - the job configuration

metaData - the app specific metadata from the file

schema - the schema of the file

context - returned by the init method

Returns:

the recordConsumer that will receive the events

init

public ReadSupport.ReadContext init(InitContext context)

Description copied from class: ReadSupport

called in InputFormat.getSplits(org.apache.hadoop.mapreduce.JobContext) in the front end

Overrides:

init in class ReadSupport<SimpleRecord>

Parameters:

context - the initialisation context

Returns:

the readContext that defines how to read the file