giraph-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ni...@apache.org
Subject [1/51] [partial] git commit: GIRAPH-457: update module names (nitay)
Date Thu, 20 Dec 2012 04:25:30 GMT
Updated Branches:
  refs/heads/trunk 196238b0d -> 458513917


GIRAPH-457: update module names (nitay)


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

Branch: refs/heads/trunk
Commit: 4585139176e4f3051c2c345c30830b090e364e87
Parents: 196238b
Author: Nitay Joffe <nitay@apache.org>
Authored: Wed Dec 19 16:46:04 2012 -0800
Committer: Nitay Joffe <nitay@apache.org>
Committed: Wed Dec 19 20:24:32 2012 -0800

----------------------------------------------------------------------
 CHANGELOG                                          |    2 +
 README                                             |    6 +-
 giraph-core/pom.xml                                |  312 +++
 giraph-core/src/main/assembly/assembly.xml         |  100 +
 giraph-core/src/main/assembly/compile.xml          |   39 +
 .../java/com/yammer/metrics/core/NoOpCounter.java  |   53 +
 .../yammer/metrics/core/NoOpExecutorService.java   |  132 +
 .../java/com/yammer/metrics/core/NoOpGuage.java    |   34 +
 .../com/yammer/metrics/core/NoOpHistogram.java     |   67 +
 .../java/com/yammer/metrics/core/NoOpMeter.java    |   67 +
 .../java/com/yammer/metrics/core/NoOpTimer.java    |   90 +
 .../java/com/yammer/metrics/core/package-info.java |   21 +
 .../main/java/org/apache/giraph/GiraphRunner.java  |  275 +++
 .../apache/giraph/aggregators/BasicAggregator.java |   58 +
 .../giraph/aggregators/BooleanAndAggregator.java   |   37 +
 .../giraph/aggregators/BooleanOrAggregator.java    |   37 +
 .../aggregators/BooleanOverwriteAggregator.java    |   41 +
 .../giraph/aggregators/DoubleMaxAggregator.java    |   37 +
 .../giraph/aggregators/DoubleMinAggregator.java    |   37 +
 .../aggregators/DoubleOverwriteAggregator.java     |   40 +
 .../aggregators/DoubleProductAggregator.java       |   36 +
 .../giraph/aggregators/DoubleSumAggregator.java    |   34 +
 .../giraph/aggregators/FloatMaxAggregator.java     |   37 +
 .../giraph/aggregators/FloatMinAggregator.java     |   37 +
 .../aggregators/FloatOverwriteAggregator.java      |   39 +
 .../giraph/aggregators/FloatProductAggregator.java |   36 +
 .../giraph/aggregators/FloatSumAggregator.java     |   36 +
 .../giraph/aggregators/IntMaxAggregator.java       |   37 +
 .../giraph/aggregators/IntMinAggregator.java       |   37 +
 .../giraph/aggregators/IntOverwriteAggregator.java |   39 +
 .../giraph/aggregators/IntProductAggregator.java   |   36 +
 .../giraph/aggregators/IntSumAggregator.java       |   36 +
 .../giraph/aggregators/LongMaxAggregator.java      |   37 +
 .../giraph/aggregators/LongMinAggregator.java      |   37 +
 .../aggregators/LongOverwriteAggregator.java       |   39 +
 .../giraph/aggregators/LongProductAggregator.java  |   36 +
 .../giraph/aggregators/LongSumAggregator.java      |   36 +
 .../apache/giraph/aggregators/package-info.java    |   21 +
 .../giraph/benchmark/AggregatorsBenchmark.java     |  289 +++
 .../benchmark/EdgeListVertexPageRankBenchmark.java |   38 +
 .../benchmark/HashMapVertexPageRankBenchmark.java  |   38 +
 .../HashMapVertexShortestPathsBenchmark.java       |   39 +
 .../MultiGraphEdgeListVertexPageRankBenchmark.java |   38 +
 ...GraphRepresentativeVertexPageRankBenchmark.java |   39 +
 .../apache/giraph/benchmark/PageRankBenchmark.java |  231 ++
 .../giraph/benchmark/PageRankComputation.java      |   65 +
 .../giraph/benchmark/RandomMessageBenchmark.java   |  409 ++++
 .../RepresentativeVertexPageRankBenchmark.java     |   39 +
 .../giraph/benchmark/ShortestPathsBenchmark.java   |  168 ++
 .../giraph/benchmark/ShortestPathsComputation.java |   81 +
 .../org/apache/giraph/benchmark/package-info.java  |   21 +
 .../org/apache/giraph/bsp/ApplicationState.java    |   33 +
 .../java/org/apache/giraph/bsp/BspInputFormat.java |   93 +
 .../java/org/apache/giraph/bsp/BspInputSplit.java  |  101 +
 .../org/apache/giraph/bsp/BspOutputFormat.java     |   71 +
 .../org/apache/giraph/bsp/BspRecordReader.java     |   73 +
 .../org/apache/giraph/bsp/BspRecordWriter.java     |   47 +
 .../org/apache/giraph/bsp/CentralizedService.java  |   79 +
 .../giraph/bsp/CentralizedServiceMaster.java       |  135 ++
 .../giraph/bsp/CentralizedServiceWorker.java       |  236 ++
 .../giraph/bsp/ImmutableOutputCommitter.java       |   63 +
 .../java/org/apache/giraph/bsp/SuperstepState.java |   33 +
 .../java/org/apache/giraph/bsp/package-info.java   |   21 +
 .../java/org/apache/giraph/comm/MasterClient.java  |   63 +
 .../java/org/apache/giraph/comm/MasterServer.java  |   38 +
 .../main/java/org/apache/giraph/comm/MsgList.java  |   56 +
 .../org/apache/giraph/comm/SendMessageCache.java   |  196 ++
 .../org/apache/giraph/comm/SendMutationsCache.java |  199 ++
 .../org/apache/giraph/comm/SendPartitionCache.java |  135 ++
 .../java/org/apache/giraph/comm/ServerData.java    |  177 ++
 .../java/org/apache/giraph/comm/WorkerClient.java  |  100 +
 .../giraph/comm/WorkerClientRequestProcessor.java  |  125 +
 .../org/apache/giraph/comm/WorkerClientServer.java |   36 +
 .../java/org/apache/giraph/comm/WorkerServer.java  |   72 +
 .../aggregators/AggregatedValueOutputStream.java   |   45 +
 .../comm/aggregators/AggregatorOutputStream.java   |   49 +
 .../giraph/comm/aggregators/AggregatorUtils.java   |  120 +
 .../comm/aggregators/AllAggregatorServerData.java  |  239 ++
 .../giraph/comm/aggregators/CountingCache.java     |   66 +
 .../comm/aggregators/CountingOutputStream.java     |   85 +
 .../aggregators/OwnerAggregatorServerData.java     |  187 ++
 .../comm/aggregators/SendAggregatedValueCache.java |   87 +
 .../comm/aggregators/SendAggregatorCache.java      |   91 +
 .../WorkerAggregatorRequestProcessor.java          |   64 +
 .../giraph/comm/aggregators/package-info.java      |   21 +
 .../giraph/comm/messages/BasicMessageStore.java    |   67 +
 .../messages/ByteArrayMessagesPerVertexStore.java  |  292 +++
 .../comm/messages/DiskBackedMessageStore.java      |  407 ++++
 .../DiskBackedMessageStoreByPartition.java         |  383 +++
 .../comm/messages/FlushableMessageStore.java       |   40 +
 .../apache/giraph/comm/messages/MessageStore.java  |   53 +
 .../comm/messages/MessageStoreByPartition.java     |   82 +
 .../giraph/comm/messages/MessageStoreFactory.java  |   39 +
 .../comm/messages/OneMessagePerVertexStore.java    |  217 ++
 .../comm/messages/SequentialFileMessageStore.java  |  395 +++
 .../giraph/comm/messages/SimpleMessageStore.java   |  245 ++
 .../apache/giraph/comm/messages/package-info.java  |   21 +
 .../org/apache/giraph/comm/netty/ByteCounter.java  |  234 ++
 .../apache/giraph/comm/netty/ChannelRotater.java   |  125 +
 .../org/apache/giraph/comm/netty/NettyClient.java  |  801 ++++++
 .../giraph/comm/netty/NettyMasterClient.java       |  119 +
 .../giraph/comm/netty/NettyMasterServer.java       |   61 +
 .../org/apache/giraph/comm/netty/NettyServer.java  |  392 +++
 .../NettyWorkerAggregatorRequestProcessor.java     |  146 ++
 .../giraph/comm/netty/NettyWorkerClient.java       |  138 ++
 .../netty/NettyWorkerClientRequestProcessor.java   |  405 ++++
 .../giraph/comm/netty/NettyWorkerServer.java       |  242 ++
 .../apache/giraph/comm/netty/SaslNettyClient.java  |  219 ++
 .../apache/giraph/comm/netty/SaslNettyServer.java  |  210 ++
 ...dAdaptiveReceiveBufferSizePredictorFactory.java |  133 +
 .../netty/handler/AddressRequestIdGenerator.java   |   53 +
 .../comm/netty/handler/AuthorizeServerHandler.java |   80 +
 .../giraph/comm/netty/handler/ClientRequestId.java |   73 +
 .../netty/handler/MasterRequestServerHandler.java  |   79 +
 .../giraph/comm/netty/handler/RequestDecoder.java  |  103 +
 .../giraph/comm/netty/handler/RequestEncoder.java  |  107 +
 .../giraph/comm/netty/handler/RequestInfo.java     |  113 +
 .../comm/netty/handler/RequestServerHandler.java   |  181 ++
 .../comm/netty/handler/ResponseClientHandler.java  |  141 ++
 .../giraph/comm/netty/handler/ResponseEncoder.java |  100 +
 .../comm/netty/handler/SaslClientHandler.java      |  168 ++
 .../comm/netty/handler/SaslServerHandler.java      |  239 ++
 .../netty/handler/WorkerRequestReservedMap.java    |   80 +
 .../netty/handler/WorkerRequestServerHandler.java  |   88 +
 .../giraph/comm/netty/handler/package-info.java    |   21 +
 .../org/apache/giraph/comm/netty/package-info.java |   21 +
 .../java/org/apache/giraph/comm/package-info.java  |   21 +
 .../giraph/comm/requests/ByteArrayRequest.java     |   85 +
 .../apache/giraph/comm/requests/MasterRequest.java |   33 +
 .../apache/giraph/comm/requests/RequestType.java   |   76 +
 .../giraph/comm/requests/SaslCompleteRequest.java  |   47 +
 .../comm/requests/SaslTokenMessageRequest.java     |  111 +
 .../requests/SendAggregatorsToMasterRequest.java   |   61 +
 .../requests/SendAggregatorsToOwnerRequest.java    |   90 +
 .../requests/SendAggregatorsToWorkerRequest.java   |   88 +
 .../SendPartitionCurrentMessagesRequest.java       |   97 +
 .../requests/SendPartitionMutationsRequest.java    |  134 +
 .../giraph/comm/requests/SendVertexRequest.java    |   89 +
 .../requests/SendWorkerAggregatorsRequest.java     |   84 +
 .../comm/requests/SendWorkerMessagesRequest.java   |  131 +
 .../apache/giraph/comm/requests/WorkerRequest.java |   41 +
 .../giraph/comm/requests/WritableRequest.java      |  129 +
 .../apache/giraph/comm/requests/package-info.java  |   21 +
 .../java/org/apache/giraph/conf/GiraphClasses.java |  560 +++++
 .../apache/giraph/conf/GiraphConfiguration.java    |  615 +++++
 .../org/apache/giraph/conf/GiraphConstants.java    |  569 +++++
 .../conf/ImmutableClassesGiraphConfigurable.java   |   49 +
 .../conf/ImmutableClassesGiraphConfiguration.java  |  554 +++++
 .../java/org/apache/giraph/conf/package-info.java  |   21 +
 .../giraph/counters/GiraphHadoopCounter.java       |  141 ++
 .../org/apache/giraph/counters/GiraphStats.java    |  172 ++
 .../org/apache/giraph/counters/GiraphTimers.java   |  158 ++
 .../apache/giraph/counters/HadoopCountersBase.java |   62 +
 .../org/apache/giraph/counters/package-info.java   |   21 +
 .../giraph/examples/AggregatorsTestVertex.java     |  134 +
 .../java/org/apache/giraph/examples/Algorithm.java |   41 +
 .../giraph/examples/ConnectedComponentsVertex.java |   96 +
 .../apache/giraph/examples/DoubleSumCombiner.java  |   40 +
 .../giraph/examples/GeneratedVertexReader.java     |   92 +
 .../org/apache/giraph/examples/IdentityVertex.java |   45 +
 .../LongDoubleFloatDoubleTextInputFormat.java      |   92 +
 .../giraph/examples/MinimumDoubleCombiner.java     |   42 +
 .../apache/giraph/examples/MinimumIntCombiner.java |   41 +
 ...lizingLongDoubleFloatDoubleTextInputFormat.java |  125 +
 .../apache/giraph/examples/RandomWalkVertex.java   |  135 ++
 .../examples/RandomWalkWithRestartVertex.java      |   84 +
 .../giraph/examples/RandomWalkWorkerContext.java   |  159 ++
 .../giraph/examples/SimpleAggregatorWriter.java    |   71 +
 .../giraph/examples/SimpleCheckpointVertex.java    |  286 +++
 .../giraph/examples/SimpleCombinerVertex.java      |   65 +
 .../apache/giraph/examples/SimpleFailVertex.java   |   69 +
 .../giraph/examples/SimpleInDegreeCountVertex.java |   55 +
 ...SimpleLongDoubleDoubleDoubleIdentityVertex.java |   32 +
 .../giraph/examples/SimpleMasterComputeVertex.java |  105 +
 .../apache/giraph/examples/SimpleMsgVertex.java    |   62 +
 .../giraph/examples/SimpleMutateGraphVertex.java   |  198 ++
 .../examples/SimpleOutDegreeCountVertex.java       |   43 +
 .../giraph/examples/SimplePageRankVertex.java      |  252 ++
 .../giraph/examples/SimpleShortestPathsVertex.java |   83 +
 .../apache/giraph/examples/SimpleSumCombiner.java  |   41 +
 .../giraph/examples/SimpleSuperstepVertex.java     |  154 ++
 .../examples/SimpleTextVertexOutputFormat.java     |   55 +
 .../examples/SimpleTriangleClosingVertex.java      |  151 ++
 .../examples/SimpleVertexWithWorkerContext.java    |  197 ++
 .../org/apache/giraph/examples/VerifyMessage.java  |  220 ++
 ...exWithDoubleValueFloatEdgeTextOutputFormat.java |   57 +
 .../org/apache/giraph/examples/package-info.java   |   21 +
 .../graph/AddressesAndPartitionsWritable.java      |  143 ++
 .../java/org/apache/giraph/graph/Aggregator.java   |   67 +
 .../org/apache/giraph/graph/AggregatorWrapper.java |  146 ++
 .../org/apache/giraph/graph/AggregatorWriter.java  |   73 +
 .../giraph/graph/BasicVertexValueReader.java       |   56 +
 .../java/org/apache/giraph/graph/BspService.java   | 1069 ++++++++
 .../org/apache/giraph/graph/BspServiceMaster.java  | 1871 +++++++++++++++
 .../org/apache/giraph/graph/BspServiceWorker.java  | 1392 +++++++++++
 .../java/org/apache/giraph/graph/BspUtils.java     |  523 ++++
 .../java/org/apache/giraph/graph/Combiner.java     |   53 +
 .../org/apache/giraph/graph/ComputeCallable.java   |  225 ++
 .../apache/giraph/graph/DefaultMasterCompute.java  |   50 +
 .../apache/giraph/graph/DefaultVertexResolver.java |  224 ++
 .../apache/giraph/graph/DefaultWorkerContext.java  |   41 +
 .../main/java/org/apache/giraph/graph/Edge.java    |  131 +
 .../org/apache/giraph/graph/EdgeInputFormat.java   |   75 +
 .../giraph/graph/EdgeInputSplitsCallable.java      |  165 ++
 .../graph/EdgeInputSplitsCallableFactory.java      |   94 +
 .../org/apache/giraph/graph/EdgeListVertex.java    |   72 +
 .../apache/giraph/graph/EdgeListVertexBase.java    |  108 +
 .../java/org/apache/giraph/graph/EdgeReader.java   |   84 +
 .../org/apache/giraph/graph/EdgeWithSource.java    |   65 +
 .../giraph/graph/FinishedSuperstepStats.java       |   44 +
 .../org/apache/giraph/graph/GiraphInputFormat.java |   42 +
 .../java/org/apache/giraph/graph/GiraphJob.java    |  280 +++
 .../giraph/graph/GiraphTransferRegulator.java      |  199 ++
 .../apache/giraph/graph/GiraphTypeValidator.java   |  240 ++
 .../java/org/apache/giraph/graph/GlobalStats.java  |  111 +
 .../java/org/apache/giraph/graph/GraphMapper.java  |  772 ++++++
 .../java/org/apache/giraph/graph/GraphState.java   |  116 +
 .../org/apache/giraph/graph/GraphStateAware.java   |   47 +
 .../org/apache/giraph/graph/HashMapVertex.java     |  160 ++
 .../org/apache/giraph/graph/InputSplitEvents.java  |   85 +
 .../giraph/graph/InputSplitPathOrganizer.java      |  195 ++
 .../org/apache/giraph/graph/InputSplitPaths.java   |   88 +
 .../apache/giraph/graph/InputSplitsCallable.java   |  389 +++
 .../giraph/graph/InputSplitsCallableFactory.java   |   40 +
 .../apache/giraph/graph/IntIntNullIntVertex.java   |  100 +
 .../apache/giraph/graph/IntNullNullNullVertex.java |   59 +
 .../graph/LongDoubleFloatDoubleEdgeListVertex.java |  181 ++
 .../giraph/graph/LongDoubleFloatDoubleVertex.java  |  217 ++
 .../giraph/graph/LongDoubleNullDoubleVertex.java   |  137 ++
 .../giraph/graph/MasterAggregatorHandler.java      |  344 +++
 .../apache/giraph/graph/MasterAggregatorUsage.java |   71 +
 .../org/apache/giraph/graph/MasterCompute.java     |  175 ++
 .../java/org/apache/giraph/graph/MasterInfo.java   |   35 +
 .../java/org/apache/giraph/graph/MasterThread.java |  191 ++
 .../giraph/graph/MultiGraphEdgeListVertex.java     |   61 +
 .../graph/MultiGraphRepresentativeVertex.java      |   48 +
 .../org/apache/giraph/graph/MutableVertex.java     |  118 +
 .../apache/giraph/graph/RepresentativeVertex.java  |   68 +
 .../giraph/graph/RepresentativeVertexBase.java     |  285 +++
 .../apache/giraph/graph/SimpleMutableVertex.java   |  130 +
 .../java/org/apache/giraph/graph/SimpleVertex.java |  104 +
 .../java/org/apache/giraph/graph/TaskInfo.java     |  152 ++
 .../apache/giraph/graph/TextAggregatorWriter.java  |  126 +
 .../main/java/org/apache/giraph/graph/Vertex.java  |  405 ++++
 .../org/apache/giraph/graph/VertexChanges.java     |   68 +
 .../org/apache/giraph/graph/VertexEdgeCount.java   |   88 +
 .../org/apache/giraph/graph/VertexInputFormat.java |   82 +
 .../giraph/graph/VertexInputSplitsCallable.java    |  180 ++
 .../graph/VertexInputSplitsCallableFactory.java    |   94 +
 .../org/apache/giraph/graph/VertexMutations.java   |  212 ++
 .../apache/giraph/graph/VertexOutputFormat.java    |   81 +
 .../java/org/apache/giraph/graph/VertexReader.java |   87 +
 .../org/apache/giraph/graph/VertexResolver.java    |   62 +
 .../giraph/graph/VertexValueInputFormat.java       |   58 +
 .../org/apache/giraph/graph/VertexValueReader.java |   61 +
 .../java/org/apache/giraph/graph/VertexWriter.java |   67 +
 .../giraph/graph/WorkerAggregatorHandler.java      |  294 +++
 .../apache/giraph/graph/WorkerAggregatorUsage.java |   44 +
 .../org/apache/giraph/graph/WorkerContext.java     |  121 +
 .../java/org/apache/giraph/graph/WorkerInfo.java   |   35 +
 .../giraph/graph/WorkerThreadAggregatorUsage.java  |   31 +
 .../java/org/apache/giraph/graph/package-info.java |   22 +
 .../graph/partition/BasicPartitionOwner.java       |  163 ++
 .../giraph/graph/partition/ByteArrayPartition.java |  277 +++
 .../graph/partition/DiskBackedPartitionStore.java  |  364 +++
 .../graph/partition/GraphPartitionerFactory.java   |   52 +
 .../graph/partition/HashMasterPartitioner.java     |  157 ++
 .../graph/partition/HashPartitionerFactory.java    |   60 +
 .../partition/HashRangePartitionerFactory.java     |   60 +
 .../partition/HashRangeWorkerPartitioner.java      |   50 +
 .../graph/partition/HashWorkerPartitioner.java     |  119 +
 .../graph/partition/MasterGraphPartitioner.java    |   83 +
 .../apache/giraph/graph/partition/Partition.java   |  122 +
 .../giraph/graph/partition/PartitionBalancer.java  |  288 +++
 .../giraph/graph/partition/PartitionExchange.java  |   77 +
 .../giraph/graph/partition/PartitionOwner.java     |   81 +
 .../giraph/graph/partition/PartitionStats.java     |  178 ++
 .../giraph/graph/partition/PartitionStore.java     |  116 +
 .../giraph/graph/partition/PartitionUtils.java     |  151 ++
 .../graph/partition/RangeMasterPartitioner.java    |   43 +
 .../graph/partition/RangePartitionOwner.java       |   74 +
 .../graph/partition/RangePartitionStats.java       |   68 +
 .../graph/partition/RangePartitionerFactory.java   |   43 +
 .../giraph/graph/partition/RangeSplitHint.java     |   72 +
 .../graph/partition/RangeWorkerPartitioner.java    |   78 +
 .../giraph/graph/partition/SimplePartition.java    |  188 ++
 .../graph/partition/SimplePartitionStore.java      |  105 +
 .../graph/partition/WorkerGraphPartitioner.java    |   94 +
 .../giraph/graph/partition/package-info.java       |   21 +
 .../SuperstepHashPartitionerFactory.java           |  127 +
 .../apache/giraph/integration/package-info.java    |   21 +
 .../io/AdjacencyListTextVertexInputFormat.java     |  181 ++
 .../io/AdjacencyListTextVertexOutputFormat.java    |   88 +
 .../giraph/io/GeneratedVertexInputFormat.java      |   56 +
 .../apache/giraph/io/GiraphFileInputFormat.java    |  339 +++
 .../apache/giraph/io/GiraphTextInputFormat.java    |   51 +
 .../giraph/io/IdWithValueTextOutputFormat.java     |   98 +
 .../giraph/io/IntIntNullIntTextInputFormat.java    |   93 +
 .../io/IntIntTextVertexValueInputFormat.java       |   76 +
 .../giraph/io/IntNullNullNullTextInputFormat.java  |   75 +
 .../giraph/io/IntNullTextEdgeInputFormat.java      |   78 +
 .../apache/giraph/io/JsonBase64VertexFormat.java   |   36 +
 .../giraph/io/JsonBase64VertexInputFormat.java     |  151 ++
 .../giraph/io/JsonBase64VertexOutputFormat.java    |  109 +
 ...JsonLongDoubleFloatDoubleVertexInputFormat.java |  108 +
 ...sonLongDoubleFloatDoubleVertexOutputFormat.java |   77 +
 ...DoubleDoubleAdjacencyListVertexInputFormat.java |   84 +
 .../giraph/io/PseudoRandomEdgeInputFormat.java     |  197 ++
 .../giraph/io/PseudoRandomVertexInputFormat.java   |  198 ++
 .../giraph/io/SequenceFileVertexInputFormat.java   |  115 +
 ...DoubleDoubleAdjacencyListVertexInputFormat.java |   78 +
 .../org/apache/giraph/io/TextEdgeInputFormat.java  |  283 +++
 .../apache/giraph/io/TextVertexInputFormat.java    |  432 ++++
 .../apache/giraph/io/TextVertexOutputFormat.java   |  165 ++
 .../giraph/io/TextVertexValueInputFormat.java      |  260 ++
 .../java/org/apache/giraph/io/package-info.java    |   21 +
 .../giraph/master/DefaultMasterObserver.java       |   55 +
 .../org/apache/giraph/master/MasterObserver.java   |   46 +
 .../org/apache/giraph/master/package-info.java     |   21 +
 .../apache/giraph/metrics/AggregatedMetric.java    |  112 +
 .../apache/giraph/metrics/AggregatedMetrics.java   |  170 ++
 .../org/apache/giraph/metrics/GiraphMetrics.java   |  141 ++
 .../giraph/metrics/GiraphMetricsRegistry.java      |  253 ++
 .../org/apache/giraph/metrics/GiraphTimer.java     |  106 +
 .../apache/giraph/metrics/GiraphTimerContext.java  |   56 +
 .../org/apache/giraph/metrics/LongAndTimeUnit.java |   88 +
 .../giraph/metrics/MetricsRegistryDebugger.java    |   57 +
 .../apache/giraph/metrics/NoOpMetricsRegistry.java |  198 ++
 .../metrics/ResetSuperstepMetricsObserver.java     |   32 +
 .../giraph/metrics/SuperstepMetricsRegistry.java   |   76 +
 .../java/org/apache/giraph/metrics/ValueGauge.java |   75 +
 .../apache/giraph/metrics/ValueWithHostname.java   |   72 +
 .../giraph/metrics/WorkerSuperstepMetrics.java     |  181 ++
 .../org/apache/giraph/metrics/package-info.java    |   21 +
 .../main/java/org/apache/giraph/package-info.java  |   21 +
 .../org/apache/giraph/utils/AnnotationUtils.java   |  254 ++
 .../org/apache/giraph/utils/ArrayListWritable.java |  125 +
 .../org/apache/giraph/utils/ByteArrayIterable.java |   90 +
 .../org/apache/giraph/utils/ByteArrayIterator.java |   79 +
 .../giraph/utils/ByteArrayVertexIdMessages.java    |  337 +++
 .../org/apache/giraph/utils/CollectionUtils.java   |  118 +
 .../org/apache/giraph/utils/ComparisonUtils.java   |   62 +
 .../utils/DynamicChannelBufferInputStream.java     |  231 ++
 .../utils/DynamicChannelBufferOutputStream.java    |  187 ++
 .../org/apache/giraph/utils/EdgeIterables.java     |   73 +
 .../org/apache/giraph/utils/EmptyIterable.java     |   64 +
 .../org/apache/giraph/utils/ExpectedBarrier.java   |  125 +
 .../giraph/utils/ExtendedByteArrayDataInput.java   |  133 +
 .../giraph/utils/ExtendedByteArrayDataOutput.java  |  173 ++
 .../org/apache/giraph/utils/ExtendedDataInput.java |   39 +
 .../apache/giraph/utils/ExtendedDataOutput.java    |   67 +
 .../java/org/apache/giraph/utils/FakeTime.java     |   61 +
 .../java/org/apache/giraph/utils/FileUtils.java    |  180 ++
 .../org/apache/giraph/utils/IncreasingBitSet.java  |  122 +
 .../main/java/org/apache/giraph/utils/IntPair.java |   75 +
 .../apache/giraph/utils/InternalVertexRunner.java  |  245 ++
 .../java/org/apache/giraph/utils/LoggerUtils.java  |   74 +
 .../java/org/apache/giraph/utils/MathUtils.java    |   57 +
 .../java/org/apache/giraph/utils/MemoryUtils.java  |   94 +
 .../java/org/apache/giraph/utils/PairList.java     |  153 ++
 .../org/apache/giraph/utils/PairListWritable.java  |   76 +
 .../org/apache/giraph/utils/ProgressableUtils.java |  339 +++
 .../org/apache/giraph/utils/ReflectionUtils.java   |  193 ++
 .../utils/RepresentativeByteArrayIterable.java     |   74 +
 .../utils/RepresentativeByteArrayIterator.java     |   58 +
 .../java/org/apache/giraph/utils/SystemTime.java   |   71 +
 .../main/java/org/apache/giraph/utils/Time.java    |  101 +
 .../java/org/apache/giraph/utils/TimedLogger.java  |   69 +
 .../main/java/org/apache/giraph/utils/Times.java   |  137 ++
 .../utils/UnmodifiableDoubleArrayIterator.java     |   53 +
 .../giraph/utils/UnmodifiableIntArrayIterator.java |   53 +
 .../utils/UnmodifiableLongArrayIterator.java       |   53 +
 .../UnmodifiableLongFloatEdgeArrayIterable.java    |   72 +
 .../UnmodifiableLongNullEdgeArrayIterable.java     |   67 +
 .../giraph/utils/UnsafeByteArrayInputStream.java   |  354 +++
 .../giraph/utils/UnsafeByteArrayOutputStream.java  |  321 +++
 .../org/apache/giraph/utils/WritableUtils.java     |  326 +++
 .../java/org/apache/giraph/utils/package-info.java |   21 +
 .../main/java/org/apache/giraph/zk/BspEvent.java   |   49 +
 .../java/org/apache/giraph/zk/PredicateLock.java   |  142 ++
 .../java/org/apache/giraph/zk/ZooKeeperExt.java    |  559 +++++
 .../org/apache/giraph/zk/ZooKeeperManager.java     |  914 +++++++
 .../java/org/apache/giraph/zk/package-info.java    |   21 +
 giraph-core/src/site/resources/css/site.css        |   29 +
 .../src/site/resources/images/ApacheGiraph.svg     |  484 ++++
 giraph-core/src/site/site.xml                      |   69 +
 giraph-core/src/site/xdoc/index.xml                |  108 +
 .../src/test/java/org/apache/giraph/BspCase.java   |  368 +++
 .../java/org/apache/giraph/TestAutoCheckpoint.java |   88 +
 .../test/java/org/apache/giraph/TestBspBasic.java  |  530 ++++
 .../test/java/org/apache/giraph/TestEdgeInput.java |  165 ++
 .../org/apache/giraph/TestGiraphConfiguration.java |   72 +
 .../org/apache/giraph/TestGraphPartitioner.java    |  162 ++
 .../org/apache/giraph/TestJsonBase64Format.java    |  104 +
 .../org/apache/giraph/TestManualCheckpoint.java    |  115 +
 .../java/org/apache/giraph/TestMasterObserver.java |  103 +
 .../java/org/apache/giraph/TestMutateGraph.java    |   64 +
 .../org/apache/giraph/TestNotEnoughMapTasks.java   |   75 +
 .../test/java/org/apache/giraph/TestPageRank.java  |  104 +
 .../java/org/apache/giraph/TestPredicateLock.java  |  148 ++
 .../java/org/apache/giraph/TestVertexTypes.java    |  211 ++
 .../java/org/apache/giraph/TestZooKeeperExt.java   |  173 ++
 .../giraph/aggregators/TestBooleanAggregators.java |   69 +
 .../giraph/aggregators/TestDoubleAggregators.java  |   89 +
 .../giraph/aggregators/TestFloatAggregators.java   |   88 +
 .../giraph/aggregators/TestIntAggregators.java     |   89 +
 .../giraph/aggregators/TestLongAggregators.java    |   89 +
 .../org/apache/giraph/comm/ConnectionTest.java     |  176 ++
 .../apache/giraph/comm/IncreasingBitSetTest.java   |   85 +
 .../org/apache/giraph/comm/RequestFailureTest.java |  189 ++
 .../java/org/apache/giraph/comm/RequestTest.java   |  271 +++
 .../org/apache/giraph/comm/SaslConnectionTest.java |  105 +
 .../org/apache/giraph/comm/TestMessageStores.java  |  304 +++
 .../examples/ConnectedComponentsVertexTest.java    |  121 +
 .../giraph/examples/MinimumIntCombinerTest.java    |   42 +
 .../examples/RandomWalkWithRestartVertexTest.java  |  131 +
 .../examples/SimpleShortestPathsVertexTest.java    |  164 ++
 .../examples/SimpleTriangleClosingVertexTest.java  |   95 +
 .../examples/TryMultiIpcBindingPortsTest.java      |  125 +
 .../giraph/graph/TestAggregatorsHandling.java      |  197 ++
 .../giraph/graph/TestIntIntNullIntVertex.java      |   78 +
 .../apache/giraph/graph/TestMultiGraphVertex.java  |  129 +
 .../org/apache/giraph/graph/TestMutableVertex.java |  467 ++++
 .../partition/TestGiraphTransferRegulator.java     |   93 +
 .../graph/partition/TestPartitionStores.java       |  211 ++
 .../TestAdjacencyListTextVertexOutputFormat.java   |  141 ++
 .../giraph/io/TestIdWithValueTextOutputFormat.java |   96 +
 ...DoubleDoubleAdjacencyListVertexInputFormat.java |  172 ++
 ...DoubleDoubleAdjacencyListVertexInputFormat.java |  223 ++
 .../java/org/apache/giraph/utils/BspUtilsTest.java |  193 ++
 .../apache/giraph/utils/ComparisonUtilsTest.java   |   75 +
 .../java/org/apache/giraph/utils/MockUtils.java    |  169 ++
 .../src/test/java/zk/TestZooKeeperManager.java     |   51 +
 giraph-formats-contrib/README                      |   16 -
 giraph-formats-contrib/pom.xml                     |  248 --
 .../src/main/assembly/compile.xml                  |   40 -
 .../io/accumulo/AccumuloVertexInputFormat.java     |  179 --
 .../io/accumulo/AccumuloVertexOutputFormat.java    |  175 --
 .../apache/giraph/io/accumulo/package-info.java    |   21 -
 .../giraph/io/hbase/HBaseVertexInputFormat.java    |  193 --
 .../giraph/io/hbase/HBaseVertexOutputFormat.java   |  173 --
 .../org/apache/giraph/io/hbase/package-info.java   |   21 -
 .../giraph/io/hcatalog/GiraphHCatInputFormat.java  |  427 ----
 .../io/hcatalog/HCatalogEdgeInputFormat.java       |  171 --
 .../io/hcatalog/HCatalogVertexInputFormat.java     |  391 ---
 .../io/hcatalog/HCatalogVertexOutputFormat.java    |  215 --
 .../hcatalog/HCatalogVertexValueInputFormat.java   |  171 --
 .../giraph/io/hcatalog/HiveGiraphRunner.java       |  490 ----
 .../org/apache/giraph/io/hcatalog/HiveUtils.java   |   64 -
 .../apache/giraph/io/hcatalog/package-info.java    |   23 -
 .../org/apache/hcatalog/mapreduce/HCatUtils.java   |  189 --
 .../apache/hcatalog/mapreduce/package-info.java    |   21 -
 .../io/accumulo/TestAccumuloVertexFormat.java      |  185 --
 .../edgemarker/AccumuloEdgeInputFormat.java        |   95 -
 .../edgemarker/AccumuloEdgeOutputFormat.java       |   77 -
 .../io/hbase/TestHBaseRootMarkerVertextFormat.java |  190 --
 .../io/hbase/edgemarker/TableEdgeInputFormat.java  |   95 -
 .../io/hbase/edgemarker/TableEdgeOutputFormat.java |   75 -
 .../apache/giraph/io/hcatalog/TestHiveUtils.java   |   36 -
 giraph-formats/README                              |   16 +
 giraph-formats/pom.xml                             |  248 ++
 giraph-formats/src/main/assembly/compile.xml       |   39 +
 .../io/accumulo/AccumuloVertexInputFormat.java     |  179 ++
 .../io/accumulo/AccumuloVertexOutputFormat.java    |  175 ++
 .../apache/giraph/io/accumulo/package-info.java    |   21 +
 .../giraph/io/hbase/HBaseVertexInputFormat.java    |  193 ++
 .../giraph/io/hbase/HBaseVertexOutputFormat.java   |  173 ++
 .../org/apache/giraph/io/hbase/package-info.java   |   21 +
 .../giraph/io/hcatalog/GiraphHCatInputFormat.java  |  427 ++++
 .../io/hcatalog/HCatalogEdgeInputFormat.java       |  171 ++
 .../io/hcatalog/HCatalogVertexInputFormat.java     |  391 +++
 .../io/hcatalog/HCatalogVertexOutputFormat.java    |  215 ++
 .../hcatalog/HCatalogVertexValueInputFormat.java   |  171 ++
 .../giraph/io/hcatalog/HiveGiraphRunner.java       |  490 ++++
 .../org/apache/giraph/io/hcatalog/HiveUtils.java   |   64 +
 .../apache/giraph/io/hcatalog/package-info.java    |   23 +
 .../org/apache/hcatalog/mapreduce/HCatUtils.java   |  189 ++
 .../apache/hcatalog/mapreduce/package-info.java    |   21 +
 .../io/accumulo/TestAccumuloVertexFormat.java      |  185 ++
 .../edgemarker/AccumuloEdgeInputFormat.java        |   95 +
 .../edgemarker/AccumuloEdgeOutputFormat.java       |   77 +
 .../io/hbase/TestHBaseRootMarkerVertextFormat.java |  190 ++
 .../io/hbase/edgemarker/TableEdgeInputFormat.java  |   95 +
 .../io/hbase/edgemarker/TableEdgeOutputFormat.java |   75 +
 .../apache/giraph/io/hcatalog/TestHiveUtils.java   |   36 +
 giraph/pom.xml                                     |  312 ---
 giraph/src/main/assembly/assembly.xml              |  100 -
 giraph/src/main/assembly/compile.xml               |   41 -
 .../java/com/yammer/metrics/core/NoOpCounter.java  |   53 -
 .../yammer/metrics/core/NoOpExecutorService.java   |  132 -
 .../java/com/yammer/metrics/core/NoOpGuage.java    |   34 -
 .../com/yammer/metrics/core/NoOpHistogram.java     |   67 -
 .../java/com/yammer/metrics/core/NoOpMeter.java    |   67 -
 .../java/com/yammer/metrics/core/NoOpTimer.java    |   90 -
 .../java/com/yammer/metrics/core/package-info.java |   21 -
 .../main/java/org/apache/giraph/GiraphRunner.java  |  275 ---
 .../apache/giraph/aggregators/BasicAggregator.java |   58 -
 .../giraph/aggregators/BooleanAndAggregator.java   |   37 -
 .../giraph/aggregators/BooleanOrAggregator.java    |   37 -
 .../aggregators/BooleanOverwriteAggregator.java    |   41 -
 .../giraph/aggregators/DoubleMaxAggregator.java    |   37 -
 .../giraph/aggregators/DoubleMinAggregator.java    |   37 -
 .../aggregators/DoubleOverwriteAggregator.java     |   40 -
 .../aggregators/DoubleProductAggregator.java       |   36 -
 .../giraph/aggregators/DoubleSumAggregator.java    |   34 -
 .../giraph/aggregators/FloatMaxAggregator.java     |   37 -
 .../giraph/aggregators/FloatMinAggregator.java     |   37 -
 .../aggregators/FloatOverwriteAggregator.java      |   39 -
 .../giraph/aggregators/FloatProductAggregator.java |   36 -
 .../giraph/aggregators/FloatSumAggregator.java     |   36 -
 .../giraph/aggregators/IntMaxAggregator.java       |   37 -
 .../giraph/aggregators/IntMinAggregator.java       |   37 -
 .../giraph/aggregators/IntOverwriteAggregator.java |   39 -
 .../giraph/aggregators/IntProductAggregator.java   |   36 -
 .../giraph/aggregators/IntSumAggregator.java       |   36 -
 .../giraph/aggregators/LongMaxAggregator.java      |   37 -
 .../giraph/aggregators/LongMinAggregator.java      |   37 -
 .../aggregators/LongOverwriteAggregator.java       |   39 -
 .../giraph/aggregators/LongProductAggregator.java  |   36 -
 .../giraph/aggregators/LongSumAggregator.java      |   36 -
 .../apache/giraph/aggregators/package-info.java    |   21 -
 .../giraph/benchmark/AggregatorsBenchmark.java     |  289 ---
 .../benchmark/EdgeListVertexPageRankBenchmark.java |   38 -
 .../benchmark/HashMapVertexPageRankBenchmark.java  |   38 -
 .../HashMapVertexShortestPathsBenchmark.java       |   39 -
 .../MultiGraphEdgeListVertexPageRankBenchmark.java |   38 -
 ...GraphRepresentativeVertexPageRankBenchmark.java |   39 -
 .../apache/giraph/benchmark/PageRankBenchmark.java |  231 --
 .../giraph/benchmark/PageRankComputation.java      |   65 -
 .../giraph/benchmark/RandomMessageBenchmark.java   |  409 ----
 .../RepresentativeVertexPageRankBenchmark.java     |   39 -
 .../giraph/benchmark/ShortestPathsBenchmark.java   |  168 --
 .../giraph/benchmark/ShortestPathsComputation.java |   81 -
 .../org/apache/giraph/benchmark/package-info.java  |   21 -
 .../org/apache/giraph/bsp/ApplicationState.java    |   33 -
 .../java/org/apache/giraph/bsp/BspInputFormat.java |   93 -
 .../java/org/apache/giraph/bsp/BspInputSplit.java  |  101 -
 .../org/apache/giraph/bsp/BspOutputFormat.java     |   71 -
 .../org/apache/giraph/bsp/BspRecordReader.java     |   73 -
 .../org/apache/giraph/bsp/BspRecordWriter.java     |   47 -
 .../org/apache/giraph/bsp/CentralizedService.java  |   79 -
 .../giraph/bsp/CentralizedServiceMaster.java       |  135 --
 .../giraph/bsp/CentralizedServiceWorker.java       |  236 --
 .../giraph/bsp/ImmutableOutputCommitter.java       |   63 -
 .../java/org/apache/giraph/bsp/SuperstepState.java |   33 -
 .../java/org/apache/giraph/bsp/package-info.java   |   21 -
 .../java/org/apache/giraph/comm/MasterClient.java  |   63 -
 .../java/org/apache/giraph/comm/MasterServer.java  |   38 -
 .../main/java/org/apache/giraph/comm/MsgList.java  |   56 -
 .../org/apache/giraph/comm/SendMessageCache.java   |  196 --
 .../org/apache/giraph/comm/SendMutationsCache.java |  199 --
 .../org/apache/giraph/comm/SendPartitionCache.java |  135 --
 .../java/org/apache/giraph/comm/ServerData.java    |  177 --
 .../java/org/apache/giraph/comm/WorkerClient.java  |  100 -
 .../giraph/comm/WorkerClientRequestProcessor.java  |  125 -
 .../org/apache/giraph/comm/WorkerClientServer.java |   36 -
 .../java/org/apache/giraph/comm/WorkerServer.java  |   72 -
 .../aggregators/AggregatedValueOutputStream.java   |   45 -
 .../comm/aggregators/AggregatorOutputStream.java   |   49 -
 .../giraph/comm/aggregators/AggregatorUtils.java   |  120 -
 .../comm/aggregators/AllAggregatorServerData.java  |  239 --
 .../giraph/comm/aggregators/CountingCache.java     |   66 -
 .../comm/aggregators/CountingOutputStream.java     |   85 -
 .../aggregators/OwnerAggregatorServerData.java     |  187 --
 .../comm/aggregators/SendAggregatedValueCache.java |   87 -
 .../comm/aggregators/SendAggregatorCache.java      |   91 -
 .../WorkerAggregatorRequestProcessor.java          |   64 -
 .../giraph/comm/aggregators/package-info.java      |   21 -
 .../giraph/comm/messages/BasicMessageStore.java    |   67 -
 .../messages/ByteArrayMessagesPerVertexStore.java  |  292 ---
 .../comm/messages/DiskBackedMessageStore.java      |  407 ----
 .../DiskBackedMessageStoreByPartition.java         |  383 ---
 .../comm/messages/FlushableMessageStore.java       |   40 -
 .../apache/giraph/comm/messages/MessageStore.java  |   53 -
 .../comm/messages/MessageStoreByPartition.java     |   82 -
 .../giraph/comm/messages/MessageStoreFactory.java  |   39 -
 .../comm/messages/OneMessagePerVertexStore.java    |  217 --
 .../comm/messages/SequentialFileMessageStore.java  |  395 ---
 .../giraph/comm/messages/SimpleMessageStore.java   |  245 --
 .../apache/giraph/comm/messages/package-info.java  |   21 -
 .../org/apache/giraph/comm/netty/ByteCounter.java  |  234 --
 .../apache/giraph/comm/netty/ChannelRotater.java   |  125 -
 .../org/apache/giraph/comm/netty/NettyClient.java  |  801 ------
 .../giraph/comm/netty/NettyMasterClient.java       |  119 -
 .../giraph/comm/netty/NettyMasterServer.java       |   61 -
 .../org/apache/giraph/comm/netty/NettyServer.java  |  392 ---
 .../NettyWorkerAggregatorRequestProcessor.java     |  146 --
 .../giraph/comm/netty/NettyWorkerClient.java       |  138 --
 .../netty/NettyWorkerClientRequestProcessor.java   |  405 ----
 .../giraph/comm/netty/NettyWorkerServer.java       |  242 --
 .../apache/giraph/comm/netty/SaslNettyClient.java  |  219 --
 .../apache/giraph/comm/netty/SaslNettyServer.java  |  210 --
 ...dAdaptiveReceiveBufferSizePredictorFactory.java |  133 -
 .../netty/handler/AddressRequestIdGenerator.java   |   53 -
 .../comm/netty/handler/AuthorizeServerHandler.java |   80 -
 .../giraph/comm/netty/handler/ClientRequestId.java |   73 -
 .../netty/handler/MasterRequestServerHandler.java  |   79 -
 .../giraph/comm/netty/handler/RequestDecoder.java  |  103 -
 .../giraph/comm/netty/handler/RequestEncoder.java  |  107 -
 .../giraph/comm/netty/handler/RequestInfo.java     |  113 -
 .../comm/netty/handler/RequestServerHandler.java   |  181 --
 .../comm/netty/handler/ResponseClientHandler.java  |  141 --
 .../giraph/comm/netty/handler/ResponseEncoder.java |  100 -
 .../comm/netty/handler/SaslClientHandler.java      |  168 --
 .../comm/netty/handler/SaslServerHandler.java      |  239 --
 .../netty/handler/WorkerRequestReservedMap.java    |   80 -
 .../netty/handler/WorkerRequestServerHandler.java  |   88 -
 .../giraph/comm/netty/handler/package-info.java    |   21 -
 .../org/apache/giraph/comm/netty/package-info.java |   21 -
 .../java/org/apache/giraph/comm/package-info.java  |   21 -
 .../giraph/comm/requests/ByteArrayRequest.java     |   85 -
 .../apache/giraph/comm/requests/MasterRequest.java |   33 -
 .../apache/giraph/comm/requests/RequestType.java   |   76 -
 .../giraph/comm/requests/SaslCompleteRequest.java  |   47 -
 .../comm/requests/SaslTokenMessageRequest.java     |  111 -
 .../requests/SendAggregatorsToMasterRequest.java   |   61 -
 .../requests/SendAggregatorsToOwnerRequest.java    |   90 -
 .../requests/SendAggregatorsToWorkerRequest.java   |   88 -
 .../SendPartitionCurrentMessagesRequest.java       |   97 -
 .../requests/SendPartitionMutationsRequest.java    |  134 -
 .../giraph/comm/requests/SendVertexRequest.java    |   89 -
 .../requests/SendWorkerAggregatorsRequest.java     |   84 -
 .../comm/requests/SendWorkerMessagesRequest.java   |  131 -
 .../apache/giraph/comm/requests/WorkerRequest.java |   41 -
 .../giraph/comm/requests/WritableRequest.java      |  129 -
 .../apache/giraph/comm/requests/package-info.java  |   21 -
 .../java/org/apache/giraph/conf/GiraphClasses.java |  560 -----
 .../apache/giraph/conf/GiraphConfiguration.java    |  615 -----
 .../org/apache/giraph/conf/GiraphConstants.java    |  569 -----
 .../conf/ImmutableClassesGiraphConfigurable.java   |   49 -
 .../conf/ImmutableClassesGiraphConfiguration.java  |  554 -----
 .../java/org/apache/giraph/conf/package-info.java  |   21 -
 .../giraph/counters/GiraphHadoopCounter.java       |  141 --
 .../org/apache/giraph/counters/GiraphStats.java    |  172 --
 .../org/apache/giraph/counters/GiraphTimers.java   |  158 --
 .../apache/giraph/counters/HadoopCountersBase.java |   62 -
 .../org/apache/giraph/counters/package-info.java   |   21 -
 .../giraph/examples/AggregatorsTestVertex.java     |  134 -
 .../java/org/apache/giraph/examples/Algorithm.java |   41 -
 .../giraph/examples/ConnectedComponentsVertex.java |   96 -
 .../apache/giraph/examples/DoubleSumCombiner.java  |   40 -
 .../giraph/examples/GeneratedVertexReader.java     |   92 -
 .../org/apache/giraph/examples/IdentityVertex.java |   45 -
 .../LongDoubleFloatDoubleTextInputFormat.java      |   92 -
 .../giraph/examples/MinimumDoubleCombiner.java     |   42 -
 .../apache/giraph/examples/MinimumIntCombiner.java |   41 -
 ...lizingLongDoubleFloatDoubleTextInputFormat.java |  125 -
 .../apache/giraph/examples/RandomWalkVertex.java   |  135 --
 .../examples/RandomWalkWithRestartVertex.java      |   84 -
 .../giraph/examples/RandomWalkWorkerContext.java   |  159 --
 .../giraph/examples/SimpleAggregatorWriter.java    |   71 -
 .../giraph/examples/SimpleCheckpointVertex.java    |  286 ---
 .../giraph/examples/SimpleCombinerVertex.java      |   65 -
 .../apache/giraph/examples/SimpleFailVertex.java   |   69 -
 .../giraph/examples/SimpleInDegreeCountVertex.java |   55 -
 ...SimpleLongDoubleDoubleDoubleIdentityVertex.java |   32 -
 .../giraph/examples/SimpleMasterComputeVertex.java |  105 -
 .../apache/giraph/examples/SimpleMsgVertex.java    |   62 -
 .../giraph/examples/SimpleMutateGraphVertex.java   |  198 --
 .../examples/SimpleOutDegreeCountVertex.java       |   43 -
 .../giraph/examples/SimplePageRankVertex.java      |  252 --
 .../giraph/examples/SimpleShortestPathsVertex.java |   83 -
 .../apache/giraph/examples/SimpleSumCombiner.java  |   41 -
 .../giraph/examples/SimpleSuperstepVertex.java     |  154 --
 .../examples/SimpleTextVertexOutputFormat.java     |   55 -
 .../examples/SimpleTriangleClosingVertex.java      |  151 --
 .../examples/SimpleVertexWithWorkerContext.java    |  197 --
 .../org/apache/giraph/examples/VerifyMessage.java  |  220 --
 ...exWithDoubleValueFloatEdgeTextOutputFormat.java |   57 -
 .../org/apache/giraph/examples/package-info.java   |   21 -
 .../graph/AddressesAndPartitionsWritable.java      |  143 --
 .../java/org/apache/giraph/graph/Aggregator.java   |   67 -
 .../org/apache/giraph/graph/AggregatorWrapper.java |  146 --
 .../org/apache/giraph/graph/AggregatorWriter.java  |   73 -
 .../giraph/graph/BasicVertexValueReader.java       |   56 -
 .../java/org/apache/giraph/graph/BspService.java   | 1069 --------
 .../org/apache/giraph/graph/BspServiceMaster.java  | 1871 ---------------
 .../org/apache/giraph/graph/BspServiceWorker.java  | 1392 -----------
 .../java/org/apache/giraph/graph/BspUtils.java     |  523 ----
 .../java/org/apache/giraph/graph/Combiner.java     |   53 -
 .../org/apache/giraph/graph/ComputeCallable.java   |  225 --
 .../apache/giraph/graph/DefaultMasterCompute.java  |   50 -
 .../apache/giraph/graph/DefaultVertexResolver.java |  224 --
 .../apache/giraph/graph/DefaultWorkerContext.java  |   41 -
 .../main/java/org/apache/giraph/graph/Edge.java    |  131 -
 .../org/apache/giraph/graph/EdgeInputFormat.java   |   75 -
 .../giraph/graph/EdgeInputSplitsCallable.java      |  165 --
 .../graph/EdgeInputSplitsCallableFactory.java      |   94 -
 .../org/apache/giraph/graph/EdgeListVertex.java    |   72 -
 .../apache/giraph/graph/EdgeListVertexBase.java    |  108 -
 .../java/org/apache/giraph/graph/EdgeReader.java   |   84 -
 .../org/apache/giraph/graph/EdgeWithSource.java    |   65 -
 .../giraph/graph/FinishedSuperstepStats.java       |   44 -
 .../org/apache/giraph/graph/GiraphInputFormat.java |   42 -
 .../java/org/apache/giraph/graph/GiraphJob.java    |  280 ---
 .../giraph/graph/GiraphTransferRegulator.java      |  199 --
 .../apache/giraph/graph/GiraphTypeValidator.java   |  240 --
 .../java/org/apache/giraph/graph/GlobalStats.java  |  111 -
 .../java/org/apache/giraph/graph/GraphMapper.java  |  772 ------
 .../java/org/apache/giraph/graph/GraphState.java   |  116 -
 .../org/apache/giraph/graph/GraphStateAware.java   |   47 -
 .../org/apache/giraph/graph/HashMapVertex.java     |  160 --
 .../org/apache/giraph/graph/InputSplitEvents.java  |   85 -
 .../giraph/graph/InputSplitPathOrganizer.java      |  195 --
 .../org/apache/giraph/graph/InputSplitPaths.java   |   88 -
 .../apache/giraph/graph/InputSplitsCallable.java   |  389 ---
 .../giraph/graph/InputSplitsCallableFactory.java   |   40 -
 .../apache/giraph/graph/IntIntNullIntVertex.java   |  100 -
 .../apache/giraph/graph/IntNullNullNullVertex.java |   59 -
 .../graph/LongDoubleFloatDoubleEdgeListVertex.java |  181 --
 .../giraph/graph/LongDoubleFloatDoubleVertex.java  |  217 --
 .../giraph/graph/LongDoubleNullDoubleVertex.java   |  137 --
 .../giraph/graph/MasterAggregatorHandler.java      |  344 ---
 .../apache/giraph/graph/MasterAggregatorUsage.java |   71 -
 .../org/apache/giraph/graph/MasterCompute.java     |  175 --
 .../java/org/apache/giraph/graph/MasterInfo.java   |   35 -
 .../java/org/apache/giraph/graph/MasterThread.java |  191 --
 .../giraph/graph/MultiGraphEdgeListVertex.java     |   61 -
 .../graph/MultiGraphRepresentativeVertex.java      |   48 -
 .../org/apache/giraph/graph/MutableVertex.java     |  118 -
 .../apache/giraph/graph/RepresentativeVertex.java  |   68 -
 .../giraph/graph/RepresentativeVertexBase.java     |  285 ---
 .../apache/giraph/graph/SimpleMutableVertex.java   |  130 -
 .../java/org/apache/giraph/graph/SimpleVertex.java |  104 -
 .../java/org/apache/giraph/graph/TaskInfo.java     |  152 --
 .../apache/giraph/graph/TextAggregatorWriter.java  |  126 -
 .../main/java/org/apache/giraph/graph/Vertex.java  |  405 ----
 .../org/apache/giraph/graph/VertexChanges.java     |   68 -
 .../org/apache/giraph/graph/VertexEdgeCount.java   |   88 -
 .../org/apache/giraph/graph/VertexInputFormat.java |   82 -
 .../giraph/graph/VertexInputSplitsCallable.java    |  180 --
 .../graph/VertexInputSplitsCallableFactory.java    |   94 -
 .../org/apache/giraph/graph/VertexMutations.java   |  212 --
 .../apache/giraph/graph/VertexOutputFormat.java    |   81 -
 .../java/org/apache/giraph/graph/VertexReader.java |   87 -
 .../org/apache/giraph/graph/VertexResolver.java    |   62 -
 .../giraph/graph/VertexValueInputFormat.java       |   58 -
 .../org/apache/giraph/graph/VertexValueReader.java |   61 -
 .../java/org/apache/giraph/graph/VertexWriter.java |   67 -
 .../giraph/graph/WorkerAggregatorHandler.java      |  294 ---
 .../apache/giraph/graph/WorkerAggregatorUsage.java |   44 -
 .../org/apache/giraph/graph/WorkerContext.java     |  121 -
 .../java/org/apache/giraph/graph/WorkerInfo.java   |   35 -
 .../giraph/graph/WorkerThreadAggregatorUsage.java  |   31 -
 .../java/org/apache/giraph/graph/package-info.java |   22 -
 .../graph/partition/BasicPartitionOwner.java       |  163 --
 .../giraph/graph/partition/ByteArrayPartition.java |  277 ---
 .../graph/partition/DiskBackedPartitionStore.java  |  364 ---
 .../graph/partition/GraphPartitionerFactory.java   |   52 -
 .../graph/partition/HashMasterPartitioner.java     |  157 --
 .../graph/partition/HashPartitionerFactory.java    |   60 -
 .../partition/HashRangePartitionerFactory.java     |   60 -
 .../partition/HashRangeWorkerPartitioner.java      |   50 -
 .../graph/partition/HashWorkerPartitioner.java     |  119 -
 .../graph/partition/MasterGraphPartitioner.java    |   83 -
 .../apache/giraph/graph/partition/Partition.java   |  122 -
 .../giraph/graph/partition/PartitionBalancer.java  |  288 ---
 .../giraph/graph/partition/PartitionExchange.java  |   77 -
 .../giraph/graph/partition/PartitionOwner.java     |   81 -
 .../giraph/graph/partition/PartitionStats.java     |  178 --
 .../giraph/graph/partition/PartitionStore.java     |  116 -
 .../giraph/graph/partition/PartitionUtils.java     |  151 --
 .../graph/partition/RangeMasterPartitioner.java    |   43 -
 .../graph/partition/RangePartitionOwner.java       |   74 -
 .../graph/partition/RangePartitionStats.java       |   68 -
 .../graph/partition/RangePartitionerFactory.java   |   43 -
 .../giraph/graph/partition/RangeSplitHint.java     |   72 -
 .../graph/partition/RangeWorkerPartitioner.java    |   78 -
 .../giraph/graph/partition/SimplePartition.java    |  188 --
 .../graph/partition/SimplePartitionStore.java      |  105 -
 .../graph/partition/WorkerGraphPartitioner.java    |   94 -
 .../giraph/graph/partition/package-info.java       |   21 -
 .../SuperstepHashPartitionerFactory.java           |  127 -
 .../apache/giraph/integration/package-info.java    |   21 -
 .../io/AdjacencyListTextVertexInputFormat.java     |  181 --
 .../io/AdjacencyListTextVertexOutputFormat.java    |   88 -
 .../giraph/io/GeneratedVertexInputFormat.java      |   56 -
 .../apache/giraph/io/GiraphFileInputFormat.java    |  339 ---
 .../apache/giraph/io/GiraphTextInputFormat.java    |   51 -
 .../giraph/io/IdWithValueTextOutputFormat.java     |   98 -
 .../giraph/io/IntIntNullIntTextInputFormat.java    |   93 -
 .../io/IntIntTextVertexValueInputFormat.java       |   76 -
 .../giraph/io/IntNullNullNullTextInputFormat.java  |   75 -
 .../giraph/io/IntNullTextEdgeInputFormat.java      |   78 -
 .../apache/giraph/io/JsonBase64VertexFormat.java   |   36 -
 .../giraph/io/JsonBase64VertexInputFormat.java     |  151 --
 .../giraph/io/JsonBase64VertexOutputFormat.java    |  109 -
 ...JsonLongDoubleFloatDoubleVertexInputFormat.java |  108 -
 ...sonLongDoubleFloatDoubleVertexOutputFormat.java |   77 -
 ...DoubleDoubleAdjacencyListVertexInputFormat.java |   84 -
 .../giraph/io/PseudoRandomEdgeInputFormat.java     |  197 --
 .../giraph/io/PseudoRandomVertexInputFormat.java   |  198 --
 .../giraph/io/SequenceFileVertexInputFormat.java   |  115 -
 ...DoubleDoubleAdjacencyListVertexInputFormat.java |   78 -
 .../org/apache/giraph/io/TextEdgeInputFormat.java  |  283 ---
 .../apache/giraph/io/TextVertexInputFormat.java    |  432 ----
 .../apache/giraph/io/TextVertexOutputFormat.java   |  165 --
 .../giraph/io/TextVertexValueInputFormat.java      |  260 --
 .../java/org/apache/giraph/io/package-info.java    |   21 -
 .../giraph/master/DefaultMasterObserver.java       |   55 -
 .../org/apache/giraph/master/MasterObserver.java   |   46 -
 .../org/apache/giraph/master/package-info.java     |   21 -
 .../apache/giraph/metrics/AggregatedMetric.java    |  112 -
 .../apache/giraph/metrics/AggregatedMetrics.java   |  170 --
 .../org/apache/giraph/metrics/GiraphMetrics.java   |  141 --
 .../giraph/metrics/GiraphMetricsRegistry.java      |  253 --
 .../org/apache/giraph/metrics/GiraphTimer.java     |  106 -
 .../apache/giraph/metrics/GiraphTimerContext.java  |   56 -
 .../org/apache/giraph/metrics/LongAndTimeUnit.java |   88 -
 .../giraph/metrics/MetricsRegistryDebugger.java    |   57 -
 .../apache/giraph/metrics/NoOpMetricsRegistry.java |  198 --
 .../metrics/ResetSuperstepMetricsObserver.java     |   32 -
 .../giraph/metrics/SuperstepMetricsRegistry.java   |   76 -
 .../java/org/apache/giraph/metrics/ValueGauge.java |   75 -
 .../apache/giraph/metrics/ValueWithHostname.java   |   72 -
 .../giraph/metrics/WorkerSuperstepMetrics.java     |  181 --
 .../org/apache/giraph/metrics/package-info.java    |   21 -
 .../main/java/org/apache/giraph/package-info.java  |   21 -
 .../org/apache/giraph/utils/AnnotationUtils.java   |  254 --
 .../org/apache/giraph/utils/ArrayListWritable.java |  125 -
 .../org/apache/giraph/utils/ByteArrayIterable.java |   90 -
 .../org/apache/giraph/utils/ByteArrayIterator.java |   79 -
 .../giraph/utils/ByteArrayVertexIdMessages.java    |  337 ---
 .../org/apache/giraph/utils/CollectionUtils.java   |  118 -
 .../org/apache/giraph/utils/ComparisonUtils.java   |   62 -
 .../utils/DynamicChannelBufferInputStream.java     |  231 --
 .../utils/DynamicChannelBufferOutputStream.java    |  187 --
 .../org/apache/giraph/utils/EdgeIterables.java     |   73 -
 .../org/apache/giraph/utils/EmptyIterable.java     |   64 -
 .../org/apache/giraph/utils/ExpectedBarrier.java   |  125 -
 .../giraph/utils/ExtendedByteArrayDataInput.java   |  133 -
 .../giraph/utils/ExtendedByteArrayDataOutput.java  |  173 --
 .../org/apache/giraph/utils/ExtendedDataInput.java |   39 -
 .../apache/giraph/utils/ExtendedDataOutput.java    |   67 -
 .../java/org/apache/giraph/utils/FakeTime.java     |   61 -
 .../java/org/apache/giraph/utils/FileUtils.java    |  180 --
 .../org/apache/giraph/utils/IncreasingBitSet.java  |  122 -
 .../main/java/org/apache/giraph/utils/IntPair.java |   75 -
 .../apache/giraph/utils/InternalVertexRunner.java  |  245 --
 .../java/org/apache/giraph/utils/LoggerUtils.java  |   74 -
 .../java/org/apache/giraph/utils/MathUtils.java    |   57 -
 .../java/org/apache/giraph/utils/MemoryUtils.java  |   94 -
 .../java/org/apache/giraph/utils/PairList.java     |  153 --
 .../org/apache/giraph/utils/PairListWritable.java  |   76 -
 .../org/apache/giraph/utils/ProgressableUtils.java |  339 ---
 .../org/apache/giraph/utils/ReflectionUtils.java   |  193 --
 .../utils/RepresentativeByteArrayIterable.java     |   74 -
 .../utils/RepresentativeByteArrayIterator.java     |   58 -
 .../java/org/apache/giraph/utils/SystemTime.java   |   71 -
 .../main/java/org/apache/giraph/utils/Time.java    |  101 -
 .../java/org/apache/giraph/utils/TimedLogger.java  |   69 -
 .../main/java/org/apache/giraph/utils/Times.java   |  137 --
 .../utils/UnmodifiableDoubleArrayIterator.java     |   53 -
 .../giraph/utils/UnmodifiableIntArrayIterator.java |   53 -
 .../utils/UnmodifiableLongArrayIterator.java       |   53 -
 .../UnmodifiableLongFloatEdgeArrayIterable.java    |   72 -
 .../UnmodifiableLongNullEdgeArrayIterable.java     |   67 -
 .../giraph/utils/UnsafeByteArrayInputStream.java   |  354 ---
 .../giraph/utils/UnsafeByteArrayOutputStream.java  |  321 ---
 .../org/apache/giraph/utils/WritableUtils.java     |  326 ---
 .../java/org/apache/giraph/utils/package-info.java |   21 -
 .../main/java/org/apache/giraph/zk/BspEvent.java   |   49 -
 .../java/org/apache/giraph/zk/PredicateLock.java   |  142 --
 .../java/org/apache/giraph/zk/ZooKeeperExt.java    |  559 -----
 .../org/apache/giraph/zk/ZooKeeperManager.java     |  914 -------
 .../java/org/apache/giraph/zk/package-info.java    |   21 -
 giraph/src/site/resources/css/site.css             |   29 -
 giraph/src/site/resources/images/ApacheGiraph.svg  |  484 ----
 giraph/src/site/site.xml                           |   69 -
 giraph/src/site/xdoc/index.xml                     |  108 -
 .../src/test/java/org/apache/giraph/BspCase.java   |  368 ---
 .../java/org/apache/giraph/TestAutoCheckpoint.java |   88 -
 .../test/java/org/apache/giraph/TestBspBasic.java  |  530 ----
 .../test/java/org/apache/giraph/TestEdgeInput.java |  165 --
 .../org/apache/giraph/TestGiraphConfiguration.java |   72 -
 .../org/apache/giraph/TestGraphPartitioner.java    |  162 --
 .../org/apache/giraph/TestJsonBase64Format.java    |  104 -
 .../org/apache/giraph/TestManualCheckpoint.java    |  115 -
 .../java/org/apache/giraph/TestMasterObserver.java |  103 -
 .../java/org/apache/giraph/TestMutateGraph.java    |   64 -
 .../org/apache/giraph/TestNotEnoughMapTasks.java   |   75 -
 .../test/java/org/apache/giraph/TestPageRank.java  |  104 -
 .../java/org/apache/giraph/TestPredicateLock.java  |  148 --
 .../java/org/apache/giraph/TestVertexTypes.java    |  211 --
 .../java/org/apache/giraph/TestZooKeeperExt.java   |  173 --
 .../giraph/aggregators/TestBooleanAggregators.java |   69 -
 .../giraph/aggregators/TestDoubleAggregators.java  |   89 -
 .../giraph/aggregators/TestFloatAggregators.java   |   88 -
 .../giraph/aggregators/TestIntAggregators.java     |   89 -
 .../giraph/aggregators/TestLongAggregators.java    |   89 -
 .../org/apache/giraph/comm/ConnectionTest.java     |  176 --
 .../apache/giraph/comm/IncreasingBitSetTest.java   |   85 -
 .../org/apache/giraph/comm/RequestFailureTest.java |  189 --
 .../java/org/apache/giraph/comm/RequestTest.java   |  271 ---
 .../org/apache/giraph/comm/SaslConnectionTest.java |  105 -
 .../org/apache/giraph/comm/TestMessageStores.java  |  304 ---
 .../examples/ConnectedComponentsVertexTest.java    |  121 -
 .../giraph/examples/MinimumIntCombinerTest.java    |   42 -
 .../examples/RandomWalkWithRestartVertexTest.java  |  131 -
 .../examples/SimpleShortestPathsVertexTest.java    |  164 --
 .../examples/SimpleTriangleClosingVertexTest.java  |   95 -
 .../examples/TryMultiIpcBindingPortsTest.java      |  125 -
 .../giraph/graph/TestAggregatorsHandling.java      |  197 --
 .../giraph/graph/TestIntIntNullIntVertex.java      |   78 -
 .../apache/giraph/graph/TestMultiGraphVertex.java  |  129 -
 .../org/apache/giraph/graph/TestMutableVertex.java |  467 ----
 .../partition/TestGiraphTransferRegulator.java     |   93 -
 .../graph/partition/TestPartitionStores.java       |  211 --
 .../TestAdjacencyListTextVertexOutputFormat.java   |  141 --
 .../giraph/io/TestIdWithValueTextOutputFormat.java |   96 -
 ...DoubleDoubleAdjacencyListVertexInputFormat.java |  172 --
 ...DoubleDoubleAdjacencyListVertexInputFormat.java |  223 --
 .../java/org/apache/giraph/utils/BspUtilsTest.java |  193 --
 .../apache/giraph/utils/ComparisonUtilsTest.java   |   75 -
 .../java/org/apache/giraph/utils/MockUtils.java    |  169 --
 giraph/src/test/java/zk/TestZooKeeperManager.java  |   51 -
 pom.xml                                            |    8 +-
 917 files changed, 63390 insertions(+), 63391 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/giraph/blob/45851391/CHANGELOG
----------------------------------------------------------------------
diff --git a/CHANGELOG b/CHANGELOG
index def8c7b..6e6e777 100644
--- a/CHANGELOG
+++ b/CHANGELOG
@@ -1,6 +1,8 @@
 Giraph Change Log
 
 Release 0.2.0 - unreleased
+  GIRAPH-457: update module names (nitay)
+
   GIRAPH-455: Add meta information to built jars (nitay)
 
   GIRAPH-456: Log where master is on every host (nitay)

http://git-wip-us.apache.org/repos/asf/giraph/blob/45851391/README
----------------------------------------------------------------------
diff --git a/README b/README
index a67cd92..c2a32ed 100644
--- a/README
+++ b/README
@@ -113,14 +113,14 @@ Specifically you would do something like:
   giraph-root/giraph/ $ mvn clean verify      # build from fresh state
   giraph-root/giraph/ $ mvn install           # install jar to local repository
 
-The giraph-formats-contrib/ module contains hooks to read/write from various
+The giraph-formats/ module contains hooks to read/write from various
 formats (e.g. Accumulo, HBase, Hive). It depends on the giraph module. This
 means if you make local changes to the giraph codebase you will first need to
-install the giraph/ jar locally so that giraph-formats-contrib/ will pick it up.
+install the giraph/ jar locally so that giraph-formats/ will pick it up.
 In other words something like this:
 
   giraph-root/giraph/ $ mvn install
-  giraph-root/giraph-formats-contrib $ mvn verify
+  giraph-root/giraph-formats $ mvn verify
 
 To build everything at once you can issue the maven commands at the top level.
 Note that we use the "install" target so that if you have any local changes to

http://git-wip-us.apache.org/repos/asf/giraph/blob/45851391/giraph-core/pom.xml
----------------------------------------------------------------------
diff --git a/giraph-core/pom.xml b/giraph-core/pom.xml
new file mode 100644
index 0000000..4fcd09a
--- /dev/null
+++ b/giraph-core/pom.xml
@@ -0,0 +1,312 @@
+<!--
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements.  See the NOTICE file
+distributed with this work for additional information
+regarding copyright ownership.  The ASF licenses this file
+to you under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance
+with the License.  You may obtain a copy of the License at
+
+http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing,
+software distributed under the License is distributed on an
+"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+KIND, either express or implied.  See the License for the
+specific language governing permissions and limitations
+under the License.
+-->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <parent>
+    <groupId>org.apache.giraph</groupId>
+    <artifactId>giraph-parent</artifactId>
+    <version>0.2-SNAPSHOT</version>
+  </parent>
+  <artifactId>giraph-core</artifactId>
+  <packaging>jar</packaging>
+
+  <name>Apache Giraph</name>
+
+  <properties>
+    <export-target.dir>export/target</export-target.dir>
+    <top.dir>${project.basedir}/..</top.dir>
+  </properties>
+
+  <build>
+    <finalName>giraph-${project.version}-${forHadoop}</finalName>
+    <plugins>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-assembly-plugin</artifactId>
+      </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-checkstyle-plugin</artifactId>
+        <version>2.9</version>
+        <configuration>
+          <configLocation>checkstyle.xml</configLocation>
+          <enableRulesSummary>false</enableRulesSummary>
+          <headerLocation>license-header.txt</headerLocation>
+          <failOnError>true</failOnError>
+          <includeTestSourceDirectory>false</includeTestSourceDirectory>
+        </configuration>
+        <executions>
+          <execution>
+            <phase>verify</phase>
+            <goals>
+              <goal>check</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-compiler-plugin</artifactId>
+      </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-enforcer-plugin</artifactId>
+      </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-jar-plugin</artifactId>
+      </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-javadoc-plugin</artifactId>
+      </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-site-plugin</artifactId>
+      </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-source-plugin</artifactId>
+      </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-surefire-plugin</artifactId>
+        <version>2.6</version>
+        <configuration>
+          <systemProperties>
+            <property>
+              <name>prop.jarLocation</name>
+              <value>${project.basedir}/target/giraph-${project.version}-${forHadoop}-jar-with-dependencies.jar</value>
+            </property>
+          </systemProperties>
+        </configuration>
+      </plugin>
+      <plugin>
+        <groupId>org.apache.rat</groupId>
+        <artifactId>apache-rat-plugin</artifactId>
+      </plugin>
+      <plugin>
+        <groupId>org.codehaus.mojo</groupId>
+        <artifactId>findbugs-maven-plugin</artifactId>
+        <version>2.5.1</version>
+        <configuration>
+          <xmlOutput>true</xmlOutput>
+          <findbugsXmlOutput>false</findbugsXmlOutput>
+          <excludeFilterFile>${top.dir}/findbugs-exclude.xml</excludeFilterFile>
+        </configuration>
+        <executions>
+          <execution>
+            <phase>verify</phase>
+            <goals>
+              <goal>check</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
+    </plugins>
+  </build>
+
+  <profiles>
+    <profile>
+      <id>hadoop_0.20.203</id>
+      <activation>
+        <activeByDefault>true</activeByDefault>
+      </activation>
+      <build>
+        <plugins>
+          <plugin>
+            <groupId>org.sonatype.plugins</groupId>
+            <artifactId>munge-maven-plugin</artifactId>
+          </plugin>
+        </plugins>
+      </build>
+    </profile>
+
+    <profile>
+      <id>hadoop_1.0</id>
+      <build>
+        <plugins>
+          <plugin>
+            <groupId>org.sonatype.plugins</groupId>
+            <artifactId>munge-maven-plugin</artifactId>
+          </plugin>
+        </plugins>
+      </build>
+    </profile>
+
+    <profile>
+      <id>hadoop_non_secure</id>
+      <build>
+        <plugins>
+          <plugin>
+            <groupId>org.sonatype.plugins</groupId>
+            <artifactId>munge-maven-plugin</artifactId>
+            <configuration>
+              <excludes>
+                **/comm/netty/SaslNettyClient.java,
+                **/comm/netty/SaslNettyServer.java,
+                **/comm/netty/handler/AuthorizeServerHandler.java,
+                **/comm/netty/handler/SaslClientHandler.java,
+                **/comm/netty/handler/SaslServerHandler.java,
+                **/comm/requests/SaslCompleteRequest.java,
+                **/comm/requests/SaslTokenMessageRequest.java,
+                **/comm/SaslConnectionTest.java
+              </excludes> 
+            </configuration>
+          </plugin>
+        </plugins>
+      </build>
+    </profile>
+
+    <profile>
+      <id>hadoop_facebook</id>
+      <build>
+        <plugins>
+          <plugin>
+            <groupId>org.sonatype.plugins</groupId>
+            <artifactId>munge-maven-plugin</artifactId>
+            <configuration>
+              <excludes>
+                **/comm/netty/SaslNettyClient.java,
+                **/comm/netty/SaslNettyServer.java,
+                **/comm/netty/handler/AuthorizeServerHandler.java,
+                **/comm/netty/handler/SaslClientHandler.java,
+                **/comm/netty/handler/SaslServerHandler.java,
+                **/comm/requests/SaslCompleteRequest.java,
+                **/comm/requests/SaslTokenMessageRequest.java,
+                **/comm/SaslConnectionTest.java
+              </excludes>
+            </configuration>
+          </plugin>
+          <plugin>
+            <groupId>org.apache.maven.plugins</groupId>
+            <artifactId>maven-surefire-plugin</artifactId>
+          </plugin>
+        </plugins>
+      </build>
+    </profile>
+
+    <profile>
+      <id>hadoop_0.23</id>
+      <build>
+        <plugins>
+          <plugin>
+            <groupId>org.sonatype.plugins</groupId>
+            <artifactId>munge-maven-plugin</artifactId>
+          </plugin>
+          <plugin>
+            <groupId>org.apache.maven.plugins</groupId>
+            <artifactId>maven-surefire-plugin</artifactId>
+          </plugin>
+        </plugins>
+      </build>
+    </profile>
+
+    <profile>
+      <id>hadoop_2.0.0</id>
+    </profile>
+
+    <profile>
+      <id>hadoop_2.0.1</id>
+    </profile>
+
+    <profile>
+      <id>hadoop_2.0.2</id>
+    </profile>
+
+    <profile>
+      <id>hadoop_trunk</id>
+    </profile>
+  </profiles>
+
+  <dependencies>
+    <!-- compile dependencies. sorted lexicographically. -->
+    <dependency>
+      <groupId>com.google.guava</groupId>
+      <artifactId>guava</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>com.yammer.metrics</groupId>
+      <artifactId>metrics-core</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>commons-cli</groupId>
+      <artifactId>commons-cli</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>commons-collections</groupId>
+      <artifactId>commons-collections</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>commons-io</groupId>
+      <artifactId>commons-io</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>io.netty</groupId>
+      <artifactId>netty</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>net.iharder</groupId>
+      <artifactId>base64</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.mahout</groupId>
+      <artifactId>mahout-collections</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.zookeeper</groupId>
+      <artifactId>zookeeper</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.codehaus.jackson</groupId>
+      <artifactId>jackson-core-asl</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.codehaus.jackson</groupId>
+      <artifactId>jackson-mapper-asl</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.json</groupId>
+      <artifactId>json</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.slf4j</groupId>
+      <artifactId>slf4j-api</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.slf4j</groupId>
+      <artifactId>slf4j-log4j12</artifactId>
+    </dependency>
+
+    <!-- test dependencies. sorted lexicographically. -->
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.mockito</groupId>
+      <artifactId>mockito-all</artifactId>
+      <scope>test</scope>
+    </dependency>
+ </dependencies>
+</project>

http://git-wip-us.apache.org/repos/asf/giraph/blob/45851391/giraph-core/src/main/assembly/assembly.xml
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/assembly/assembly.xml b/giraph-core/src/main/assembly/assembly.xml
new file mode 100644
index 0000000..3637c88
--- /dev/null
+++ b/giraph-core/src/main/assembly/assembly.xml
@@ -0,0 +1,100 @@
+<!--
+   Licensed to the Apache Software Foundation (ASF) under one or more
+   contributor license agreements.  See the NOTICE file distributed with
+   this work for additional information regarding copyright ownership.
+   The ASF licenses this file to You under the Apache License, Version 2.0
+   (the "License"); you may not use this file except in compliance with
+   the License.  You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.
+-->
+<assembly xmlns="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.0"
+  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.0 http://maven.apache.org/xsd/assembly-1.1.0.xsd">
+  <id>bin</id>
+  <formats>
+    <format>tar.gz</format>
+  </formats>
+  <moduleSets>
+    <moduleSet>
+      <binaries>
+        <includeDependencies>true</includeDependencies>
+        <outputDirectory>lib</outputDirectory>
+        <unpack>false</unpack>
+        <dependencySets>
+          <dependencySet/>
+        </dependencySets>
+      </binaries>
+    </moduleSet>
+  </moduleSets>
+  <fileSets>
+    <fileSet>
+      <directory>${project.build.directory}</directory>
+      <outputDirectory>/lib</outputDirectory>
+      <includes>
+        <include>*.jar</include>
+      </includes>
+      <excludes>
+        <exclude>giraph*.jar</exclude>
+      </excludes>
+    </fileSet>
+
+    <fileSet>
+      <directory>${project.build.directory}</directory>
+      <outputDirectory>.</outputDirectory>
+      <includes>
+        <include>giraph*.jar</include>
+      </includes>
+      <excludes>
+        <exclude>giraph*jar-with-dependencies.jar</exclude>
+      </excludes>
+    </fileSet>
+
+    <fileSet>
+      <includes>
+        <include>${basedir}/CHANGELOG</include>
+        <include>${basedir}/LICENSE.txt</include>
+        <include>${basedir}/NOTICE</include>
+        <include>${basedir}/README</include>
+        <include>${basedir}/CODE_CONVENTIONS</include>
+      </includes>
+    </fileSet>
+    <fileSet>
+      <includes>
+        <include>pom.xml</include>
+      </includes>
+    </fileSet>
+
+    <fileSet>
+      <directory>src</directory>
+    </fileSet>
+
+    <fileSet>
+      <directory>bin</directory>
+      <outputDirectory>bin</outputDirectory>
+      <fileMode>755</fileMode>
+    </fileSet>
+    <fileSet>
+      <directory>target/site</directory>
+      <outputDirectory>docs</outputDirectory>
+    </fileSet>
+
+    <fileSet>
+      <directory>conf</directory>
+    </fileSet>
+  </fileSets>
+  <dependencySets>
+    <dependencySet>
+      <useProjectArtifact>false</useProjectArtifact>
+      <outputDirectory>/lib</outputDirectory>
+      <unpack>false</unpack>
+      <scope>runtime</scope>
+    </dependencySet>
+  </dependencySets>
+</assembly>

http://git-wip-us.apache.org/repos/asf/giraph/blob/45851391/giraph-core/src/main/assembly/compile.xml
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/assembly/compile.xml b/giraph-core/src/main/assembly/compile.xml
new file mode 100644
index 0000000..b2e620f
--- /dev/null
+++ b/giraph-core/src/main/assembly/compile.xml
@@ -0,0 +1,39 @@
+<!--
+   Licensed to the Apache Software Foundation (ASF) under one or more
+   contributor license agreements.  See the NOTICE file distributed with
+   this work for additional information regarding copyright ownership.
+   The ASF licenses this file to You under the Apache License, Version 2.0
+   (the "License"); you may not use this file except in compliance with
+   the License.  You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.
+-->
+<assembly xmlns="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.0"
+  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.0 http://maven.apache.org/xsd/assembly-1.1.0.xsd">
+  <id>jar-with-dependencies</id>
+   <formats>
+    <format>jar</format>
+  </formats>
+  <includeBaseDirectory>false</includeBaseDirectory>
+
+  <dependencySets>
+    <dependencySet>
+      <useProjectArtifact>true</useProjectArtifact>
+      <outputDirectory>/</outputDirectory>
+      <unpackOptions>
+        <excludes>
+          <exclude>META-INF/LICENSE</exclude>
+        </excludes>
+      </unpackOptions>
+      <unpack>true</unpack>
+      <scope>runtime</scope>
+    </dependencySet>
+  </dependencySets>
+</assembly>

http://git-wip-us.apache.org/repos/asf/giraph/blob/45851391/giraph-core/src/main/java/com/yammer/metrics/core/NoOpCounter.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/com/yammer/metrics/core/NoOpCounter.java b/giraph-core/src/main/java/com/yammer/metrics/core/NoOpCounter.java
new file mode 100644
index 0000000..53dca57
--- /dev/null
+++ b/giraph-core/src/main/java/com/yammer/metrics/core/NoOpCounter.java
@@ -0,0 +1,53 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.yammer.metrics.core;
+
+/**
+ * A Metrics Counter implementation that does nothing
+ */
+public class NoOpCounter extends Counter {
+  /** singleton instance for everyone to use */
+  public static final NoOpCounter INSTANCE = new NoOpCounter();
+
+  /** do not instantiate */
+  private NoOpCounter() { }
+
+  @Override
+  public void inc() { }
+
+  @Override
+  public void inc(long n) { }
+
+  @Override
+  public void dec() { }
+
+  @Override
+  public void dec(long n) { }
+
+  @Override
+  public long count() { return 0; }
+
+  @Override
+  public void clear() { }
+
+  @Override
+  public <T> void processWith(MetricProcessor<T> processor, MetricName name,
+                              T context)
+    throws Exception { }
+}

http://git-wip-us.apache.org/repos/asf/giraph/blob/45851391/giraph-core/src/main/java/com/yammer/metrics/core/NoOpExecutorService.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/com/yammer/metrics/core/NoOpExecutorService.java b/giraph-core/src/main/java/com/yammer/metrics/core/NoOpExecutorService.java
new file mode 100644
index 0000000..151cde2
--- /dev/null
+++ b/giraph-core/src/main/java/com/yammer/metrics/core/NoOpExecutorService.java
@@ -0,0 +1,132 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.yammer.metrics.core;
+
+import java.util.Collection;
+import java.util.List;
+import java.util.concurrent.Callable;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Future;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.ScheduledFuture;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+
+/**
+ * An executor service that does nothing. Used with empty metrics so that no
+ * threads are created wasting time / space.
+ */
+public class NoOpExecutorService implements ScheduledExecutorService {
+  @Override
+  public ScheduledFuture<?> schedule(Runnable runnable, long l,
+                                     TimeUnit timeUnit) {
+    return null;
+  }
+
+  @Override
+  public <V> ScheduledFuture<V> schedule(Callable<V> vCallable, long l,
+                                         TimeUnit timeUnit) {
+    return null;
+  }
+
+  @Override
+  public ScheduledFuture<?> scheduleAtFixedRate(
+    Runnable runnable, long l, long l1, TimeUnit timeUnit
+  ) {
+    return null;
+  }
+
+  @Override
+  public ScheduledFuture<?> scheduleWithFixedDelay(
+    Runnable runnable, long l, long l1, TimeUnit timeUnit
+  ) {
+    return null;
+  }
+
+  @Override
+  public void shutdown() {
+  }
+
+  @Override
+  public List<Runnable> shutdownNow() {
+    return null;
+  }
+
+  @Override
+  public boolean isShutdown() {
+    return false;
+  }
+
+  @Override
+  public boolean isTerminated() {
+    return false;
+  }
+
+  @Override
+  public boolean awaitTermination(long l, TimeUnit timeUnit)
+    throws InterruptedException {
+    return false;
+  }
+
+  @Override
+  public <T> Future<T> submit(Callable<T> tCallable) {
+    return null;
+  }
+
+  @Override
+  public <T> Future<T> submit(Runnable runnable, T t) {
+    return null;
+  }
+
+  @Override
+  public Future<?> submit(Runnable runnable) {
+    return null;
+  }
+
+  @Override
+  public <T> List<Future<T>> invokeAll(
+    Collection<? extends Callable<T>> callables)
+    throws InterruptedException {
+    return null;
+  }
+
+  @Override
+  public <T> List<Future<T>> invokeAll(
+    Collection<? extends Callable<T>> callables, long l, TimeUnit timeUnit
+  ) throws InterruptedException {
+    return null;
+  }
+
+  @Override
+  public <T> T invokeAny(Collection<? extends Callable<T>> callables)
+    throws InterruptedException, ExecutionException {
+    return null;
+  }
+
+  @Override
+  public <T> T invokeAny(Collection<? extends Callable<T>> callables, long l,
+                         TimeUnit timeUnit)
+    throws InterruptedException, ExecutionException, TimeoutException {
+    return null;
+  }
+
+  @Override
+  public void execute(Runnable runnable) {
+  }
+}

http://git-wip-us.apache.org/repos/asf/giraph/blob/45851391/giraph-core/src/main/java/com/yammer/metrics/core/NoOpGuage.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/com/yammer/metrics/core/NoOpGuage.java b/giraph-core/src/main/java/com/yammer/metrics/core/NoOpGuage.java
new file mode 100644
index 0000000..b94a5ef
--- /dev/null
+++ b/giraph-core/src/main/java/com/yammer/metrics/core/NoOpGuage.java
@@ -0,0 +1,34 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.yammer.metrics.core;
+
+/**
+ * A Metrics Gauge implementation that always returns null.
+ * @param <T> Type of value returned by this Gauge.
+ */
+public class NoOpGuage<T> extends Gauge<T> {
+  /** singleton instance for everyone to use */
+  public static final NoOpGuage INSTANCE = new NoOpGuage();
+
+  /** do not instantiate */
+  public NoOpGuage() { }
+
+  @Override
+  public T value() { return null; }
+}

http://git-wip-us.apache.org/repos/asf/giraph/blob/45851391/giraph-core/src/main/java/com/yammer/metrics/core/NoOpHistogram.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/com/yammer/metrics/core/NoOpHistogram.java b/giraph-core/src/main/java/com/yammer/metrics/core/NoOpHistogram.java
new file mode 100644
index 0000000..8683e4a
--- /dev/null
+++ b/giraph-core/src/main/java/com/yammer/metrics/core/NoOpHistogram.java
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.yammer.metrics.core;
+
+import com.yammer.metrics.stats.Snapshot;
+
+/**
+ * An empty Metrics' Histogram that does nothing.
+ */
+public class NoOpHistogram extends Histogram {
+  /** singleton instance for everyone to use */
+  public static final NoOpHistogram INSTANCE = new NoOpHistogram();
+
+  /** do not instantiate */
+  private NoOpHistogram() { super(SampleType.UNIFORM); }
+
+  @Override
+  public void clear() { }
+
+  @Override
+  public void update(int value) { }
+
+  @Override
+  public void update(long value) { }
+
+  @Override
+  public long count() { return 0; }
+
+  @Override
+  public double max() { return 0.0; }
+
+  @Override
+  public double min() { return 0.0; }
+
+  @Override
+  public double mean() { return 0.0; }
+
+  @Override
+  public double stdDev() { return 0.0; }
+
+  @Override
+  public double sum() { return 0.0; }
+
+  @Override
+  public Snapshot getSnapshot() { return new Snapshot(new double[0]); }
+
+  @Override
+  public <T> void processWith(MetricProcessor<T> processor, MetricName name,
+                              T context)
+    throws Exception { }
+}

http://git-wip-us.apache.org/repos/asf/giraph/blob/45851391/giraph-core/src/main/java/com/yammer/metrics/core/NoOpMeter.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/com/yammer/metrics/core/NoOpMeter.java b/giraph-core/src/main/java/com/yammer/metrics/core/NoOpMeter.java
new file mode 100644
index 0000000..11a4c24
--- /dev/null
+++ b/giraph-core/src/main/java/com/yammer/metrics/core/NoOpMeter.java
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.yammer.metrics.core;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * An empty Metrics' Meter implementation that does nothing.
+ */
+public class NoOpMeter extends Meter {
+  /** singleton instance for everyone to use */
+  public static final NoOpMeter INSTANCE = new NoOpMeter();
+
+  /** do not instantiate */
+  private NoOpMeter() {
+    super(new NoOpExecutorService(), "", TimeUnit.SECONDS,
+          Clock.defaultClock());
+  }
+
+  @Override
+  void tick() { }
+
+  @Override
+  public void mark() { }
+
+  @Override
+  public void mark(long n) { }
+
+  @Override
+  public long count() { return 0; }
+
+  @Override
+  public double fifteenMinuteRate() { return 0.0; }
+
+  @Override
+  public double fiveMinuteRate() { return 0.0; }
+
+  @Override
+  public double meanRate() { return 0.0; }
+
+  @Override
+  public double oneMinuteRate() { return 0.0; }
+
+  @Override
+  public void stop() { }
+
+  @Override
+  public <T> void processWith(MetricProcessor<T> processor, MetricName name,
+                              T context)
+    throws Exception { }
+}


Mime
View raw message