com.splout.db.hadoop
Class IdentityRecordProcessor

java.lang.Object
  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