Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/292#discussion_r68177086
--- 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 --
It seems this is now deprecated and optimization will happen automatically.
Will remove this from the changes.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
