class Embulk::FilterPlugin

def self.from_java(java_class)
  JavaPlugin.ruby_adapter_class(java_class, FilterPlugin, RubyAdapter)
end

def self.new_java
  JavaAdapter.new(self)
end

def self.transaction(config, in_schema, &control)
  yield(config)
  return {}
end

def add(page)
  raise NotImplementedError, "FilterPlugin#add(page) must be implemented"
end

def close
end

def finish
end

def init
end

def initialize(task, in_schema, out_schema, page_builder)
  @task = task
  @in_schema = in_schema
  @out_schema = out_schema
  @page_builder = page_builder
  init
end