public class SimpleReadSupport extends ReadSupport<SimpleRecord>
ReadSupport.ReadContext
PARQUET_READ_SCHEMA
Constructor and Description |
---|
SimpleReadSupport() |
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 |
getSchemaForRead, getSchemaForRead, init
public RecordMaterializer<SimpleRecord> prepareForRead(org.apache.hadoop.conf.Configuration conf, Map<String,String> metaData, MessageType schema, ReadSupport.ReadContext context)
ReadSupport
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 destinationprepareForRead
in class ReadSupport<SimpleRecord>
conf
- the job configurationmetaData
- the app specific metadata from the fileschema
- the schema of the filecontext
- returned by the init methodpublic ReadSupport.ReadContext init(InitContext context)
ReadSupport
InputFormat.getSplits(org.apache.hadoop.mapreduce.JobContext)
in the front endinit
in class ReadSupport<SimpleRecord>
context
- the initialisation contextCopyright © 2015. All rights reserved.