Uses of Interface
com.splout.db.hadoop.RecordProcessor

Packages that use RecordProcessor

com.splout.db.examples
com.splout.db.hadoop	This package contains all the classes that implement business logic for helping building Splout datastores using Hadoop with Pangool (http://pangool.net).

Uses of RecordProcessor in com.splout.db.examples

Classes in com.splout.db.examples that implement RecordProcessor

class

PageCountsRecordProcessor Custom record processor that filters out some records and URL-Decodes a field.

Uses of RecordProcessor in com.splout.db.hadoop

Classes in com.splout.db.hadoop that implement RecordProcessor

class

IdentityRecordProcessor This is the default RecordProcessor that just bypasses the Tuples comming in from the input files.

Methods in com.splout.db.hadoop that return RecordProcessor

RecordProcessor

TableInput.getRecordProcessor()

Methods in com.splout.db.hadoop with parameters of type RecordProcessor

TableBuilder	TableBuilder.addCSVTextFile(org.apache.hadoop.fs.Path path, char separator, char quoteCharacter, char escapeCharacter, boolean hasHeader, boolean strictQuotes, java.lang.String nullString, com.datasalt.pangool.io.Schema fileSchema, RecordProcessor recordProcessor)
TableBuilder	TableBuilder.addCSVTextFile(org.apache.hadoop.fs.Path path, com.datasalt.pangool.io.Schema fileSchema, RecordProcessor recordProcessor)
TableBuilder	TableBuilder.addCSVTextFile(java.lang.String path, char separator, char quoteCharacter, char escapeCharacter, boolean hasHeader, boolean strictQuotes, java.lang.String nullString, com.datasalt.pangool.io.Schema fileSchema, RecordProcessor recordProcessor)
TableBuilder	TableBuilder.addCSVTextFile(java.lang.String path, com.datasalt.pangool.io.Schema fileSchema, RecordProcessor recordProcessor)
TableBuilder	TableBuilder.addCustomInputFormatFile(org.apache.hadoop.fs.Path path, org.apache.hadoop.mapreduce.InputFormat<com.datasalt.pangool.io.ITuple,org.apache.hadoop.io.NullWritable> inputFormat, java.util.Map<java.lang.String,java.lang.String> specificContext, RecordProcessor recordProcessor)
TableBuilder	TableBuilder.addCustomInputFormatFile(org.apache.hadoop.fs.Path path, org.apache.hadoop.mapreduce.InputFormat<com.datasalt.pangool.io.ITuple,org.apache.hadoop.io.NullWritable> inputFormat, RecordProcessor recordProcessor)
TableBuilder	TableBuilder.addFixedWidthTextFile(org.apache.hadoop.fs.Path path, com.datasalt.pangool.io.Schema schema, int[] fields, boolean hasHeader, java.lang.String nullString, RecordProcessor recordProcessor)
TableBuilder	TableBuilder.addTupleFile(org.apache.hadoop.fs.Path path, RecordProcessor recordProcessor)