Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo
Project: http://git-wip-us.apache.org/repos/asf/tajo/repo Commit: http://git-wip-us.apache.org/repos/asf/tajo/commit/b33a9450 Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/b33a9450 Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/b33a9450 Branch: refs/heads/TAJO-1027 Commit: b33a94509c1a007b56785435c8e16640ffde91b7 Parents: aa01e83 7c5ef87 Author: Jaehwa Jung <[email protected]> Authored: Thu Sep 4 11:14:19 2014 +0900 Committer: Jaehwa Jung <[email protected]> Committed: Thu Sep 4 11:14:19 2014 +0900 ---------------------------------------------------------------------- CHANGES | 35 + LICENSE | 31 + pom.xml | 52 +- tajo-algebra/pom.xml | 13 +- tajo-catalog/pom.xml | 12 +- tajo-catalog/tajo-catalog-client/pom.xml | 13 +- .../tajo/catalog/AbstractCatalogClient.java | 75 +- tajo-catalog/tajo-catalog-common/pom.xml | 13 +- .../org/apache/tajo/catalog/CatalogUtil.java | 2 +- .../org/apache/tajo/catalog/FunctionDesc.java | 2 +- .../apache/tajo/catalog/TestKeyValueSet.java | 1 - tajo-catalog/tajo-catalog-drivers/pom.xml | 11 +- .../tajo-catalog-drivers/tajo-hcatalog/pom.xml | 19 +- tajo-catalog/tajo-catalog-server/pom.xml | 20 +- .../org/apache/tajo/catalog/CatalogServer.java | 2 +- tajo-client/pom.xml | 14 +- .../main/java/org/apache/tajo/cli/TajoCli.java | 24 +- .../org/apache/tajo/cli/TajoHAAdminCommand.java | 57 + .../java/org/apache/tajo/client/TajoAdmin.java | 27 +- .../java/org/apache/tajo/client/TajoClient.java | 78 +- .../org/apache/tajo/client/TajoGetConf.java | 16 +- .../org/apache/tajo/client/TajoHAAdmin.java | 210 ++ .../apache/tajo/client/TajoHAClientUtil.java | 87 + tajo-common/pom.xml | 13 +- .../java/org/apache/tajo/OverridableConf.java | 12 + .../main/java/org/apache/tajo/SessionVars.java | 2 +- .../java/org/apache/tajo/TajoConstants.java | 5 + .../java/org/apache/tajo/conf/TajoConf.java | 16 +- .../java/org/apache/tajo/datum/CharDatum.java | 5 +- .../main/java/org/apache/tajo/datum/Datum.java | 11 +- .../org/apache/tajo/datum/DatumFactory.java | 32 +- .../java/org/apache/tajo/datum/Inet4Datum.java | 5 + .../java/org/apache/tajo/datum/NullDatum.java | 5 + .../java/org/apache/tajo/datum/TextDatum.java | 8 + .../java/org/apache/tajo/util/BitArray.java | 2 +- .../org/apache/tajo/util/CommonTestingUtil.java | 24 +- .../org/apache/tajo/util/HAServiceUtil.java | 293 ++ .../java/org/apache/tajo/util/KeyValueSet.java | 18 +- .../main/java/org/apache/tajo/util/Pair.java | 44 +- .../java/org/apache/tajo/util/StringUtils.java | 34 + .../apache/tajo/util/datetime/DateTimeUtil.java | 35 + tajo-core/pom.xml | 35 +- .../tajo/engine/codegen/CaseWhenEmitter.java | 210 ++ .../engine/codegen/CaseWhenSwitchGenerator.java | 92 + .../tajo/engine/codegen/CodeGenUtils.java | 41 + .../tajo/engine/codegen/CompilationError.java | 31 + .../tajo/engine/codegen/EvalCodeEmitter.java | 27 + .../tajo/engine/codegen/EvalCodeGenContext.java | 223 ++ .../tajo/engine/codegen/EvalCodeGenerator.java | 840 ++++++ .../engine/codegen/ExecutorPreCompiler.java | 213 ++ .../tajo/engine/codegen/TajoClassLoader.java | 30 + .../engine/codegen/TajoGeneratorAdapter.java | 953 +++++++ .../engine/codegen/VariablesPreBuilder.java | 83 + .../apache/tajo/engine/eval/AlgebraicUtil.java | 6 +- .../tajo/engine/eval/BetweenPredicateEval.java | 26 + .../org/apache/tajo/engine/eval/BinaryEval.java | 7 + .../apache/tajo/engine/eval/CaseWhenEval.java | 38 +- .../org/apache/tajo/engine/eval/ConstEval.java | 12 +- .../org/apache/tajo/engine/eval/EvalNode.java | 6 +- .../apache/tajo/engine/eval/EvalTreeUtil.java | 98 +- .../org/apache/tajo/engine/eval/EvalType.java | 56 +- .../org/apache/tajo/engine/eval/FieldEval.java | 12 +- .../apache/tajo/engine/eval/FunctionEval.java | 25 +- .../tajo/engine/eval/LikePredicateEval.java | 4 + .../engine/eval/PatternMatchPredicateEval.java | 8 + .../tajo/engine/eval/RowConstantEval.java | 10 + .../engine/eval/SimilarToPredicateEval.java | 5 + .../tajo/engine/eval/SimpleEvalNodeVisitor.java | 27 +- .../org/apache/tajo/engine/eval/UnaryEval.java | 11 + .../function/builtin/CoalesceBoolean.java | 4 +- .../engine/function/builtin/CoalesceDate.java | 3 +- .../engine/function/builtin/CoalesceDouble.java | 3 +- .../engine/function/builtin/CoalesceLong.java | 3 +- .../engine/function/builtin/CoalesceString.java | 3 +- .../engine/function/builtin/CoalesceTime.java | 3 +- .../function/builtin/CoalesceTimestamp.java | 3 +- .../engine/plan/EvalTreeProtoDeserializer.java | 218 ++ .../engine/plan/EvalTreeProtoSerializer.java | 308 ++ .../tajo/engine/planner/ExprAnnotator.java | 17 +- .../apache/tajo/engine/planner/ExprFinder.java | 2 +- .../engine/planner/LogicalPlanPreprocessor.java | 22 +- .../engine/planner/PhysicalPlannerImpl.java | 11 + .../apache/tajo/engine/planner/Projector.java | 33 +- .../engine/planner/RangePartitionAlgorithm.java | 61 +- .../engine/planner/UniformRangePartition.java | 309 +- .../tajo/engine/planner/logical/HavingNode.java | 15 +- .../planner/logical/PersistentStoreNode.java | 2 +- .../tajo/engine/planner/logical/ScanNode.java | 12 +- .../engine/planner/logical/SelectableNode.java | 48 + .../engine/planner/logical/SelectionNode.java | 15 +- .../engine/planner/logical/join/JoinGraph.java | 2 +- .../engine/planner/physical/BNLJoinExec.java | 9 +- .../planner/physical/BSTIndexScanExec.java | 2 +- .../physical/BasicPhysicalExecutorVisitor.java | 2 + .../planner/physical/BinaryPhysicalExec.java | 2 + .../planner/physical/ColPartitionStoreExec.java | 55 +- .../planner/physical/ExternalSortExec.java | 4 + .../HashBasedColPartitionStoreExec.java | 6 +- .../planner/physical/HashFullOuterJoinExec.java | 8 +- .../engine/planner/physical/HashJoinExec.java | 7 +- .../planner/physical/HashLeftOuterJoinExec.java | 7 +- .../planner/physical/HashLeftSemiJoinExec.java | 4 + .../physical/HashShuffleFileWriteExec.java | 125 +- .../physical/MergeFullOuterJoinExec.java | 7 +- .../engine/planner/physical/MergeJoinExec.java | 7 +- .../engine/planner/physical/NLJoinExec.java | 2 +- .../planner/physical/NLLeftOuterJoinExec.java | 2 +- .../physical/PartitionMergeScanExec.java | 5 +- .../engine/planner/physical/PhysicalExec.java | 11 +- .../physical/PhysicalExecutorVisitor.java | 2 + .../planner/physical/PhysicalPlanUtil.java | 64 + .../physical/PhysicalPlanningException.java | 31 - .../engine/planner/physical/ProjectionExec.java | 2 +- .../physical/RightOuterMergeJoinExec.java | 7 +- .../engine/planner/physical/SelectionExec.java | 8 +- .../engine/planner/physical/SeqScanExec.java | 34 +- .../SortBasedColPartitionStoreExec.java | 40 +- .../engine/planner/physical/StoreTableExec.java | 64 +- .../planner/physical/UnaryPhysicalExec.java | 5 + .../planner/rewrite/FilterPushDownRule.java | 19 +- .../tajo/engine/query/QueryUnitRequestImpl.java | 2 +- .../org/apache/tajo/master/GlobalEngine.java | 16 +- .../tajo/master/LaunchTaskRunnersEvent.java | 45 + .../apache/tajo/master/TajoContainerProxy.java | 34 +- .../java/org/apache/tajo/master/TajoMaster.java | 38 +- .../org/apache/tajo/master/ha/HAService.java | 56 + .../tajo/master/ha/HAServiceHDFSImpl.java | 278 ++ .../apache/tajo/master/ha/TajoMasterInfo.java | 89 + .../apache/tajo/master/querymaster/Query.java | 3 +- .../tajo/master/querymaster/QueryMaster.java | 115 +- .../querymaster/QueryMasterManagerService.java | 13 + .../master/querymaster/QueryMasterTask.java | 50 +- .../tajo/master/querymaster/QueryUnit.java | 83 + .../tajo/master/querymaster/Repartitioner.java | 346 ++- .../tajo/master/querymaster/SubQuery.java | 88 +- .../org/apache/tajo/master/session/Session.java | 8 +- .../tajo/webapp/QueryExecutorServlet.java | 5 + .../worker/ExecutionBlockSharedResource.java | 139 + .../java/org/apache/tajo/worker/FetchImpl.java | 32 + .../java/org/apache/tajo/worker/Fetcher.java | 3 +- .../tajo/worker/TajoResourceAllocator.java | 43 +- .../java/org/apache/tajo/worker/TajoWorker.java | 158 +- .../tajo/worker/TajoWorkerManagerService.java | 24 +- .../main/java/org/apache/tajo/worker/Task.java | 80 +- .../apache/tajo/worker/TaskAttemptContext.java | 60 +- .../java/org/apache/tajo/worker/TaskRunner.java | 22 +- .../apache/tajo/worker/TaskRunnerManager.java | 127 +- .../tajo/worker/WorkerHeartbeatService.java | 42 +- tajo-core/src/main/proto/Plan.proto | 209 ++ .../src/main/proto/QueryMasterProtocol.proto | 1 + .../src/main/proto/TajoWorkerProtocol.proto | 33 + .../resources/webapps/admin/catalogview.jsp | 13 +- .../main/resources/webapps/admin/cluster.jsp | 87 +- .../src/main/resources/webapps/admin/index.jsp | 47 +- .../src/main/resources/webapps/admin/query.jsp | 13 +- .../resources/webapps/admin/query_executor.jsp | 13 +- .../apache/tajo/LocalTajoTestingUtility.java | 6 +- .../org/apache/tajo/TajoTestingCluster.java | 47 +- .../engine/codegen/TestEvalCodeGenerator.java | 311 ++ .../engine/codegen/TestGeneratorAdapter.java | 41 + .../apache/tajo/engine/eval/ExprTestBase.java | 102 +- .../apache/tajo/engine/eval/TestEvalTree.java | 21 +- .../tajo/engine/eval/TestEvalTreeUtil.java | 7 + .../apache/tajo/engine/eval/TestPredicates.java | 17 + .../tajo/engine/eval/TestSQLExpression.java | 24 +- .../function/TestConditionalExpressions.java | 123 +- .../function/TestPatternMatchingPredicates.java | 2 +- .../planner/TestUniformRangePartition.java | 635 ++++- .../planner/physical/TestPhysicalPlanner.java | 238 +- .../tajo/engine/query/TestGroupByQuery.java | 8 +- .../tajo/engine/query/TestSelectQuery.java | 14 + .../apache/tajo/engine/query/TestSortQuery.java | 73 +- .../tajo/engine/query/TestTablePartitions.java | 72 + .../apache/tajo/master/TestRepartitioner.java | 309 +- .../tajo/master/ha/TestHAServiceHDFSImpl.java | 133 + .../querymaster/TestIntermediateEntry.java | 53 + .../querymaster/TestQueryUnitStatusUpdate.java | 6 +- .../tajo/scheduler/TestFifoScheduler.java | 47 +- .../org/apache/tajo/worker/TestFetcher.java | 23 +- .../testColumnEqualityButNotJoinCondition1.sql | 7 + .../testColumnEqualityButNotJoinCondition2.sql | 7 + .../TestSortQuery/testSortOnNullColumn.sql | 13 + .../TestSortQuery/testSortOnUnicodeTextAsc.sql | 6 + .../TestSortQuery/testSortOnUnicodeTextDesc.sql | 6 + ...estColumnEqualityButNotJoinCondition1.result | 3 + ...estColumnEqualityButNotJoinCondition2.result | 6 + .../TestSortQuery/testSortOnNullColumn.result | 6 + .../testSortOnUnicodeTextAsc.result | 6 + .../testSortOnUnicodeTextDesc.result | 6 + .../TestTajoCli/testHelpSessionVars.result | 1 + tajo-dist/pom.xml | 22 + tajo-dist/src/main/bin/start-tajo.sh | 18 +- tajo-dist/src/main/bin/stop-tajo.sh | 19 +- tajo-dist/src/main/bin/tajo | 18 +- tajo-dist/src/main/bin/tajo-daemons.sh | 1 + tajo-dist/src/main/conf/tajo-env.sh | 13 +- tajo-docs/pom.xml | 18 + tajo-docs/src/main/sphinx/configuration.rst | 3 +- .../sphinx/configuration/ha_configuration.rst | 135 + tajo-jdbc/pom.xml | 13 +- .../org/apache/tajo/jdbc/MetaDataTuple.java | 11 + tajo-maven-plugins/pom.xml | 12 + tajo-project/pom.xml | 23 +- tajo-rpc/pom.xml | 12 + tajo-storage/pom.xml | 18 +- .../tajo/storage/AbstractStorageManager.java | 1 - .../java/org/apache/tajo/storage/Appender.java | 2 + .../org/apache/tajo/storage/FileAppender.java | 4 + .../org/apache/tajo/storage/FrameTuple.java | 11 + .../tajo/storage/HashShuffleAppender.java | 209 ++ .../storage/HashShuffleAppenderManager.java | 225 ++ .../java/org/apache/tajo/storage/LazyTuple.java | 14 +- .../java/org/apache/tajo/storage/RawFile.java | 1 + .../org/apache/tajo/storage/RowStoreUtil.java | 8 +- .../java/org/apache/tajo/storage/Tuple.java | 5 + .../org/apache/tajo/storage/TupleRange.java | 29 +- .../java/org/apache/tajo/storage/VTuple.java | 11 + .../tajo/storage/parquet/ParquetAppender.java | 15 +- .../parquet/InternalParquetRecordWriter.java | 4 + .../thirdparty/parquet/ParquetWriter.java | 4 + .../tajo/storage/TestCompressionStorages.java | 2 - .../tajo/storage/parquet/TestReadWrite.java | 7 +- tajo-thirdparty/asm/pom.xml | 180 ++ .../org/objectweb/asm/AnnotationVisitor.java | 169 ++ .../org/objectweb/asm/AnnotationWriter.java | 318 +++ .../tajo/org/objectweb/asm/Attribute.java | 255 ++ .../tajo/org/objectweb/asm/ByteVector.java | 312 ++ .../tajo/org/objectweb/asm/ClassReader.java | 2202 ++++++++++++++ .../tajo/org/objectweb/asm/ClassVisitor.java | 286 ++ .../tajo/org/objectweb/asm/ClassWriter.java | 1706 +++++++++++ .../apache/tajo/org/objectweb/asm/Context.java | 110 + .../org/apache/tajo/org/objectweb/asm/Edge.java | 75 + .../tajo/org/objectweb/asm/FieldVisitor.java | 121 + .../tajo/org/objectweb/asm/FieldWriter.java | 273 ++ .../apache/tajo/org/objectweb/asm/Frame.java | 1453 ++++++++++ .../apache/tajo/org/objectweb/asm/Handle.java | 170 ++ .../apache/tajo/org/objectweb/asm/Handler.java | 121 + .../org/apache/tajo/org/objectweb/asm/Item.java | 311 ++ .../apache/tajo/org/objectweb/asm/Label.java | 560 ++++ .../tajo/org/objectweb/asm/MethodVisitor.java | 662 +++++ .../tajo/org/objectweb/asm/MethodWriter.java | 2685 ++++++++++++++++++ .../apache/tajo/org/objectweb/asm/Opcodes.java | 358 +++ .../org/apache/tajo/org/objectweb/asm/Type.java | 895 ++++++ .../tajo/org/objectweb/asm/attrs/package.html | 66 + .../objectweb/asm/commons/AdviceAdapter.java | 625 ++++ .../objectweb/asm/commons/AnalyzerAdapter.java | 920 ++++++ .../asm/commons/CodeSizeEvaluator.java | 217 ++ .../objectweb/asm/commons/GeneratorAdapter.java | 1641 +++++++++++ .../asm/commons/InstructionAdapter.java | 1090 +++++++ .../asm/commons/JSRInlinerAdapter.java | 746 +++++ .../asm/commons/LocalVariablesSorter.java | 361 +++ .../tajo/org/objectweb/asm/commons/Method.java | 282 ++ .../org/objectweb/asm/commons/Remapper.java | 223 ++ .../asm/commons/RemappingAnnotationAdapter.java | 79 + .../asm/commons/RemappingClassAdapter.java | 126 + .../asm/commons/RemappingFieldAdapter.java | 62 + .../asm/commons/RemappingMethodAdapter.java | 161 ++ .../asm/commons/RemappingSignatureAdapter.java | 155 + .../asm/commons/SerialVersionUIDAdder.java | 533 ++++ .../objectweb/asm/commons/SimpleRemapper.java | 69 + .../objectweb/asm/commons/StaticInitMerger.java | 96 + .../asm/commons/TableSwitchGenerator.java | 57 + .../asm/commons/TryCatchBlockSorter.java | 92 + .../tajo/org/objectweb/asm/commons/package.html | 66 + .../optimizer/AnnotationConstantsCollector.java | 147 + .../asm/optimizer/ClassConstantsCollector.java | 184 ++ .../objectweb/asm/optimizer/ClassOptimizer.java | 167 ++ .../org/objectweb/asm/optimizer/Constant.java | 323 +++ .../objectweb/asm/optimizer/ConstantPool.java | 249 ++ .../asm/optimizer/FieldConstantsCollector.java | 75 + .../objectweb/asm/optimizer/JarOptimizer.java | 234 ++ .../asm/optimizer/MethodConstantsCollector.java | 161 ++ .../asm/optimizer/MethodOptimizer.java | 167 ++ .../objectweb/asm/optimizer/NameMapping.java | 114 + .../org/objectweb/asm/optimizer/Shrinker.java | 283 ++ .../objectweb/asm/optimizer/jdk1.2.2_017.txt.gz | Bin 0 -> 113814 bytes .../objectweb/asm/optimizer/jdk1.3.1_19.txt.gz | Bin 0 -> 128067 bytes .../asm/optimizer/shrink-annotations.properties | 71 + .../asm/optimizer/shrink-frames.properties | 80 + .../asm/optimizer/shrink-resize.properties | 55 + .../asm/optimizer/shrink-signatures.properties | 61 + .../asm/optimizer/shrink-writer.properties | 84 + .../objectweb/asm/optimizer/shrink.properties | 372 +++ .../apache/tajo/org/objectweb/asm/package.html | 105 + .../asm/signature/SignatureReader.java | 228 ++ .../asm/signature/SignatureVisitor.java | 235 ++ .../asm/signature/SignatureWriter.java | 227 ++ .../org/objectweb/asm/signature/package.html | 54 + .../objectweb/asm/tree/AbstractInsnNode.java | 248 ++ .../org/objectweb/asm/tree/AnnotationNode.java | 225 ++ .../tajo/org/objectweb/asm/tree/ClassNode.java | 345 +++ .../org/objectweb/asm/tree/FieldInsnNode.java | 108 + .../tajo/org/objectweb/asm/tree/FieldNode.java | 243 ++ .../tajo/org/objectweb/asm/tree/FrameNode.java | 210 ++ .../org/objectweb/asm/tree/IincInsnNode.java | 82 + .../org/objectweb/asm/tree/InnerClassNode.java | 101 + .../tajo/org/objectweb/asm/tree/InsnList.java | 600 ++++ .../tajo/org/objectweb/asm/tree/InsnNode.java | 87 + .../org/objectweb/asm/tree/IntInsnNode.java | 87 + .../asm/tree/InvokeDynamicInsnNode.java | 100 + .../org/objectweb/asm/tree/JumpInsnNode.java | 95 + .../tajo/org/objectweb/asm/tree/LabelNode.java | 78 + .../org/objectweb/asm/tree/LdcInsnNode.java | 78 + .../org/objectweb/asm/tree/LineNumberNode.java | 84 + .../objectweb/asm/tree/LocalVariableNode.java | 112 + .../asm/tree/LookupSwitchInsnNode.java | 117 + .../org/objectweb/asm/tree/MethodInsnNode.java | 109 + .../tajo/org/objectweb/asm/tree/MethodNode.java | 597 ++++ .../asm/tree/MultiANewArrayInsnNode.java | 83 + .../objectweb/asm/tree/TableSwitchInsnNode.java | 113 + .../objectweb/asm/tree/TryCatchBlockNode.java | 94 + .../org/objectweb/asm/tree/TypeInsnNode.java | 90 + .../org/objectweb/asm/tree/VarInsnNode.java | 93 + .../objectweb/asm/tree/analysis/Analyzer.java | 549 ++++ .../asm/tree/analysis/AnalyzerException.java | 61 + .../asm/tree/analysis/BasicInterpreter.java | 358 +++ .../objectweb/asm/tree/analysis/BasicValue.java | 111 + .../asm/tree/analysis/BasicVerifier.java | 433 +++ .../org/objectweb/asm/tree/analysis/Frame.java | 729 +++++ .../asm/tree/analysis/Interpreter.java | 226 ++ .../asm/tree/analysis/SimpleVerifier.java | 320 +++ .../objectweb/asm/tree/analysis/SmallSet.java | 134 + .../asm/tree/analysis/SourceInterpreter.java | 198 ++ .../asm/tree/analysis/SourceValue.java | 97 + .../objectweb/asm/tree/analysis/Subroutine.java | 90 + .../org/objectweb/asm/tree/analysis/Value.java | 45 + .../objectweb/asm/tree/analysis/package.html | 85 + .../tajo/org/objectweb/asm/tree/package.html | 210 ++ .../tajo/org/objectweb/asm/util/ASMifiable.java | 56 + .../tajo/org/objectweb/asm/util/ASMifier.java | 1151 ++++++++ .../asm/util/CheckAnnotationAdapter.java | 136 + .../objectweb/asm/util/CheckClassAdapter.java | 914 ++++++ .../objectweb/asm/util/CheckFieldAdapter.java | 100 + .../objectweb/asm/util/CheckMethodAdapter.java | 1397 +++++++++ .../asm/util/CheckSignatureAdapter.java | 330 +++ .../tajo/org/objectweb/asm/util/Printer.java | 500 ++++ .../org/objectweb/asm/util/Textifiable.java | 56 + .../tajo/org/objectweb/asm/util/Textifier.java | 1200 ++++++++ .../asm/util/TraceAnnotationVisitor.java | 89 + .../objectweb/asm/util/TraceClassVisitor.java | 209 ++ .../objectweb/asm/util/TraceFieldVisitor.java | 76 + .../objectweb/asm/util/TraceMethodVisitor.java | 223 ++ .../asm/util/TraceSignatureVisitor.java | 317 +++ .../tajo/org/objectweb/asm/util/package.html | 58 + .../objectweb/asm/xml/ASMContentHandler.java | 1317 +++++++++ .../tajo/org/objectweb/asm/xml/Processor.java | 1044 +++++++ .../tajo/org/objectweb/asm/xml/SAXAdapter.java | 89 + .../objectweb/asm/xml/SAXAnnotationAdapter.java | 185 ++ .../org/objectweb/asm/xml/SAXClassAdapter.java | 324 +++ .../org/objectweb/asm/xml/SAXCodeAdapter.java | 362 +++ .../org/objectweb/asm/xml/SAXFieldAdapter.java | 63 + .../tajo/org/objectweb/asm/xml/asm-xml.dtd | 367 +++ .../tajo/org/objectweb/asm/xml/package.html | 114 + tajo-yarn-pullserver/pom.xml | 17 + .../pullserver/listener/FileCloseListener.java | 15 +- .../pullserver/listener/FileCloseListener.java | 15 +- .../pullserver/listener/FileCloseListener.java | 15 +- .../tajo/pullserver/PullServerAuxService.java | 2 +- .../apache/tajo/pullserver/TajoPullServer.java | 73 + .../tajo/pullserver/TajoPullServerService.java | 215 +- .../java/org/apache/tajo/storage/Tuple.java | 27 +- 361 files changed, 54189 insertions(+), 1084 deletions(-) ----------------------------------------------------------------------
