[
https://issues.apache.org/jira/browse/APEXMALHAR-1957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15328582#comment-15328582
]
ASF GitHub Bot commented on APEXMALHAR-1957:
--------------------------------------------
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/292#discussion_r66886409
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/hbase/HBaseScanOperator.java ---
@@ -79,4 +170,79 @@ public void emitTuples()
*/
protected abstract T getTuple(Result result);
+ /**
+ * Returns the start row key in the table as set previously
+ * @return {@link #startRow}
+ */
+ public String getStartRow()
+ {
+ return startRow;
+ }
+
+ /**
+ * Sets the start row key in the table from where the scan should begin
+ * @param startRow
+ */
+ public void setStartRow(String startRow)
+ {
+ this.startRow = startRow;
+ }
+
+ /**
+ * Returns the end row key in the table as set previously
+ * @return {@link #endRow}
+ */
+ public String getEndRow()
+ {
+ return endRow;
+ }
+
+ /**
+ * Sets the end row key in the table where the scan should end
+ * @param endRow
+ */
+ public void setEndRow(String endRow)
+ {
+ this.endRow = endRow;
+ }
+
+ /**
+ * Returns the last read row key from the hbase table
+ * @return {@link #lastReadRow}
+ */
+ public String getLastReadRow()
+ {
+ return lastReadRow;
+ }
+
+ /**
+ * Sets the last read row key from the hbase table. After the failures,
the new scan will start from this row key
+ * @param lastReadRow
+ */
+ public void setLastReadRow(String lastReadRow)
+ {
+ this.lastReadRow = lastReadRow;
+ }
+
+ /**
+ * Returns the Scan HINT_LOOKAHEAD parameter as configured. Default is
{@value #DEF_HINT_SCAN_LOOKAHEAD}
--- End diff --
Can you please check once that HINT_LOOKAHEAD feature is available in all
HBase client and server versions?
If not, can you please describe this operator as works best for certain
version and above for all other versions this field will be ignored?
> Improve HBasePOJOInputOperator with support for threaded read
> -------------------------------------------------------------
>
> Key: APEXMALHAR-1957
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-1957
> Project: Apache Apex Malhar
> Issue Type: Task
> Reporter: Bhupesh Chawda
> Assignee: Bhupesh Chawda
>
> Add the following support to Hbase POJO Input Operator:
> * Add support for threaded read
> * Allow to specify a set of "column family: column" and fetch data only for
> these columns
> * Allow to specify an end row key to stop scanning
> * Add metrics
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
