gistfile1.txt

    @Override
    public TupleEntryIterator openForRead(FlowProcess<JobConf> flowProcess,
                                          RecordReader input)

            throws IOException  {

        System.out.println("[CustomTap] => openForRead()");
        this.table = new HTable(flowProcess.getConfigCopy(), tableName) ;


        System.out.println("Set scan filters based record reader...");

        TableRecordReader scanBasedRecordReader = new TableRecordReader();
        scanBasedRecordReader.setHTable(this.table);
        scanBasedRecordReader.setScan(tableScan);

        TupleEntryIterator storeTableScanIterator = new HadoopTupleEntrySchemeIterator( flowProcess,
                                                                                        this,
                                                                                        scanBasedRecordReader );


        return storeTableScanIterator;
    }