|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface RecordProcessor
A custom Java business logic piece that can be implemented by the user and passed to a TableInput
.
Here we can implement a custom filter or processor without needing to use the Hadoop/Pangool API directly.
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.
Method Summary | |
---|---|
com.datasalt.pangool.io.ITuple |
process(com.datasalt.pangool.io.ITuple record,
CounterInterface context)
Custom Java business logic can be implemented here. |
Method Detail |
---|
com.datasalt.pangool.io.ITuple process(com.datasalt.pangool.io.ITuple record, CounterInterface context) throws java.lang.Throwable
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.
java.lang.Throwable
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |