Sha256: 764f1f7a2158dfbe2a31023ce2b1299dbe657a095f4d7e02b4ca2d41e28ff986
Contents?: true
Size: 455 Bytes
Versions: 104
Compression:
Stored size: 455 Bytes
Contents
package org.embulk.spi;
import org.embulk.config.TaskSource;
import org.embulk.config.ConfigSource;
public interface FilterPlugin
{
interface Control
{
void run(TaskSource taskSource, Schema outputSchema);
}
void transaction(ConfigSource config, Schema inputSchema,
FilterPlugin.Control control);
PageOutput open(TaskSource taskSource, Schema inputSchema,
Schema outputSchema, PageOutput output);
}
Version data entries
104 entries across 104 versions & 1 rubygems