You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tajo.apache.org by ji...@apache.org on 2014/10/03 07:07:18 UTC
[2/9] git commit: Merge branch 'master' of
http://git-wip-us.apache.org/repos/asf/tajo into index_support
Merge branch 'master' of http://git-wip-us.apache.org/repos/asf/tajo into index_support
Project: http://git-wip-us.apache.org/repos/asf/tajo/repo
Commit: http://git-wip-us.apache.org/repos/asf/tajo/commit/6d6b968f
Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/6d6b968f
Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/6d6b968f
Branch: refs/heads/index_support
Commit: 6d6b968f3259acd5d6c82f41ae0e6945c68daa28
Parents: 31d524c 6dac6a5
Author: Jihoon Son <ji...@apache.org>
Authored: Mon Jul 21 11:44:57 2014 +0900
Committer: Jihoon Son <ji...@apache.org>
Committed: Mon Jul 21 11:44:57 2014 +0900
----------------------------------------------------------------------
CHANGES | 64 +++
.../tajo/catalog/statistics/ColumnStats.java | 10 +-
.../tajo/catalog/statistics/TableStats.java | 9 +-
.../tajo/catalog/statistics/TestTableStat.java | 55 ++
.../tajo-catalog-drivers/tajo-hcatalog/pom.xml | 4 +-
.../tajo/catalog/store/HCatalogStore.java | 25 +-
.../catalog/store/HCatalogStoreClientPool.java | 32 +-
.../java/org/apache/tajo/cli/HelpCommand.java | 58 ++-
.../main/java/org/apache/tajo/cli/TajoCli.java | 43 +-
.../java/org/apache/tajo/TajoConstants.java | 2 +-
.../java/org/apache/tajo/conf/TajoConf.java | 6 +
.../java/org/apache/tajo/util/KeyValueSet.java | 2 +-
tajo-common/src/main/proto/tajo_protos.proto | 1 +
.../tajo/engine/function/string/Concat.java | 16 +-
.../tajo/engine/function/string/Concat_ws.java | 25 +-
.../tajo/engine/planner/LogicalPlanner.java | 3 +-
.../engine/planner/PhysicalPlannerImpl.java | 1 +
.../engine/planner/PreLogicalPlanVerifier.java | 3 -
.../engine/planner/RangePartitionAlgorithm.java | 2 +-
.../planner/global/ExecutionBlockCursor.java | 131 ++++-
.../engine/planner/global/GlobalPlanner.java | 16 +-
.../tajo/engine/planner/global/MasterPlan.java | 11 +
.../planner/physical/ColPartitionStoreExec.java | 42 +-
.../DistinctGroupbyHashAggregationExec.java | 30 +-
.../HashBasedColPartitionStoreExec.java | 24 +-
.../planner/physical/HashLeftOuterJoinExec.java | 41 +-
.../physical/HashShuffleFileWriteExec.java | 1 +
.../SortBasedColPartitionStoreExec.java | 25 +-
.../planner/rewrite/ProjectionPushDownRule.java | 4 +-
.../org/apache/tajo/engine/utils/TupleUtil.java | 70 ++-
.../org/apache/tajo/master/GlobalEngine.java | 3 +
.../apache/tajo/master/querymaster/Query.java | 160 +++++-
.../master/querymaster/QueryMasterTask.java | 14 -
.../tajo/master/querymaster/QueryUnit.java | 13 +
.../master/querymaster/QueryUnitAttempt.java | 2 +-
.../tajo/master/querymaster/Repartitioner.java | 143 +++++-
.../tajo/master/querymaster/SubQuery.java | 22 +-
.../java/org/apache/tajo/worker/Fetcher.java | 119 +++--
.../main/java/org/apache/tajo/worker/Task.java | 61 ++-
.../apache/tajo/worker/TaskAttemptContext.java | 18 +
.../apache/tajo/worker/TaskRunnerHistory.java | 5 +-
.../src/main/proto/TajoWorkerProtocol.proto | 2 +
.../resources/webapps/admin/catalogview.jsp | 19 +-
.../java/org/apache/tajo/QueryTestCaseBase.java | 32 +-
.../TestStringOperatorsAndFunctions.java | 6 +
.../planner/global/TestBroadcastJoinPlan.java | 84 ++++
.../tajo/engine/query/TestCreateTable.java | 199 +++++---
.../tajo/engine/query/TestGroupByQuery.java | 85 +++-
.../tajo/engine/query/TestInsertQuery.java | 227 +++++++++
.../tajo/engine/query/TestJoinBroadcast.java | 26 +
.../apache/tajo/engine/query/TestJoinQuery.java | 56 +++
.../apache/tajo/engine/query/TestSortQuery.java | 49 ++
.../tajo/engine/query/TestTablePartitions.java | 219 ++++++++
.../org/apache/tajo/jdbc/TestResultSet.java | 3 +
.../querymaster/TestQueryUnitStatusUpdate.java | 4 +-
.../org/apache/tajo/worker/TestFetcher.java | 162 ++++--
.../testGroupByWithConstantKeys2.sql | 1 +
.../queries/TestInsertQuery/testInsertInto.sql | 1 +
.../testJoinFilterOfRowPreservedTable1.sql | 8 +
.../testGroupByWithConstantKeys1.result | 3 +
.../testGroupByWithConstantKeys2.result | 5 +
.../testJoinFilterOfRowPreservedTable1.result | 15 +
.../configuration/catalog_configuration.rst | 2 +-
.../org/apache/tajo/jdbc/TajoConnection.java | 2 +-
.../java/org/apache/tajo/rpc/TestAsyncRpc.java | 22 +-
tajo-storage/pom.xml | 4 +-
.../java/org/apache/tajo/storage/RawFile.java | 18 +-
.../org/apache/tajo/storage/RowStoreUtil.java | 1 +
.../org/apache/tajo/storage/StorageUtil.java | 83 ++-
.../apache/tajo/storage/TableStatistics.java | 5 +-
.../tajo/storage/parquet/TajoParquetReader.java | 2 +-
.../tajo/storage/parquet/TajoParquetWriter.java | 2 +-
.../org/apache/tajo/storage/rcfile/RCFile.java | 1 +
.../thirdparty/parquet/CodecFactory.java | 196 ++++++++
.../parquet/ColumnChunkPageWriteStore.java | 211 ++++++++
.../parquet/InternalParquetRecordReader.java | 187 +++++++
.../parquet/InternalParquetRecordWriter.java | 156 ++++++
.../thirdparty/parquet/ParquetFileWriter.java | 504 +++++++++++++++++++
.../thirdparty/parquet/ParquetReader.java | 151 ++++++
.../thirdparty/parquet/ParquetWriter.java | 220 ++++++++
.../java/org/apache/tajo/storage/v2/RCFile.java | 5 -
.../org/apache/tajo/storage/TestStorages.java | 58 ++-
.../tajo/pullserver/PullServerAuxService.java | 4 +-
.../tajo/pullserver/TajoPullServerService.java | 32 +-
84 files changed, 3946 insertions(+), 442 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tajo/blob/6d6b968f/tajo-common/src/main/java/org/apache/tajo/conf/TajoConf.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tajo/blob/6d6b968f/tajo-core/src/main/java/org/apache/tajo/engine/planner/LogicalPlanner.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tajo/blob/6d6b968f/tajo-core/src/main/java/org/apache/tajo/engine/planner/PhysicalPlannerImpl.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tajo/blob/6d6b968f/tajo-core/src/main/java/org/apache/tajo/engine/planner/global/GlobalPlanner.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tajo/blob/6d6b968f/tajo-core/src/main/java/org/apache/tajo/engine/planner/rewrite/ProjectionPushDownRule.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tajo/blob/6d6b968f/tajo-core/src/main/java/org/apache/tajo/worker/TaskAttemptContext.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tajo/blob/6d6b968f/tajo-core/src/test/java/org/apache/tajo/QueryTestCaseBase.java
----------------------------------------------------------------------