Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2081#discussion_r177973231
--- Diff:
examples/spark2/src/main/scala/org/apache/carbondata/examples/SparkSessionExample.scala
---
@@ -63,123 +63,126 @@ object SparkSessionExample {
sparksession.sparkContext.setLogLevel("ERROR")
- // Create table
- sparksession.sql("DROP TABLE IF EXISTS sparksession_table")
- sparksession.sql(
- s"""
- | CREATE TABLE sparksession_table(
- | shortField SHORT,
- | intField INT,
- | bigintField LONG,
- | doubleField DOUBLE,
- | stringField STRING,
- | timestampField TIMESTAMP,
- | decimalField DECIMAL(18,2),
- | dateField DATE,
- | charField CHAR(5)
- | )
- | USING org.apache.spark.sql.CarbonSource
- | OPTIONS('DICTIONARY_INCLUDE'='dateField, charField',
- | 'dbName'='default', 'tableName'='sparksession_table')
+ for (keyWord <- Array("org.apache.spark.sql.CarbonSource",
"carbondata")) {
--- End diff --
I think this makes it more complex, just use `carbondata` is enough
---
