carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chenliang...@apache.org
Subject [3/3] incubator-carbondata git commit: [CARBONDATA-571][CARBONDATA-572] Clean up code for carbon spark integration This closes #484
Date Wed, 04 Jan 2017 09:15:48 GMT
[CARBONDATA-571][CARBONDATA-572] Clean up code for carbon spark integration This closes #484


Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/af956f53
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/af956f53
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/af956f53

Branch: refs/heads/master
Commit: af956f533eca6c847266fad18c8085b9ab12a0ad
Parents: b966043 7b8b195
Author: chenliang613 <chenliang613@apache.org>
Authored: Wed Jan 4 17:15:21 2017 +0800
Committer: chenliang613 <chenliang613@apache.org>
Committed: Wed Jan 4 17:15:21 2017 +0800

----------------------------------------------------------------------
 .../scan/executor/impl/DetailQueryExecutor.java |  13 ++-
 .../impl/VectorDetailQueryExecutor.java         |  11 +-
 .../scan/executor/util/QueryUtil.java           |   4 +-
 .../carbondata/scan/filter/FilterUtil.java      |   6 +-
 .../AbstractDetailQueryResultIterator.java      |   2 +-
 .../iterator/DetailQueryResultIterator.java     |   2 +-
 .../VectorDetailQueryResultIterator.java        |   2 +-
 .../MalformedCarbonCommandException.java        |  14 ---
 .../carbondata/spark/load/CarbonLoaderUtil.java |  18 ++-
 .../spark/load/DeleteLoadFolders.java           |  54 +--------
 .../spark/load/DeletedLoadMetadata.java         |  53 ---------
 .../spark/merger/CarbonCompactionExecutor.java  |  35 +-----
 .../spark/merger/CarbonDataMergerUtil.java      |  48 +-------
 .../spark/merger/RowResultMerger.java           |   8 +-
 .../spark/merger/TupleConversionAdapter.java    |   6 +-
 .../spark/partition/api/DataPartitioner.java    |  19 +--
 .../spark/partition/api/Partition.java          |   5 -
 .../api/impl/DataPartitionerProperties.java     |  87 --------------
 .../partition/api/impl/DefaultLoadBalancer.java |   4 -
 .../spark/partition/api/impl/PartitionImpl.java |  54 ---------
 .../api/impl/PartitionMultiFileImpl.java        |   5 -
 .../api/impl/QueryPartitionHelper.java          |   3 +-
 .../api/impl/SampleDataPartitionerImpl.java     | 117 +------------------
 .../carbondata/spark/util/CarbonQueryUtil.java  |  14 +--
 .../apache/carbondata/spark/CarbonFilters.scala | 104 +++++++++++------
 .../spark/rdd/CarbonDataLoadRDD.scala           |  10 +-
 .../spark/rdd/CarbonDeleteLoadByDateRDD.scala   |   4 +-
 .../spark/rdd/CarbonGlobalDictionaryRDD.scala   |  36 +++---
 .../carbondata/spark/rdd/CarbonMergerRDD.scala  |   6 +-
 .../spark/rdd/DataLoadPartitionCoalescer.scala  |   8 +-
 .../spark/rdd/NewCarbonDataLoadRDD.scala        |  59 +++++-----
 .../spark/util/GlobalDictionaryUtil.scala       |   5 +-
 .../spark/sql/catalyst/CarbonDDLSqlParser.scala |  35 +++---
 .../CarbonTableIdentifierImplicit.scala         |   2 +-
 .../spark/rdd/CarbonDataRDDFactory.scala        |   1 -
 .../spark/sql/CarbonDatasourceRelation.scala    |  10 +-
 .../spark/sql/CarbonDictionaryDecoder.scala     |   2 +-
 .../scala/org/apache/spark/sql/CarbonScan.scala |   3 +-
 .../spark/sql/SparkUnknownExpression.scala      |   9 +-
 .../execution/command/carbonTableSchema.scala   |   9 +-
 .../spark/sql/optimizer/CarbonOptimizer.scala   |  15 ++-
 .../DataCompactionBlockletBoundryTest.scala     |   3 +-
 .../DataCompactionBoundaryConditionsTest.scala  |   1 +
 .../DataCompactionCardinalityBoundryTest.scala  |  12 +-
 .../datacompaction/DataCompactionLockTest.scala |   3 +-
 .../DataCompactionNoDictionaryTest.scala        |   5 +-
 .../datacompaction/DataCompactionTest.scala     |  12 +-
 .../MajorCompactionIgnoreInMinorTest.scala      |   1 +
 .../MajorCompactionStopsAfterCompaction.scala   |   1 +
 .../spark/util/DictionaryTestCaseUtil.scala     |   3 +-
 .../spark/rdd/CarbonDataRDDFactory.scala        |   1 -
 51 files changed, 248 insertions(+), 696 deletions(-)
----------------------------------------------------------------------



Mime
View raw message