You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ja...@apache.org on 2017/05/08 09:48:16 UTC
[04/14] incubator-carbondata git commit: fix style error
fix style error
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/58883d6c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/58883d6c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/58883d6c
Branch: refs/heads/12-dev
Commit: 58883d6c3937dacc7976f972cbbd5351fb910c6e
Parents: 981a325
Author: lionelcao <wh...@gmail.com>
Authored: Thu Apr 27 11:24:32 2017 +0800
Committer: lionelcao <wh...@gmail.com>
Committed: Thu May 4 15:29:47 2017 +0800
----------------------------------------------------------------------
.../examples/CarbonPartitionExample.scala | 18 ++++++++++--------
1 file changed, 10 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/58883d6c/examples/spark2/src/main/scala/org/apache/carbondata/examples/CarbonPartitionExample.scala
----------------------------------------------------------------------
diff --git a/examples/spark2/src/main/scala/org/apache/carbondata/examples/CarbonPartitionExample.scala b/examples/spark2/src/main/scala/org/apache/carbondata/examples/CarbonPartitionExample.scala
index 96c1c72..86f3553 100644
--- a/examples/spark2/src/main/scala/org/apache/carbondata/examples/CarbonPartitionExample.scala
+++ b/examples/spark2/src/main/scala/org/apache/carbondata/examples/CarbonPartitionExample.scala
@@ -48,10 +48,10 @@ object CarbonPartitionExample {
spark.sparkContext.setLogLevel("WARN")
- spark.sql("DROP TABLE IF EXISTS non_partition_table")
+ spark.sql("DROP TABLE IF EXISTS t1")
spark.sql("""
- | CREATE TABLE IF NOT EXISTS non_partition_table
+ | CREATE TABLE IF NOT EXISTS t1
| (
| vin String,
| logdate Timestamp,
@@ -62,10 +62,10 @@ object CarbonPartitionExample {
| STORED BY 'carbondata'
""".stripMargin)
- spark.sql("DROP TABLE IF EXISTS partition_table")
+ spark.sql("DROP TABLE IF EXISTS t3")
spark.sql("""
- | CREATE TABLE IF NOT EXISTS partition_table
+ | CREATE TABLE IF NOT EXISTS t3
| (
| vin String,
| logdate Timestamp,
@@ -78,14 +78,16 @@ object CarbonPartitionExample {
| TBLPROPERTIES('PARTITIONING'='HASH','PARTITIONCOUNT'='5')
""".stripMargin)
- //spark.sql(s"""
- // LOAD DATA LOCAL INPATH '$testData' into table rx5_tbox_parquet_all options('BAD_RECORDS_ACTION'='FORCE')
+ // spark.sql(s"""
+ // LOAD DATA LOCAL INPATH '$testData' into table t3
+ // options('BAD_RECORDS_ACTION'='FORCE')
// """)
- //spark.sql("select vin, count(*) from rx5_tbox_parquet_all group by vin order by count(*) desc").show(50)
+ // spark.sql("select vin, count(*) from t3 group by vin
+ // order by count(*) desc").show(50)
// Drop table
- //spark.sql("DROP TABLE IF EXISTS carbon_table")
+ // spark.sql("DROP TABLE IF EXISTS t3")
}
}