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/06/28 16:41:05 UTC
[08/20] carbondata git commit: [CARBONDATA-1065] Added set command in
carbon to update properties dynamically. This closes #972
[CARBONDATA-1065] Added set command in carbon to update properties dynamically. This closes #972
Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/88522912
Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/88522912
Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/88522912
Branch: refs/heads/encoding_override
Commit: 88522912ba3248c349c7585c2ed75f70604972ef
Parents: 2234ec8 39644b5
Author: Venkata Ramana G <ra...@huawei.com>
Authored: Tue Jun 27 16:21:22 2017 +0530
Committer: Venkata Ramana G <ra...@huawei.com>
Committed: Tue Jun 27 16:21:22 2017 +0530
----------------------------------------------------------------------
.../common/constants/LoggerAction.java | 38 +++++
.../core/constants/CarbonCommonConstants.java | 100 ++++++++++-
.../constants/CarbonLoadOptionConstants.java | 88 ++++++++++
.../constants/CarbonV3DataFormatConstants.java | 5 +
.../InvalidConfigurationException.java | 87 ++++++++++
.../carbondata/core/util/CarbonProperties.java | 76 +++++++--
.../carbondata/core/util/CarbonProperty.java | 28 ++++
.../carbondata/core/util/CarbonSessionInfo.java | 38 +++++
.../apache/carbondata/core/util/CarbonUtil.java | 74 ++++++++-
.../carbondata/core/util/SessionParams.java | 141 ++++++++++++++++
.../core/util/ThreadLocalSessionInfo.java | 34 ++++
.../hadoop/ft/CarbonInputMapperTest.java | 5 +
.../carbondata/hadoop/ft/InputFilesTest.java | 5 +
.../dataload/TestGlobalSortDataLoad.scala | 6 +-
.../TestLoadDataWithDiffTimestampFormat.scala | 4 +-
.../carbondata/spark/load/ValidateUtil.scala | 8 +-
.../spark/rdd/AlterTableAddColumnRDD.scala | 5 +-
.../spark/rdd/AlterTableDropColumnRDD.scala | 5 +-
.../spark/rdd/CarbonCleanFilesRDD.scala | 5 +-
.../spark/rdd/CarbonDeleteLoadByDateRDD.scala | 4 +-
.../spark/rdd/CarbonDeleteLoadRDD.scala | 4 +-
.../spark/rdd/CarbonDropTableRDD.scala | 6 +-
.../spark/rdd/CarbonGlobalDictionaryRDD.scala | 19 +--
.../carbondata/spark/rdd/CarbonMergerRDD.scala | 4 +-
.../apache/carbondata/spark/rdd/CarbonRDD.scala | 46 ++++++
.../carbondata/spark/rdd/CarbonScanRDD.scala | 4 +-
.../spark/rdd/DataLoadCoalescedRDD.scala | 11 +-
.../spark/rdd/NewCarbonDataLoadRDD.scala | 25 ++-
.../spark/rdd/UpdateCoalescedRDD.scala | 7 +-
.../spark/sql/catalyst/CarbonDDLSqlParser.scala | 4 +-
.../spark/sql/test/TestQueryExecutor.scala | 1 +
.../spark/rdd/CarbonDataRDDFactory.scala | 2 +-
.../sql/CarbonDatasourceHadoopRelation.scala | 7 +-
.../execution/command/carbonTableSchema.scala | 19 ++-
.../spark/rdd/CarbonDataRDDFactory.scala | 2 +-
.../sql/CarbonDatasourceHadoopRelation.scala | 3 +
.../spark/sql/CarbonDictionaryDecoder.scala | 5 +-
.../scala/org/apache/spark/sql/CarbonEnv.scala | 19 ++-
.../execution/command/CarbonHiveCommands.scala | 34 +++-
.../sql/execution/command/DDLStrategy.scala | 12 +-
.../execution/command/carbonTableSchema.scala | 68 +++++---
.../spark/sql/hive/CarbonSessionState.scala | 2 +-
.../spark/sql/internal/CarbonSqlConf.scala | 144 ++++++++++++++++
.../spark/sql/parser/CarbonSparkSqlParser.scala | 15 +-
.../BadRecordPathLoadOptionTest.scala | 87 ++++++++++
.../DataLoadFailAllTypeSortTest.scala | 1 -
.../commands/SetCommandTestCase.scala | 165 +++++++++++++++++++
.../processing/constants/LoggerAction.java | 38 -----
.../processing/model/CarbonLoadModel.java | 14 ++
.../newflow/DataLoadProcessBuilder.java | 3 +
.../newflow/sort/SortScopeOptions.java | 17 +-
.../steps/DataConverterProcessorStepImpl.java | 25 ++-
...ConverterProcessorWithBucketingStepImpl.java | 23 ++-
.../util/CarbonDataProcessorUtil.java | 16 +-
.../carbon/datastore/BlockIndexStoreTest.java | 3 +-
55 files changed, 1404 insertions(+), 207 deletions(-)
----------------------------------------------------------------------