Hack#48

MyMatches.java

package org.hadoophacks.pig;

import java.io.IOException;
import org.apache.pig.FilterFunc;
import org.apache.pig.data.Tuple;
import org.apache.pig.backend.executionengine.ExecException;


public class MyMatches extends FilterFunc{

    public Boolean exec(Tuple input)throws IOException{
	
	if(input == null || input.size() != 2){
	    return false;
	}
	try{
	    Object arg0 = input.get(0);
	    Object arg1 = input.get(1);

	    if(arg0 == null || arg1 == null || !(arg0 instanceof String) || !(arg1 instanceof String)){
		return false;
	    }
	    String str = (String)arg0;
	    String pattern = (String)arg1;

	    return str.matches(pattern);
	}
	catch(ExecException e){
	    throw new IOException(e);
	}
    }
}