Adapter.java

Adapter.java

 public void open() {
    new Thread() {
                public void run() {
                    loadData((Schema)null, _file);
                }
    }.start();
}

@Override
    protected boolean processRecord(GenericRecord data) {
        adapterQueue.put(data);
        return true;
    }

protected AvroRecord read() {
        return adapterQueue.take();
}