HBase Input Operators

[Bhupesh Chawda]

Hi All,

Any reason why the HBase input operators in Apex Malhar - contrib are doing
the entire table scan in the emitTuples() method. Shouldn't this just
return a single row each time? The current way seems to be sending the
entire table in a single call of emitTuples().

Here is the code fragment from HBaseScanOperator:

  @Override
>   public void emitTuples()
>   {
>     try {
>       HTable table = getTable();
>       Scan scan = operationScan();
>       ResultScanner scanner = table.getScanner(scan);
>       for (Result result : scanner) {
>         //KeyValue[] kvs = result.raw();
>         //T t = getTuple(kvs);
>         T t = getTuple(result);
>         outputPort.emit(t);
>       }
>     } catch (Exception e) {
>       e.printStackTrace();
>     }
>   }
>
>
Thanks.
Bhupesh