Repository: incubator-apex-malhar Updated Branches: refs/heads/master 9c11400a2 -> dc36b9896
Renaming a variable Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/802cfce2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/802cfce2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/802cfce2 Branch: refs/heads/master Commit: 802cfce223a6296b2a3a9d61a89d4461b7b96fed Parents: d094a04 Author: Priyanka Gugale <[email protected]> Authored: Thu May 12 16:59:29 2016 -0700 Committer: Priyanka Gugale <[email protected]> Committed: Tue May 17 14:31:14 2016 -0700 ---------------------------------------------------------------------- .../contrib/cassandra/CassandraPOJOInputOperator.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/802cfce2/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOInputOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOInputOperator.java index b7301cb..9c56178 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOInputOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPOJOInputOperator.java @@ -61,7 +61,7 @@ import com.datatorrent.lib.util.PojoUtils.*; @Evolving public class CassandraPOJOInputOperator extends AbstractCassandraInputOperator<Object> implements Operator.ActivationListener<OperatorContext> { - private String TOKEN_QUERY; + private String tokenQuery; @NotNull private List<FieldInfo> fieldInfos; private Number startRow; @@ -196,7 +196,7 @@ public class CassandraPOJOInputOperator extends AbstractCassandraInputOperator<O public void setup(OperatorContext context) { super.setup(context); - TOKEN_QUERY = "select token(" + primaryKeyColumn + ") from " + store.keyspace + "." + tablename + " where " + primaryKeyColumn + " = ?"; + tokenQuery = "select token(" + primaryKeyColumn + ") from " + store.keyspace + "." + tablename + " where " + primaryKeyColumn + " = ?"; } @Override @@ -371,7 +371,7 @@ public class CassandraPOJOInputOperator extends AbstractCassandraInputOperator<O private Long fetchKeyTokenFromDB(Object keyValue) { - PreparedStatement statement = store.getSession().prepare(TOKEN_QUERY); + PreparedStatement statement = store.getSession().prepare(tokenQuery); BoundStatement boundStatement = new BoundStatement(statement); boundStatement.bind(keyValue); ResultSet rs = store.getSession().execute(boundStatement);
