public void operateOnSomeRows(
RowIterator inputIterator,
RowEmitter outputEmitter
)
{
while ( inputIterator.advanceToNextRow() )
{
String[] parts = splitPattern_.split( inputIterator.getStringAt(0) );
for (String part : parts)
{
outputEmitter.addString(part);
outputEmitter.addInt(1);
outputEmitter.emitRow();
}
}
}
See the examples/ directory in the SQL-MapReduce SDK for sample SQL-MapReduce functions, as well as a Makefile to build and package them. For reference information on the SQL-MapReduce API, see the Javadoc reference in the SDK bundle.