f99aecbe51b4e23dca4e0f536bdc439fe89f07ca - pregelix

commit	f99aecbe51b4e23dca4e0f536bdc439fe89f07ca	[log] [tgz]
author	buyingyi <buyingyi@123451ca-8445-de46-9d55-352943316053>	Sun Oct 07 00:23:17 2012 +0000
committer	buyingyi <buyingyi@123451ca-8445-de46-9d55-352943316053>	Sun Oct 07 00:23:17 2012 +0000
tree	7cad4d374724e710ecdf5b67350569ed0dc0fd33

add Pregelix codebase

git-svn-id: https://hyracks.googlecode.com/svn/branches/fullstack_staging@1960 123451ca-8445-de46-9d55-352943316053

AsterixCodeStyle.xml[Added - diff]
pom.xml[Added - diff]
pregelix-api/pom.xml[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/delegate/VertexDelegate.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/graph/Edge.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/graph/MsgList.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/graph/Vertex.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/graph/VertexCombiner.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/io/BasicGenInputSplit.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/io/VertexInputFormat.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/io/VertexOutputFormat.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/io/VertexReader.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/io/VertexWriter.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/io/generated/GeneratedVertexInputFormat.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/io/generated/GeneratedVertexReader.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/io/text/TextVertexInputFormat.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/io/text/TextVertexOutputFormat.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/job/PregelixJob.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/util/ArrayListWritable.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/util/BspUtils.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/util/FrameTupleUtils.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/util/ReflectionUtils.java[Added - diff]
pregelix-api/src/main/java/edu/uci/ics/pregelix/api/util/SerDeUtils.java[Added - diff]
pregelix-core/data/tpch0.001/customer-part1.tbl[Added - diff]
pregelix-core/data/tpch0.001/customer-part2.tbl[Added - diff]
pregelix-core/data/tpch0.001/customer.tbl[Added - diff]
pregelix-core/data/tpch0.001/lineitem.tbl[Added - diff]
pregelix-core/data/tpch0.001/nation.tbl[Added - diff]
pregelix-core/data/tpch0.001/orders-part1.tbl[Added - diff]
pregelix-core/data/tpch0.001/orders-part2.tbl[Added - diff]
pregelix-core/data/tpch0.001/orders.tbl[Added - diff]
pregelix-core/data/tpch0.001/part.tbl[Added - diff]
pregelix-core/data/tpch0.001/partsupp.tbl[Added - diff]
pregelix-core/data/tpch0.001/region.tbl[Added - diff]
pregelix-core/data/tpch0.001/supplier.tbl[Added - diff]
pregelix-core/data/tpch0.001/tpch.ddl[Added - diff]
pregelix-core/data/webmap/webmap_link.txt[Added - diff]
pregelix-core/pom.xml[Added - diff]
pregelix-core/src/main/assembly/binary-assembly.xml[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/base/IDriver.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/base/IJobGen.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/base/INormalizedKeyComputerFactoryProvider.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/data/TypeTraits.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/driver/Driver.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/hadoop/config/ConfigurationFactory.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/hadoop/data/Message.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/hadoop/data/MessageList.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/jobgen/JobGen.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/jobgen/JobGenInnerJoin.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/jobgen/JobGenOuterJoin.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/jobgen/JobGenOuterJoinSingleSort.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/jobgen/JobGenOuterJoinSort.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/jobgen/JobGenUtil.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/jobgen/clusterconfig/ClusterConfig.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/jobgen/provider/NormalizedKeyComputerFactoryProvider.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/runtime/touchpoint/WritableRecordDescriptorFactory.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/util/BufferSerDeUtils.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/util/DataBalancer.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/util/DataGenerator.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/util/DataflowUtils.java[Added - diff]
pregelix-core/src/main/java/edu/uci/ics/pregelix/core/util/PregelixHyracksIntegrationUtil.java[Added - diff]
pregelix-core/src/main/java/org/apache/hadoop/fs/Path.java[Added - diff]
pregelix-core/src/main/java/org/apache/hadoop/mapreduce/InputSplit.java[Added - diff]
pregelix-core/src/main/resources/conf/cluster.properties[Added - diff]
pregelix-core/src/main/resources/conf/master[Added - diff]
pregelix-core/src/main/resources/conf/slaves[Added - diff]
pregelix-core/src/main/resources/conf/stores.properties[Added - diff]
pregelix-core/src/main/resources/hyracks-deployment.properties[Added - diff]
pregelix-core/src/main/resources/scripts/pregelix[Added - diff]
pregelix-core/src/main/resources/scripts/pregelix.bat[Added - diff]
pregelix-core/src/main/resources/scripts/startAllNCs.sh[Added - diff]
pregelix-core/src/main/resources/scripts/startCluster.sh[Added - diff]
pregelix-core/src/main/resources/scripts/startcc.sh[Added - diff]
pregelix-core/src/main/resources/scripts/startnc.sh[Added - diff]
pregelix-core/src/test/java/edu/uci/ics/pregelix/core/join/JoinTest.java[Added - diff]
pregelix-core/src/test/java/edu/uci/ics/pregelix/core/join/JoinTestNullWriterFactory.java[Added - diff]
pregelix-core/src/test/java/edu/uci/ics/pregelix/core/util/TestUtils.java[Added - diff]
pregelix-core/src/test/resources/cluster/data.properties[Added - diff]
pregelix-core/src/test/resources/hadoop/conf/core-site.xml[Added - diff]
pregelix-core/src/test/resources/hadoop/conf/hdfs-site.xml[Added - diff]
pregelix-core/src/test/resources/hadoop/conf/log4j.properties[Added - diff]
pregelix-core/src/test/resources/hadoop/conf/mapred-site.xml[Added - diff]
pregelix-core/src/test/resources/hyracks-deployment.properties[Added - diff]
pregelix-core/src/test/resources/log4j.properties[Added - diff]
pregelix-core/src/test/resources/logging.properties[Added - diff]
pregelix-dataflow-std-base/pom.xml[Added - diff]
pregelix-dataflow-std-base/src/main/java/edu/uci/ics/pregelix/dataflow/std/base/IFunction.java[Added - diff]
pregelix-dataflow-std-base/src/main/java/edu/uci/ics/pregelix/dataflow/std/base/IFunctionFactory.java[Added - diff]
pregelix-dataflow-std-base/src/main/java/edu/uci/ics/pregelix/dataflow/std/base/IRecordDescriptorFactory.java[Added - diff]
pregelix-dataflow-std-base/src/main/java/edu/uci/ics/pregelix/dataflow/std/base/IRuntimeHook.java[Added - diff]
pregelix-dataflow-std-base/src/main/java/edu/uci/ics/pregelix/dataflow/std/base/IRuntimeHookFactory.java[Added - diff]
pregelix-dataflow-std-base/src/main/java/edu/uci/ics/pregelix/dataflow/std/base/IUpdateFunction.java[Added - diff]
pregelix-dataflow-std-base/src/main/java/edu/uci/ics/pregelix/dataflow/std/base/IUpdateFunctionFactory.java[Added - diff]
pregelix-dataflow-std/pom.xml[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/BTreeSearchFunctionUpdateOperatorDescriptor.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/BTreeSearchFunctionUpdateOperatorNodePushable.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/FileWriteOperatorDescriptor.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/FunctionCallOperatorDescriptor.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/IndexNestedLoopJoinFunctionUpdateOperatorDescriptor.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/IndexNestedLoopJoinFunctionUpdateOperatorNodePushable.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/IndexNestedLoopJoinOperatorDescriptor.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/IndexNestedLoopJoinOperatorNodePushable.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/IndexNestedLoopRightOuterJoinFunctionUpdateOperatorNodePushable.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/IndexNestedLoopRightOuterJoinOperatorNodePushable.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/IndexNestedLoopSetUnionFunctionUpdateOperatorNodePushable.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/IndexNestedLoopSetUnionOperatorNodePushable.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/ProjectOperatorDescriptor.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/RuntimeHookOperatorDescriptor.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/TreeIndexBulkReLoadOperatorDescriptor.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/std/TreeIndexBulkReLoadOperatorNodePushable.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/util/FunctionProxy.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/util/ResetableByteArrayInputStream.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/util/ResetableByteArrayOutputStream.java[Added - diff]
pregelix-dataflow-std/src/main/java/edu/uci/ics/pregelix/dataflow/util/TupleDeserializer.java[Added - diff]
pregelix-dataflow/pom.xml[Added - diff]
pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/ConnectorPolicyAssignmentPolicy.java[Added - diff]
pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/CountTupleOperatorDescriptor.java[Added - diff]
pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/EmptySinkOperatorDescriptor.java[Added - diff]
pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/EmptyTupleSourceOperatorDescriptor.java[Added - diff]
pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/HDFSFileWriteOperatorDescriptor.java[Added - diff]
pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/MaterializingReadOperatorDescriptor.java[Added - diff]
pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/MaterializingWriteOperatorDescriptor.java[Added - diff]
pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/NonCombinerConnectorPolicyAssignmentPolicy.java[Added - diff]
pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/TerminationStateWriterOperatorDescriptor.java[Added - diff]
pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/VertexFileScanOperatorDescriptor.java[Added - diff]
pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/base/IConfigurationFactory.java[Added - diff]
pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/context/RuntimeContext.java[Added - diff]
pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/context/StateKey.java[Added - diff]
pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/state/MaterializerTaskState.java[Added - diff]
pregelix-dataflow/src/main/java/edu/uci/ics/pregelix/dataflow/util/IterationUtils.java[Added - diff]
pregelix-dist/pom.xml[Added - diff]
pregelix-example/data/webmap/webmap_link.txt[Added - diff]
pregelix-example/data/webmapcomplex/webmap_link.txt[Added - diff]
pregelix-example/pom.xml[Added - diff]
pregelix-example/src/main/assembly/binary-assembly.xml[Added - diff]
pregelix-example/src/main/java/edu/uci/ics/pregelix/example/ConnectedComponentsVertex.java[Added - diff]
pregelix-example/src/main/java/edu/uci/ics/pregelix/example/PageRankVertex.java[Added - diff]
pregelix-example/src/main/java/edu/uci/ics/pregelix/example/ShortestPathsVertex.java[Added - diff]
pregelix-example/src/main/java/edu/uci/ics/pregelix/example/VertexAggregator.java[Added - diff]
pregelix-example/src/main/java/edu/uci/ics/pregelix/example/VertexSorter.java[Added - diff]
pregelix-example/src/main/java/edu/uci/ics/pregelix/example/client/Client.java[Added - diff]
pregelix-example/src/main/java/edu/uci/ics/pregelix/example/inputformat/TextConnectedComponentsInputFormat.java[Added - diff]
pregelix-example/src/main/java/edu/uci/ics/pregelix/example/inputformat/TextPageRankInputFormat.java[Added - diff]
pregelix-example/src/main/java/edu/uci/ics/pregelix/example/inputformat/TextShortestPathsInputFormat.java[Added - diff]
pregelix-example/src/main/java/edu/uci/ics/pregelix/example/io/VLongWritable.java[Added - diff]
pregelix-example/src/test/java/edu/uci/ics/pregelix/example/dataload/DataLoadTest.java[Added - diff]
pregelix-example/src/test/java/edu/uci/ics/pregelix/example/jobgen/JobGenerator.java[Added - diff]
pregelix-example/src/test/java/edu/uci/ics/pregelix/example/jobrun/RunJobTestCase.java[Added - diff]
pregelix-example/src/test/java/edu/uci/ics/pregelix/example/jobrun/RunJobTestSuite.java[Added - diff]
pregelix-example/src/test/java/edu/uci/ics/pregelix/example/util/TestUtils.java[Added - diff]
pregelix-example/src/test/resources/cluster/data.properties[Added - diff]
pregelix-example/src/test/resources/expected/ConnectedComponentsReal.result[Added - diff]
pregelix-example/src/test/resources/expected/ConnectedComponentsRealComplex.result[Added - diff]
pregelix-example/src/test/resources/expected/PageRank.result[Added - diff]
pregelix-example/src/test/resources/expected/PageRankReal.result[Added - diff]
pregelix-example/src/test/resources/expected/PageRankRealComplex.result[Added - diff]
pregelix-example/src/test/resources/expected/ShortestPaths.result[Added - diff]
pregelix-example/src/test/resources/expected/ShortestPathsReal.result[Added - diff]
pregelix-example/src/test/resources/hadoop/conf/core-site.xml[Added - diff]
pregelix-example/src/test/resources/hadoop/conf/hdfs-site.xml[Added - diff]
pregelix-example/src/test/resources/hadoop/conf/log4j.properties[Added - diff]
pregelix-example/src/test/resources/hadoop/conf/mapred-site.xml[Added - diff]
pregelix-example/src/test/resources/hyracks-deployment.properties[Added - diff]
pregelix-example/src/test/resources/ignore.txt[Added - diff]
pregelix-example/src/test/resources/jobs/ConnectedComponentsReal.xml[Added - diff]
pregelix-example/src/test/resources/jobs/ConnectedComponentsRealComplex.xml[Added - diff]
pregelix-example/src/test/resources/jobs/PageRank.xml[Added - diff]
pregelix-example/src/test/resources/jobs/PageRankReal.xml[Added - diff]
pregelix-example/src/test/resources/jobs/PageRankRealComplex.xml[Added - diff]
pregelix-example/src/test/resources/jobs/ShortestPaths.xml[Added - diff]
pregelix-example/src/test/resources/jobs/ShortestPathsReal.xml[Added - diff]
pregelix-example/src/test/resources/log4j.properties[Added - diff]
pregelix-example/src/test/resources/logging.properties[Added - diff]
pregelix-example/src/test/resources/only.txt[Added - diff]
pregelix-runtime/pom.xml[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/base/IAggregateFunction.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/base/IAggregateFunctionFactory.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/bootstrap/NCBootstrapImpl.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/bootstrap/StorageManagerInterface.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/bootstrap/TreeIndexRegistryProvider.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/function/ComputeUpdateFunctionFactory.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/function/StartComputeUpdateFunctionFactory.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/simpleagg/AccumulatingAggregatorFactory.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/simpleagg/AggregationFunction.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/simpleagg/AggregationFunctionFactory.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/touchpoint/MergePartitionComputerFactory.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/touchpoint/MsgListNullWriterFactory.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/touchpoint/PostSuperStepRuntimeHookFactory.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/touchpoint/PreSuperStepRuntimeHookFactory.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/touchpoint/RuntimeHookFactory.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/touchpoint/VLongAscNormalizedKeyComputerFactory.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/touchpoint/VLongDescNormalizedKeyComputerFactory.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/touchpoint/VertexIdNullWriterFactory.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/touchpoint/VertexIdPartitionComputerFactory.java[Added - diff]
pregelix-runtime/src/main/java/edu/uci/ics/pregelix/runtime/touchpoint/WritableDescComparingBinaryComparatorFactory.java[Added - diff]

195 files changed

tree: 7cad4d374724e710ecdf5b67350569ed0dc0fd33

AsterixCodeStyle.xml
pom.xml
pregelix-api/
pregelix-core/
pregelix-dataflow-std-base/
pregelix-dataflow-std/
pregelix-dataflow/
pregelix-dist/
pregelix-example/
pregelix-runtime/