Sha256: 7b40bab69a2a725f630ad5d39e07745896c5eb222184503477acb665013e3eea
Contents?: true
Size: 792 Bytes
Versions: 7
Compression:
Stored size: 792 Bytes
Contents
package org.embulk.filter.row;
import org.embulk.filter.row.RowFilterPlugin.PluginTask;
import org.embulk.filter.row.where.ParserExp;
import org.embulk.spi.Exec;
import org.embulk.spi.PageReader;
import org.embulk.spi.Schema;
import org.slf4j.Logger;
class GuardColumnVisitorWhereImpl
extends AbstractGuardColumnVisitor
{
private static final Logger logger = Exec.getLogger(RowFilterPlugin.class);
ParserExp parserExp;
GuardColumnVisitorWhereImpl(PluginTask task, Schema inputSchema, Schema outputSchema, PageReader pageReader, ParserExp parserExp)
{
super(task, inputSchema, outputSchema, pageReader);
this.parserExp = parserExp;
}
public boolean visitColumns(Schema inputSchema)
{
return parserExp.eval(pageReader);
}
}
Version data entries
7 entries across 7 versions & 1 rubygems