[
https://issues.apache.org/jira/browse/APEXMALHAR-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190877#comment-15190877
]
ASF GitHub Bot commented on APEXMALHAR-1985:
--------------------------------------------
Github user DT-Priyanka commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/182#discussion_r55825610
--- Diff:
contrib/src/test/java/com/datatorrent/contrib/cassandra/CassandraOperatorTest.java
---
@@ -333,26 +333,26 @@ public void testCassandraInputOperator()
String query2 = "SELECT * FROM " + KEYSPACE + "." + "%t where
token(%p) > %v;";
inputOperator.setQuery(query2);
+ inputOperator.setStartRow(10);
inputOperator.setup(context);
inputOperator.outputPort.setup(tpc);
inputOperator.activate(context);
- inputOperator.setStartRow(10);
inputOperator.beginWindow(1);
inputOperator.emitTuples();
inputOperator.endWindow();
- Assert.assertEquals("rows from db", 14, sink.collectedTuples.size());
+ Assert.assertEquals("rows from db", 26, sink.collectedTuples.size());
sink.clear();
inputOperator.columnDataTypes.clear();
String query3 = "SELECT * FROM " + KEYSPACE + "." + "%t where
token(%p) > %v LIMIT %l;";
inputOperator.setQuery(query3);
+ inputOperator.setStartRow(1);
inputOperator.setup(context);
inputOperator.outputPort.setup(tpc);
inputOperator.activate(context);
- inputOperator.setStartRow(1);
inputOperator.setLimit(10);
--- End diff --
will change this.
> Cassandra Input Oeprator: startRow set incorrectly
> --------------------------------------------------
>
> Key: APEXMALHAR-1985
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-1985
> Project: Apache Apex Malhar
> Issue Type: Bug
> Reporter: Priyanka Gugale
> Assignee: Priyanka Gugale
>
> The CassandraInputOperator scans the table starting with StratRow, at end of
> each query, it updates start row to the last scanned row in current query.
> The query format is: select * from %t where token(%p) > %v limit %l
> Where %v is set to primary column value, but instead it should be set to
> token value of start row i.e.
> %v = token(startRow).
> Reference:
> http://mail-archives.apache.org/mod_mbox/cassandra-user/201308.mbox/%3cca+vsrlpezqsv_85yqqr-99f-q2pmv2laj825wzrl7meaf_j...@mail.gmail.com%3E
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
