|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.splout.db.hadoop.IdentityRecordProcessor
public class IdentityRecordProcessor
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
.
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 |
---|
public IdentityRecordProcessor()
Method Detail |
---|
public com.datasalt.pangool.io.ITuple process(com.datasalt.pangool.io.ITuple record, CounterInterface context) throws java.lang.Throwable
RecordProcessor
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.
process
in interface RecordProcessor
java.lang.Throwable
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |