gistfile1.txt

public class FilterDynamicSchemaProcessor extends FilterDynamicSchemaProcessor implements DynamicSchemaProcessor {
	
	@Override
	protected String filter(String schemaUrl, PropertyList connectInfo, InputStream is) throws Exception {
		String schema = super.filter(schemaUrl, connectInfo, is);
		System.out.println("FilterDynamicSchemaProcessor filter() called");
    String schema = super.filter(schemaUrl, connectInfo, stream);
    try 
    {
        schema = schema.replaceAll("%USER_ID%", "abcd");
    }
    catch (PatternSyntaxException pse) 
    {
        pse.printStackTrace();
    }
    System.out.println("Inside DynamicSchemaProcessor Filter");
    return schema;
	}

}