[CALCITE-1716] Fix Cassandra integration tests
Project: http://git-wip-us.apache.org/repos/asf/calcite/repo Commit: http://git-wip-us.apache.org/repos/asf/calcite/commit/9c8b5979 Tree: http://git-wip-us.apache.org/repos/asf/calcite/tree/9c8b5979 Diff: http://git-wip-us.apache.org/repos/asf/calcite/diff/9c8b5979 Branch: refs/heads/branch-1.12 Commit: 9c8b5979754855d06226f6c3879aee04cabcb3af Parents: 1e405d6 Author: Michael Mior <[email protected]> Authored: Mon Mar 20 17:19:37 2017 -0400 Committer: Michael Mior <[email protected]> Committed: Mon Mar 20 17:19:37 2017 -0400 ---------------------------------------------------------------------- .../test/java/org/apache/calcite/test/CassandraAdapterIT.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/calcite/blob/9c8b5979/cassandra/src/test/java/org/apache/calcite/test/CassandraAdapterIT.java ---------------------------------------------------------------------- diff --git a/cassandra/src/test/java/org/apache/calcite/test/CassandraAdapterIT.java b/cassandra/src/test/java/org/apache/calcite/test/CassandraAdapterIT.java index f1e87ff..bca9233 100644 --- a/cassandra/src/test/java/org/apache/calcite/test/CassandraAdapterIT.java +++ b/cassandra/src/test/java/org/apache/calcite/test/CassandraAdapterIT.java @@ -71,7 +71,7 @@ public class CassandraAdapterIT { .returns("username=!PUBLIC!; time=e8754000-80b8-1fe9-8e73-e3698c967ddd; " + "tweet_id=f3c329de-d05b-11e5-b58b-90e2ba530b12\n") .explainContains("PLAN=CassandraToEnumerableConverter\n" - + " CassandraFilter(condition=[=(CAST($0):VARCHAR(8) CHARACTER SET \"ISO-8859-1\" COLLATE \"ISO-8859-1$en_US$primary\", '!PUBLIC!')])\n" + + " CassandraFilter(condition=[=($0, '!PUBLIC!')])\n" + " CassandraTableScan(table=[[twissandra, userline]]"); } @@ -96,7 +96,7 @@ public class CassandraAdapterIT { .returnsCount(146) .explainContains("PLAN=CassandraToEnumerableConverter\n" + " CassandraSort(sort0=[$1], dir0=[DESC])\n" - + " CassandraFilter(condition=[=(CAST($0):VARCHAR(8) CHARACTER SET \"ISO-8859-1\" COLLATE \"ISO-8859-1$en_US$primary\", '!PUBLIC!')])\n"); + + " CassandraFilter(condition=[=($0, '!PUBLIC!')])\n"); } @Test public void testProject() { @@ -109,7 +109,7 @@ public class CassandraAdapterIT { .explainContains("PLAN=CassandraToEnumerableConverter\n" + " CassandraLimit(fetch=[2])\n" + " CassandraProject(tweet_id=[$2])\n" - + " CassandraFilter(condition=[=(CAST($0):VARCHAR(8) CHARACTER SET \"ISO-8859-1\" COLLATE \"ISO-8859-1$en_US$primary\", '!PUBLIC!')])\n"); + + " CassandraFilter(condition=[=($0, '!PUBLIC!')])\n"); } @Test public void testProjectAlias() {
