Skip to content

Commit

Permalink
SPARKC-385 fix formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
jtgrabowski committed May 25, 2016
1 parent 0b1c5aa commit df26b2d
Showing 1 changed file with 14 additions and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -134,22 +134,23 @@ class CassandraRDDSpec extends SparkCassandraITFlatSpecBase {
session.execute(s"""CREATE TABLE "MixedSpace"."MoxedCAs" (key INT PRIMARY KEY, value INT)""")
},
Future {
if (versionGreaterThanOrEquals(2,2)) {
if (versionGreaterThanOrEquals(2, 2)) {
session.execute(
s""" CREATE TABLE $ks.user(
id int PRIMARY KEY,
login text,
firstname text,
lastname text,
country text
)""")
s"""
|CREATE TABLE $ks.user(
| id int PRIMARY KEY,
| login text,
| firstname text,
| lastname text,
| country text)""".stripMargin)

session.execute(
s"""CREATE MATERIALIZED VIEW $ks.user_by_country
AS SELECT * //denormalize ALL columns
FROM user
WHERE country IS NOT NULL AND id IS NOT NULL
PRIMARY KEY(country, id);""")
s"""
|CREATE MATERIALIZED VIEW $ks.user_by_country
| AS SELECT * //denormalize ALL columns
| FROM user
| WHERE country IS NOT NULL AND id IS NOT NULL
| PRIMARY KEY(country, id);""".stripMargin)

session.execute(s"INSERT INTO $ks.user(id,login,firstname,lastname,country) VALUES(1, 'jdoe', 'John', 'DOE', 'US')")

Expand Down

0 comments on commit df26b2d

Please sign in to comment.