carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravipes...@apache.org
Subject [4/4] incubator-carbondata git commit: [CARBONDATA-308] Use CarbonInputFormat in CarbonScanRDD compute This closes #262
Date Fri, 25 Nov 2016 10:21:04 GMT
[CARBONDATA-308] Use CarbonInputFormat in CarbonScanRDD compute This closes #262


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

Branch: refs/heads/master
Commit: e05c0d5da95e503e532aca5833c99f2f51021dc4
Parents: 5c697e9 5f6a56c
Author: ravipesala <ravi.pesala@gmail.com>
Authored: Fri Nov 25 15:50:37 2016 +0530
Committer: ravipesala <ravi.pesala@gmail.com>
Committed: Fri Nov 25 15:50:37 2016 +0530

----------------------------------------------------------------------
 .../carbon/datastore/block/Distributable.java   |   8 +-
 .../carbon/datastore/block/TableBlockInfo.java  |   3 +-
 .../carbon/datastore/block/TableTaskInfo.java   |   2 +-
 .../scan/filter/FilterExpressionProcessor.java  |  29 +-
 .../examples/DataFrameAPIExample.scala          |   5 +-
 .../carbondata/hadoop/CarbonInputFormat.java    | 334 +++++-----------
 .../carbondata/hadoop/CarbonInputSplit.java     | 112 +++++-
 .../hadoop/CarbonMultiBlockSplit.java           | 105 +++++
 .../carbondata/hadoop/CarbonRecordReader.java   |  34 +-
 .../hadoop/readsupport/CarbonReadSupport.java   |   2 +-
 .../AbstractDictionaryDecodedReadSupport.java   |   2 +-
 .../impl/ArrayWritableReadSupport.java          |   2 +-
 .../readsupport/impl/RawDataReadSupport.java    |   6 +-
 .../hadoop/util/CarbonInputFormatUtil.java      |  14 +
 .../hadoop/ft/CarbonInputMapperTest.java        |  15 +-
 .../carbondata/spark/load/CarbonLoaderUtil.java |  99 +----
 .../spark/merger/CarbonDataMergerUtil.java      |  11 +-
 .../readsupport/SparkRowReadSupportImpl.java    |   9 +-
 .../carbondata/spark/util/LoadMetadataUtil.java |   4 +-
 .../spark/rdd/CarbonDataRDDFactory.scala        |  20 +-
 .../carbondata/spark/rdd/CarbonMergerRDD.scala  | 151 +++-----
 .../carbondata/spark/rdd/CarbonScanRDD.scala    | 387 ++++++++-----------
 .../apache/carbondata/spark/rdd/Compactor.scala |  13 +-
 .../carbondata/spark/util/QueryPlanUtil.scala   |  56 ---
 .../sql/CarbonDatasourceHadoopRelation.scala    |  20 +-
 .../spark/sql/CarbonDatasourceRelation.scala    |   3 +-
 .../org/apache/spark/sql/CarbonOperators.scala  | 191 ---------
 .../scala/org/apache/spark/sql/CarbonScan.scala | 186 +++++++++
 .../execution/command/carbonTableSchema.scala   |  20 +-
 .../spark/sql/hive/DistributionUtil.scala       |  21 +-
 .../AllDataTypesTestCaseAggregate.scala         |  20 +-
 .../CompactionSystemLockFeatureTest.scala       |  20 +-
 .../DataCompactionBoundaryConditionsTest.scala  |   3 -
 .../DataCompactionCardinalityBoundryTest.scala  |  10 +-
 .../datacompaction/DataCompactionLockTest.scala |  11 +-
 .../DataCompactionMinorThresholdTest.scala      |   6 +-
 .../DataCompactionNoDictionaryTest.scala        |  10 +-
 .../datacompaction/DataCompactionTest.scala     |  14 +-
 .../MajorCompactionIgnoreInMinorTest.scala      |  32 +-
 .../MajorCompactionStopsAfterCompaction.scala   |  14 +-
 .../dataretention/DataRetentionTestCase.scala   |   5 +-
 .../lcm/status/SegmentStatusManager.java        | 160 ++++----
 42 files changed, 964 insertions(+), 1205 deletions(-)
----------------------------------------------------------------------



Mime
View raw message