[
https://issues.apache.org/jira/browse/GIRAPH-667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13662426#comment-13662426
]
Hudson commented on GIRAPH-667:
-------------------------------
Integrated in Giraph-trunk-Commit #953 (See
[https://builds.apache.org/job/Giraph-trunk-Commit/953/])
GIRAPH-667: Decouple Vertex data and Computation, make Computation and
Combiner classes switchable (majakabiljo) (Revision
8811165e85ae2db442e34f1021db29f4dfcc8430)
Result = SUCCESS
majakabiljo :
http://git-wip-us.apache.org/repos/asf?p=giraph.git&a=commit&h=8811165e85ae2db442e34f1021db29f4dfcc8430
Files :
*
giraph-hcatalog/src/main/java/org/apache/giraph/io/hcatalog/HCatGiraphRunner.java
*
giraph-core/src/main/java/org/apache/giraph/io/superstep_output/MultiThreadedSuperstepOutput.java
*
giraph-core/src/main/java/org/apache/giraph/partition/HashMasterPartitioner.java
* giraph-core/src/test/java/org/apache/giraph/comm/TestMessageStores.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/VertexWithDoubleValueNullEdgeTextOutputFormat.java
*
giraph-core/src/main/java/org/apache/giraph/integration/SuperstepHashPartitionerFactory.java
*
giraph-core/src/main/java/org/apache/giraph/comm/messages/SimpleMessageStore.java
* giraph-core/src/test/java/org/apache/giraph/comm/SaslConnectionTest.java
* giraph-examples/src/main/java/org/apache/giraph/examples/VerifyMessage.java
*
giraph-examples/src/test/java/org/apache/giraph/examples/TryMultiIpcBindingPortsTest.java
*
giraph-hive/src/main/java/org/apache/giraph/hive/input/vertex/HiveToVertex.java
*
giraph-core/src/main/java/org/apache/giraph/io/superstep_output/NoOpSuperstepOutput.java
*
giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SynchronizedSuperstepOutput.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/JsonBase64VertexOutputFormat.java
* giraph-core/src/main/java/org/apache/giraph/benchmark/PageRankBenchmark.java
* giraph-core/src/test/java/org/apache/giraph/comm/RequestTest.java
* giraph-core/src/main/java/org/apache/giraph/graph/GraphStateAware.java
* giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyWorkerServer.java
*
giraph-core/src/main/java/org/apache/giraph/partition/DefaultPartitionContext.java
*
giraph-core/src/main/java/org/apache/giraph/worker/EdgeInputSplitsCallable.java
*
giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyWorkerClientRequestProcessor.java
*
giraph-core/src/main/java/org/apache/giraph/io/iterables/EdgeReaderWrapper.java
* giraph-core/src/main/java/org/apache/giraph/io/EdgeReader.java
* giraph-examples/src/main/java/org/apache/giraph/examples/SimpleFailVertex.java
* giraph-core/src/main/java/org/apache/giraph/utils/WritableUtils.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/IdWithValueTextOutputFormat.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/NormalizingLongDoubleDoubleTextInputFormat.java
* giraph-core/src/main/java/org/apache/giraph/benchmark/ShortestPathsVertex.java
* giraph-examples/src/test/java/org/apache/giraph/TestMaxSuperstep.java
*
giraph-hive/src/main/java/org/apache/giraph/hive/input/vertex/AbstractHiveToVertex.java
*
giraph-hcatalog/src/main/java/org/apache/giraph/io/hcatalog/HCatalogVertexOutputFormat.java
*
giraph-hive/src/main/java/org/apache/giraph/hive/output/examples/HiveOutputIntIntVertex.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleLongDoubleDoubleDoubleIdentityComputation.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/PseudoRandomVertexInputFormat.java
* giraph-core/src/main/java/org/apache/giraph/bsp/CentralizedServiceMaster.java
*
giraph-hive/src/main/java/org/apache/giraph/hive/input/vertex/SimpleHiveToVertex.java
*
giraph-core/src/main/java/org/apache/giraph/worker/VertexInputSplitsCallable.java
* giraph-core/src/main/java/org/apache/giraph/comm/SendCache.java
* giraph-hive/src/test/java/org/apache/giraph/hive/output/HiveOutputTest.java
* giraph-core/src/main/java/org/apache/giraph/edge/MutableEdgesWrapper.java
* giraph-core/src/main/java/org/apache/giraph/master/MasterThread.java
* giraph-core/src/main/java/org/apache/giraph/comm/WorkerClient.java
* giraph-hive/src/main/java/org/apache/giraph/hive/output/VertexToHive.java
* giraph-core/src/test/java/org/apache/giraph/utils/ComputationCountEdges.java
* giraph-core/src/main/java/org/apache/giraph/benchmark/PageRankVertex.java
*
giraph-core/src/test/java/org/apache/giraph/utils/IntIntNullNoOpComputation.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/ConnectedComponentsVertex.java
*
giraph-hive/src/main/java/org/apache/giraph/hive/input/edge/HiveEdgeReader.java
* giraph-core/src/main/java/org/apache/giraph/graph/VertexChanges.java
*
giraph-core/src/main/java/org/apache/giraph/comm/requests/SendPartitionMutationsRequest.java
* giraph-core/src/main/java/org/apache/giraph/conf/AllOptions.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/IdentityComputation.java
* giraph-core/src/main/java/org/apache/giraph/partition/Partition.java
*
giraph-hbase/src/test/java/org/apache/giraph/io/hbase/edgemarker/TableEdgeOutputFormat.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleTriangleClosingComputation.java
* giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleTextVertexOutputFormat.java
* giraph-core/src/main/java/org/apache/giraph/io/GiraphInputFormat.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/RandomWalkWithRestartComputation.java
* giraph-core/src/main/java/org/apache/giraph/partition/BasicPartition.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleSuperstepVertex.java
*
giraph-core/src/main/java/org/apache/giraph/conf/DefaultImmutableClassesGiraphConfigurable.java
*
giraph-hive/src/main/java/org/apache/giraph/hive/input/edge/HiveEdgeInputFormat.java
*
giraph-hive/src/test/java/org/apache/giraph/hive/input/HiveVertexInputTest.java
* giraph-core/src/main/java/org/apache/giraph/io/VertexValueReader.java
* giraph-core/src/main/java/org/apache/giraph/graph/VertexResolver.java
*
giraph-core/src/main/java/org/apache/giraph/partition/RangeMasterPartitioner.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/RandomWalkWorkerContext.java
*
giraph-core/src/test/java/org/apache/giraph/io/TestAdjacencyListTextVertexOutputFormat.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/LongDoubleNullTextInputFormat.java
*
giraph-examples/src/test/java/org/apache/giraph/examples/ConnectedComponentsVertexTestInMemory.java
* giraph-core/src/test/java/org/apache/giraph/conf/TestObjectCreation.java
*
giraph-core/src/main/java/org/apache/giraph/benchmark/WeightedPageRankComputation.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/JsonLongDoubleFloatDoubleVertexOutputFormat.java
*
giraph-core/src/main/java/org/apache/giraph/comm/messages/DiskBackedMessageStore.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/PartitionContextTestVertex.java
* giraph-core/src/main/java/org/apache/giraph/graph/DefaultVertexResolver.java
*
giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfigurable.java
*
giraph-core/src/test/java/org/apache/giraph/vertices/IntIntNullVertexDoNothing.java
* giraph-core/src/test/java/org/apache/giraph/utils/NoOpComputation.java
* giraph-core/src/main/java/org/apache/giraph/comm/requests/WritableRequest.java
*
giraph-core/src/main/java/org/apache/giraph/io/internal/WrappedVertexReader.java
* giraph-core/src/test/java/org/apache/giraph/utils/LongNoOpComputation.java
* giraph-examples/src/main/java/org/apache/giraph/examples/IdentityVertex.java
* giraph-hive/src/test/java/org/apache/giraph/hive/vertexes/VertexSumEdges.java
*
giraph-examples/src/test/java/org/apache/giraph/examples/PageRankComputationTest.java
* giraph-examples/src/main/java/org/apache/giraph/examples/RandomWalkVertex.java
* giraph-core/src/main/java/org/apache/giraph/comm/ServerData.java
*
giraph-core/src/main/java/org/apache/giraph/io/internal/WrappedVertexOutputFormat.java
*
giraph-core/src/main/java/org/apache/giraph/benchmark/ShortestPathsBenchmark.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleCombinerVertex.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleVertexWithWorkerContext.java
* giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayVertexIdData.java
*
giraph-core/src/main/java/org/apache/giraph/benchmark/RandomMessageBenchmark.java
*
giraph-examples/src/test/java/org/apache/giraph/examples/SimpleShortestPathsComputationTest.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleMsgComputation.java
*
giraph-accumulo/src/test/java/org/apache/giraph/io/accumulo/TestAccumuloVertexFormat.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/SequenceFileVertexInputFormat.java
*
giraph-hive/src/main/java/org/apache/giraph/hive/output/SimpleVertexToHive.java
* giraph-examples/src/test/java/org/apache/giraph/TestGraphPartitioner.java
* giraph-examples/src/main/java/org/apache/giraph/examples/PageRankVertex.java
*
giraph-core/src/main/java/org/apache/giraph/benchmark/ShortestPathsComputation.java
*
giraph-hive/src/main/java/org/apache/giraph/hive/input/edge/AbstractHiveToEdge.java
*
giraph-examples/src/test/java/org/apache/giraph/examples/SimpleTriangleClosingVertexTest.java
*
giraph-examples/src/test/java/org/apache/giraph/examples/ConnectedComponentsComputationTestInMemory.java
* giraph-core/src/main/java/org/apache/giraph/partition/ByteArrayPartition.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimplePageRankComputation.java
* giraph-examples/src/main/java/org/apache/giraph/examples/SimpleMsgVertex.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/IntIntTextVertexValueInputFormat.java
*
giraph-core/src/main/java/org/apache/giraph/partition/SimpleIntRangePartitionerFactory.java
* giraph-core/src/main/java/org/apache/giraph/graph/GraphState.java
* giraph-core/src/main/java/org/apache/giraph/graph/VertexValueFactory.java
*
giraph-core/src/main/java/org/apache/giraph/comm/messages/ByteArrayMessagesPerVertexStore.java
* giraph-core/src/main/java/org/apache/giraph/conf/GiraphClasses.java
* CHANGELOG
*
giraph-core/src/main/java/org/apache/giraph/comm/netty/handler/WorkerRequestServerHandler.java
*
giraph-hbase/src/test/java/org/apache/giraph/io/hbase/edgemarker/TableEdgeInputFormat.java
* giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyMasterServer.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/SequenceFileVertexOutputFormat.java
* giraph-hive/src/test/java/org/apache/giraph/hive/vertexes/package-info.java
* giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayVertexIdEdges.java
* giraph-examples/src/test/java/org/apache/giraph/examples/TestPageRank.java
*
giraph-hcatalog/src/main/java/org/apache/giraph/io/hcatalog/HCatalogVertexInputFormat.java
* giraph-core/src/main/java/org/apache/giraph/io/internal/WrappedEdgeReader.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleShortestPathsVertex.java
*
giraph-core/src/main/java/org/apache/giraph/io/filters/DefaultVertexInputFilter.java
* giraph-core/src/main/java/org/apache/giraph/graph/Computation.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/AdjacencyListTextVertexOutputFormat.java
*
giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerMessagesRequest.java
* giraph-core/src/main/java/org/apache/giraph/graph/VertexMutations.java
*
giraph-core/src/main/java/org/apache/giraph/benchmark/WeightedPageRankVertex.java
* giraph-core/src/main/java/org/apache/giraph/benchmark/PageRankComputation.java
*
giraph-core/src/main/java/org/apache/giraph/comm/messages/MessageStoreFactory.java
* giraph-core/src/main/java/org/apache/giraph/utils/VertexIdIterator.java
* giraph-core/src/main/java/org/apache/giraph/master/BspServiceMaster.java
* giraph-core/src/main/java/org/apache/giraph/edge/ConfigurableOutEdges.java
*
giraph-core/src/main/java/org/apache/giraph/partition/HashRangePartitionerFactory.java
*
giraph-core/src/main/java/org/apache/giraph/comm/messages/InMemoryMessageStoreFactory.java
*
giraph-core/src/main/java/org/apache/giraph/io/iterables/VertexReaderWrapper.java
*
giraph-core/src/main/java/org/apache/giraph/partition/DiskBackedPartitionStore.java
* giraph-core/src/main/java/org/apache/giraph/comm/SendMessageCache.java
*
giraph-hive/src/main/java/org/apache/giraph/hive/common/DefaultConfigurableAndTableSchemaAware.java
* giraph-core/src/main/java/org/apache/giraph/io/VertexReader.java
*
giraph-core/src/main/java/org/apache/giraph/partition/WorkerGraphPartitioner.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleCombinerComputation.java
*
giraph-core/src/main/java/org/apache/giraph/partition/ReusesObjectsPartition.java
* giraph-core/src/main/java/org/apache/giraph/bsp/CentralizedService.java
*
giraph-core/src/main/java/org/apache/giraph/io/filters/DefaultEdgeInputFilter.java
* giraph-core/src/main/java/org/apache/giraph/partition/RangeSplitHint.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/PseudoRandomIntNullVertexInputFormat.java
* giraph-core/src/main/java/org/apache/giraph/master/SuperstepClasses.java
*
giraph-core/src/main/java/org/apache/giraph/job/GiraphConfigurationValidator.java
*
giraph-core/src/main/java/org/apache/giraph/partition/MasterGraphPartitioner.java
* giraph-examples/src/test/java/org/apache/giraph/TestComputationState.java
*
giraph-hive/src/test/java/org/apache/giraph/hive/computations/ComputationSumEdges.java
* giraph-core/src/main/java/org/apache/giraph/io/filters/VertexInputFilter.java
*
giraph-core/src/main/java/org/apache/giraph/partition/SimplePartitionStore.java
*
giraph-core/src/main/java/org/apache/giraph/worker/WorkerAggregatorHandler.java
* giraph-core/src/test/java/org/apache/giraph/yarn/TestYarnJob.java
* giraph-core/src/test/java/org/apache/giraph/utils/MockUtils.java
* giraph-examples/src/test/java/org/apache/giraph/TestNotEnoughMapTasks.java
* giraph-core/src/main/java/org/apache/giraph/io/SimpleVertexWriter.java
* giraph-core/src/main/java/org/apache/giraph/graph/GraphTaskManager.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleOutDegreeCountVertex.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleInDegreeCountVertex.java
*
giraph-examples/src/test/java/org/apache/giraph/examples/RandomWalkWithRestartVertexTest.java
*
giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleSuperstepComputation.java
* giraph-hive/src/main/java/org/apache/giraph/hive/output/HiveVertexWriter.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/VertexWithDoubleValueDoubleEdgeTextOutputFormat.java
*
giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayVertexIdMessages.java
* giraph-core/src/test/java/org/apache/giraph/vertices/VertexDoNothing.java
*
giraph-core/src/main/java/org/apache/giraph/partition/HashPartitionerFactory.java
*
giraph-core/src/test/java/org/apache/giraph/io/TestIdWithValueTextOutputFormat.java
* giraph-core/src/main/java/org/apache/giraph/master/MasterCompute.java
* giraph-examples/src/test/java/org/apache/giraph/TestManualCheckpoint.java
* giraph-core/src/main/java/org/apache/giraph/io/VertexOutputFormat.java
* giraph-examples/src/test/java/org/apache/giraph/vertex/TestVertexTypes.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleMasterComputeComputation.java
*
giraph-core/src/main/java/org/apache/giraph/partition/GraphPartitionerFactory.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/LongDoubleDoubleTextInputFormat.java
*
giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyWorkerAggregatorRequestProcessor.java
* giraph-core/src/main/java/org/apache/giraph/utils/TestGraph.java
*
giraph-core/src/test/java/org/apache/giraph/master/TestComputationCombinerTypes.java
*
giraph-core/src/main/java/org/apache/giraph/partition/HashRangeWorkerPartitioner.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/AggregatorsTestComputation.java
* giraph-core/src/main/java/org/apache/giraph/worker/InputSplitsCallable.java
*
giraph-examples/src/test/java/org/apache/giraph/examples/ConnectedComponentsComputationTest.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/RandomWalkWithRestartVertex.java
*
giraph-core/src/main/java/org/apache/giraph/master/MasterAggregatorHandler.java
*
giraph-examples/src/test/java/org/apache/giraph/examples/RandomWalkWithRestartComputationTest.java
* giraph-core/src/main/java/org/apache/giraph/edge/MutableEdgesIterable.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleOutDegreeCountComputation.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleMasterComputeVertex.java
* giraph-core/src/main/java/org/apache/giraph/io/VertexWriter.java
* giraph-core/src/main/java/org/apache/giraph/graph/Vertex.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleFailComputation.java
* giraph-core/src/main/java/org/apache/giraph/graph/GraphMapper.java
*
giraph-hive/src/test/java/org/apache/giraph/hive/computations/ComputationCountEdges.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleMutateGraphComputation.java
*
giraph-core/src/main/java/org/apache/giraph/comm/requests/SendPartitionCurrentMessagesRequest.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/RandomWalkVertexMasterCompute.java
*
giraph-examples/src/test/java/org/apache/giraph/aggregators/TestAggregatorsHandling.java
* giraph-core/src/main/java/org/apache/giraph/comm/requests/WorkerRequest.java
* giraph-core/src/test/java/org/apache/giraph/comm/ConnectionTest.java
* giraph-core/src/main/java/org/apache/giraph/bsp/CentralizedServiceWorker.java
* giraph-core/src/test/java/org/apache/giraph/io/TestEdgeInput.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/RandomWalkComputation.java
* giraph-hive/src/main/java/org/apache/giraph/hive/HiveGiraphRunner.java
*
giraph-core/src/main/java/org/apache/giraph/benchmark/WeightedPageRankBenchmark.java
* giraph-core/src/main/java/org/apache/giraph/comm/WorkerServer.java
* giraph-core/src/test/java/org/apache/giraph/vertices/VertexCountEdges.java
*
giraph-core/src/main/java/org/apache/giraph/comm/requests/SendVertexRequest.java
*
giraph-accumulo/src/main/java/org/apache/giraph/io/accumulo/AccumuloVertexInputFormat.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/TextVertexValueInputFormat.java
*
giraph-hive/src/test/java/org/apache/giraph/hive/computations/package-info.java
* giraph-core/src/main/java/org/apache/giraph/comm/SendEdgeCache.java
* giraph-core/src/test/java/org/apache/giraph/partition/TestPartitionStores.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimplePageRankVertex.java
*
giraph-core/src/main/java/org/apache/giraph/partition/SimpleLongRangePartitionerFactory.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleLongDoubleDoubleDoubleIdentityVertex.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/multi/VertexInputFormatDescription.java
* giraph-core/src/main/java/org/apache/giraph/utils/ConfigurationUtils.java
* giraph-core/src/test/java/org/apache/giraph/utils/IntNoOpComputation.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/multi/MultiEdgeInputFormat.java
*
giraph-core/src/test/java/org/apache/giraph/io/TestTextDoubleDoubleAdjacencyListVertexInputFormat.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleTriangleClosingVertex.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleCheckpointVertex.java
*
giraph-hbase/src/test/java/org/apache/giraph/io/hbase/TestHBaseRootMarkerVertextFormat.java
*
giraph-examples/src/test/java/org/apache/giraph/examples/PageRankVertexTest.java
*
giraph-core/src/main/java/org/apache/giraph/benchmark/AggregatorsBenchmark.java
* giraph-core/src/main/java/org/apache/giraph/comm/SendPartitionCache.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/AggregatorsTestVertex.java
*
giraph-core/src/test/java/org/apache/giraph/partition/TestGiraphTransferRegulator.java
*
giraph-core/src/main/java/org/apache/giraph/comm/messages/SequentialFileMessageStore.java
*
giraph-hive/src/main/java/org/apache/giraph/hive/input/vertex/HiveVertexReader.java
*
giraph-examples/src/test/java/org/apache/giraph/examples/SimpleShortestPathsVertexTest.java
*
giraph-core/src/main/java/org/apache/giraph/utils/InMemoryVertexInputFormat.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleMutateGraphVertex.java
* giraph-core/src/test/java/org/apache/giraph/io/TestFilters.java
* giraph-examples/src/test/java/org/apache/giraph/TestAutoCheckpoint.java
* giraph-core/src/main/java/org/apache/giraph/utils/InternalVertexRunner.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleInDegreeCountComputation.java
*
giraph-core/src/main/java/org/apache/giraph/partition/SimpleRangeMasterPartitioner.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/JsonLongDoubleFloatDoubleVertexInputFormat.java
*
giraph-accumulo/src/test/java/org/apache/giraph/io/accumulo/edgemarker/AccumuloEdgeOutputFormat.java
* giraph-examples/src/test/java/org/apache/giraph/TestMutateGraph.java
*
giraph-core/src/test/java/org/apache/giraph/io/TestLongDoubleDoubleAdjacencyListVertexInputFormat.java
* giraph-core/src/main/java/org/apache/giraph/graph/ComputeCallable.java
* giraph-core/src/test/java/org/apache/giraph/comm/RequestFailureTest.java
* giraph-core/src/main/java/org/apache/giraph/partition/PartitionStore.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/ConnectedComponentsComputation.java
*
giraph-core/src/main/java/org/apache/giraph/comm/WorkerClientRequestProcessor.java
* giraph-core/src/main/java/org/apache/giraph/partition/SimplePartition.java
* giraph-core/src/main/java/org/apache/giraph/worker/WorkerContext.java
* giraph-core/src/main/java/org/apache/giraph/graph/GiraphTransferRegulator.java
* giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyWorkerClient.java
* giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyMasterClient.java
*
giraph-core/src/main/java/org/apache/giraph/partition/HashWorkerPartitioner.java
*
giraph-core/src/main/java/org/apache/giraph/partition/SimpleRangeWorkerPartitioner.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/TestComputationStateComputation.java
*
giraph-examples/src/test/java/org/apache/giraph/examples/SimpleTriangleClosingComputationTest.java
* giraph-core/src/test/java/org/apache/giraph/graph/TestVertexAndEdges.java
*
giraph-examples/src/test/java/org/apache/giraph/examples/ConnectedComponentsVertexTest.java
*
giraph-core/src/main/java/org/apache/giraph/graph/DefaultVertexValueFactory.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/multi/EdgeInputFormatDescription.java
*
giraph-hive/src/main/java/org/apache/giraph/hive/output/HiveVertexOutputFormat.java
* giraph-core/src/main/java/org/apache/giraph/comm/SendMutationsCache.java
* giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java
* giraph-examples/src/test/java/org/apache/giraph/TestPartitionContext.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/TextVertexOutputFormat.java
* giraph-hive/src/test/java/org/apache/giraph/hive/input/HiveEdgeInputTest.java
* giraph-core/src/main/java/org/apache/giraph/edge/EdgeStore.java
*
giraph-hive/src/main/java/org/apache/giraph/hive/input/vertex/HiveVertexInputFormat.java
*
giraph-core/src/main/java/org/apache/giraph/partition/RangePartitionerFactory.java
* giraph-core/src/main/java/org/apache/giraph/bsp/BspService.java
* giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java
* giraph-core/src/test/java/org/apache/giraph/master/TestSwitchClasses.java
* giraph-core/src/main/java/org/apache/giraph/partition/PartitionContext.java
* giraph-examples/src/test/java/org/apache/giraph/TestBspBasic.java
* giraph-examples/src/main/java/org/apache/giraph/examples/SimpleCheckpoint.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/multi/MultiVertexInputFormat.java
*
giraph-core/src/main/java/org/apache/giraph/partition/RangeWorkerPartitioner.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/PageRankComputation.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/TextDoubleDoubleAdjacencyListVertexInputFormat.java
*
giraph-accumulo/src/test/java/org/apache/giraph/io/accumulo/edgemarker/AccumuloEdgeInputFormat.java
*
giraph-hive/src/test/java/org/apache/giraph/hive/vertexes/VertexCountEdges.java
*
giraph-hive/src/main/java/org/apache/giraph/hive/output/AbstractVertexToHive.java
*
giraph-core/src/main/java/org/apache/giraph/comm/messages/DiskBackedMessageStoreByPartition.java
*
giraph-core/src/main/java/org/apache/giraph/comm/messages/OneMessagePerVertexStore.java
* giraph-core/src/main/java/org/apache/giraph/utils/ReflectionUtils.java
*
giraph-examples/src/main/java/org/apache/giraph/examples/SimpleShortestPathsComputation.java
*
giraph-core/src/main/java/org/apache/giraph/worker/VertexInputSplitsCallableFactory.java
* giraph-core/src/test/java/org/apache/giraph/io/TestJsonBase64Format.java
* giraph-core/src/test/java/org/apache/giraph/master/TestMasterObserver.java
*
giraph-core/src/main/java/org/apache/giraph/io/formats/TextVertexInputFormat.java
* giraph-core/src/main/java/org/apache/giraph/graph/BasicComputation.java
*
giraph-examples/src/test/java/org/apache/giraph/vertex/TestComputationTypes.java
*
giraph-core/src/main/java/org/apache/giraph/worker/EdgeInputSplitsCallableFactory.java
> Decouple Vertex data and Computation, make Computation and Combiner classes
> switchable
> --------------------------------------------------------------------------------------
>
> Key: GIRAPH-667
> URL: https://issues.apache.org/jira/browse/GIRAPH-667
> Project: Giraph
> Issue Type: New Feature
> Reporter: Maja Kabiljo
> Assignee: Maja Kabiljo
> Attachments: GIRAPH-667.patch
>
>
> Currently, our Vertex class holds a lot of stuff which shouldn't be there,
> related to global graph and worker state. We should decouple vertex and
> computation, vertex should be provided by the infrastructure and user should
> implement the computation.
> In many real-world applications there are several different stages, where
> different kind of computation is done and different type of messages are
> sent. This can be done currently by having complicated compute() and encoding
> the message type inside of the message. Much better would be to provide a way
> to change which Computation is used by Giraph. Applications can then be
> considered as pieces which can be put together in a pipeline coordinated by
> master.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
