com.splout.db.hadoop
Class IdentityRecordProcessor

java.lang.Object
  extended by com.splout.db.hadoop.IdentityRecordProcessor
All Implemented Interfaces:
RecordProcessor, java.io.Serializable

public class IdentityRecordProcessor
extends java.lang.Object
implements RecordProcessor

This is the default RecordProcessor that just bypasses the Tuples comming in from the input files. Thus, it is expected that the Schema in the TableInput files matches the Schema of the Table that will be produced by the TablespaceGenerator.

See Also:
Serialized Form

Constructor Summary
IdentityRecordProcessor()
           
 
Method Summary
 com.datasalt.pangool.io.ITuple process(com.datasalt.pangool.io.ITuple record, CounterInterface context)
          Custom Java business logic can be implemented here.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

IdentityRecordProcessor

public IdentityRecordProcessor()
Method Detail

process

public com.datasalt.pangool.io.ITuple process(com.datasalt.pangool.io.ITuple record,
                                              CounterInterface context)
                                       throws java.lang.Throwable
Description copied from interface: RecordProcessor
Custom Java business logic can be implemented here. The record contains the parsed fields and can be manipulated. The return can be used to filter out the record if needed (by returning null). So, this function serves as both a filter and a custom record processor.

The input Tuple will have the Schema of the file being processed. The returned Tuple must have the same Schema than the Table being created.

Specified by:
process in interface RecordProcessor
Throws:
java.lang.Throwable


Copyright © 2012-2013 Datasalt Systems S.L.. All Rights Reserved.