You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2016/01/11 21:31:08 UTC
[4/6] storm git commit: STORM-1348 - Fix tests added with STORM-1211
STORM-1348 - Fix tests added with STORM-1211
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/0702f54d
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/0702f54d
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/0702f54d
Branch: refs/heads/master
Commit: 0702f54d72e1d18411fc24c9019e3e88b7d35e81
Parents: 054a7f3
Author: Florian Hussonnois <fl...@gmail.com>
Authored: Mon Dec 14 11:43:19 2015 +0100
Committer: Florian Hussonnois <fl...@gmail.com>
Committed: Mon Dec 14 11:57:22 2015 +0100
----------------------------------------------------------------------
.../apache/storm/cassandra/trident/TridentTopologyTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/0702f54d/external/storm-cassandra/src/test/java/org/apache/storm/cassandra/trident/TridentTopologyTest.java
----------------------------------------------------------------------
diff --git a/external/storm-cassandra/src/test/java/org/apache/storm/cassandra/trident/TridentTopologyTest.java b/external/storm-cassandra/src/test/java/org/apache/storm/cassandra/trident/TridentTopologyTest.java
index c775919..bdacfe4 100644
--- a/external/storm-cassandra/src/test/java/org/apache/storm/cassandra/trident/TridentTopologyTest.java
+++ b/external/storm-cassandra/src/test/java/org/apache/storm/cassandra/trident/TridentTopologyTest.java
@@ -45,7 +45,6 @@ import java.util.Random;
import static org.apache.storm.cassandra.DynamicStatementBuilder.boundQuery;
import static org.apache.storm.cassandra.DynamicStatementBuilder.field;
-import static org.apache.storm.cassandra.DynamicStatementBuilder.with;
/**
*
@@ -109,7 +108,8 @@ public class TridentTopologyTest extends BaseTopologyTest {
CassandraState.Options options = new CassandraState.Options(new CassandraContext());
CQLStatementTupleMapper insertTemperatureValues = boundQuery(
"INSERT INTO weather.temperature(weather_station_id, weather_station_name, event_time, temperature) VALUES(?, ?, ?, ?)")
- .bind(with(field("weather_station_id"), field("name").as("weather_station_name"), field("event_time").now(), field("temperature")));
+ .bind(field("weather_station_id"), field("name").as("weather_station_name"), field("event_time").now(), field("temperature"))
+ .build();
options.withCQLStatementTupleMapper(insertTemperatureValues);
return new CassandraStateFactory(options);
}
@@ -117,7 +117,7 @@ public class TridentTopologyTest extends BaseTopologyTest {
public CassandraStateFactory getSelectWeatherStationStateFactory() {
CassandraState.Options options = new CassandraState.Options(new CassandraContext());
CQLStatementTupleMapper insertTemperatureValues = boundQuery("SELECT name FROM weather.station WHERE id = ?")
- .bind(with(field("weather_station_id").as("id")));
+ .bind(field("weather_station_id").as("id")).build();
options.withCQLStatementTupleMapper(insertTemperatureValues);
options.withCQLResultSetValuesMapper(new TridentResultSetValuesMapper(new Fields("name")));
return new CassandraStateFactory(options);