giraph-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Nitay Joffe" <ni...@apache.org>
Subject Re: Review Request 13306: Improve Writable API
Date Wed, 21 Aug 2013 01:41:15 GMT


> On Aug. 20, 2013, 6:17 p.m., Avery Ching wrote:
> > giraph-core/src/main/java/org/apache/giraph/combiner/MinimumDoubleCombiner.java,
line 28
> > <https://reviews.apache.org/r/13306/diff/2/?file=341782#file341782line28>
> >
> >     Can't this also stay extending Combiner with Writables?  Internally, the infrastructure
can use RawCombiner...

Yes I'll fix this and others as I find them.


> On Aug. 20, 2013, 6:17 p.m., Avery Ching wrote:
> > giraph-core/src/main/java/org/apache/giraph/comm/messages/primitives/LongByteArrayMessageStore.java,
line 80
> > <https://reviews.apache.org/r/13306/diff/2/?file=341808#file341808line80>
> >
> >     Why does SerDe need to be passed everywhere as a parameter?  Isn't there a global
cache for them?  It makes the constructors all messy...

This is because message stores are used for both incoming and outgoing messages, which may
have different types. The existing code has always passed through some information to detect
which messages class we're using, for example the class itself, the message value factory,
etc. So, in line with that, we need to know which message serde to use so we pass it here.


> On Aug. 20, 2013, 6:17 p.m., Avery Ching wrote:
> > giraph-core/src/main/java/org/apache/giraph/serde/SerDeCache.java, lines 30-34
> > <https://reviews.apache.org/r/13306/diff/2/?file=341993#file341993line30>
> >
> >     Is there an example why the serdes wouldn't be thread safe?  Just curious.

I don't have one, I just allow them to be.


- Nitay


-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/13306/#review25352
-----------------------------------------------------------


On Aug. 16, 2013, 1:55 p.m., Nitay Joffe wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/13306/
> -----------------------------------------------------------
> 
> (Updated Aug. 16, 2013, 1:55 p.m.)
> 
> 
> Review request for giraph.
> 
> 
> Bugs: GIRAPH-684
>     https://issues.apache.org/jira/browse/GIRAPH-684
> 
> 
> Repository: giraph-git
> 
> 
> Description
> -------
> 
> GIRAPH-684: Improve Writable API
> 
> This diff removes Writable/WritableComparable from the generic types, allowing the serializer/comparator
used to be specified separately.
> If the types given implement Writable or Comparable then a default implementation will
be used that applies the type's own logic.
> 
> 
> Diffs
> -----
> 
>   findbugs-exclude.xml 21aa4efd32a2e66b97510eb90c846d36731bdf60 
>   giraph-accumulo/src/main/java/org/apache/giraph/io/accumulo/AccumuloVertexInputFormat.java
c286ed4450362a6b44d8025f92518e9a83fda263 
>   giraph-accumulo/src/main/java/org/apache/giraph/io/accumulo/AccumuloVertexOutputFormat.java
1927ed7bf84bd8d783eca98769a7310f87d7ce67 
>   giraph-accumulo/src/test/java/org/apache/giraph/io/accumulo/edgemarker/AccumuloEdgeInputFormat.java
ff79d7a7f3f7c3c34e59db9f2169591b11276287 
>   giraph-accumulo/src/test/java/org/apache/giraph/io/accumulo/edgemarker/AccumuloEdgeOutputFormat.java
c2ebbe211fbe431535307b75e23a75b3a540e86d 
>   giraph-core/src/main/java/org/apache/giraph/api/AbstractComputation.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/api/Combiner.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/api/Computation.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/api/io/EdgeInputFormat.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/api/io/SuperstepOutput.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/api/io/VertexInputFormat.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/api/io/VertexOutputFormat.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/api/io/VertexReader.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/api/io/VertexValueInputFormat.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/api/io/VertexValueReader.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/api/io/VertexWriter.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/api/io/package-info.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/api/package-info.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/bsp/BspService.java aae01da7da25933f637533b9b48bba19440df482

>   giraph-core/src/main/java/org/apache/giraph/bsp/CentralizedService.java ff3e427df2926a377c83283abd30d4fc948f0a93

>   giraph-core/src/main/java/org/apache/giraph/bsp/CentralizedServiceMaster.java 999888df66a23ed0858fdaf0ca3d3557bda5786f

>   giraph-core/src/main/java/org/apache/giraph/bsp/CentralizedServiceWorker.java 29567c030701bc7e05caf882248c4c90c6520a5c

>   giraph-core/src/main/java/org/apache/giraph/combiner/Combiner.java 7830ffff079c945eb8b0258a733ff72dc426b797

>   giraph-core/src/main/java/org/apache/giraph/combiner/DoubleSumCombiner.java 8da4ba77b6f68d8f901b9aa4f2ecc439eec5434d

>   giraph-core/src/main/java/org/apache/giraph/combiner/FloatSumCombiner.java d89879150efa7ee0df9845f26dc9390a9b632171

>   giraph-core/src/main/java/org/apache/giraph/combiner/MinimumDoubleCombiner.java 0a85d64c388582e1f7d25c57da2772ada51f9ea5

>   giraph-core/src/main/java/org/apache/giraph/combiner/MinimumIntCombiner.java fcef58eaec13c22ffa01c34d0a3ec29ab0fee53d

>   giraph-core/src/main/java/org/apache/giraph/combiner/RawCombiner.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/combiner/SimpleSumCombiner.java 2a11d2f06be9365ec8ef6dae0759a9e47a4f08c0

>   giraph-core/src/main/java/org/apache/giraph/comm/SendCache.java 30c07ee957b66b9c11495cabf3719f94e445acf1

>   giraph-core/src/main/java/org/apache/giraph/comm/SendEdgeCache.java 5513da2a6a4bed63ae0915fb257e830b6c077fa5

>   giraph-core/src/main/java/org/apache/giraph/comm/SendMessageCache.java 8df0dda628e1753896eaa0ed96a5383318056612

>   giraph-core/src/main/java/org/apache/giraph/comm/SendMessageToAllCache.java 54234c58935d5ed17acfc3eb4d440dbd3678fbeb

>   giraph-core/src/main/java/org/apache/giraph/comm/SendMutationsCache.java a1f08c0ef44600c7544ab7376d71295e15c907a6

>   giraph-core/src/main/java/org/apache/giraph/comm/SendPartitionCache.java 524c9f1cf6a605d9e06b216b980b8e21712d7af5

>   giraph-core/src/main/java/org/apache/giraph/comm/ServerData.java 39bf5042e2f937ead0a0d6ba2f88dff432d12224

>   giraph-core/src/main/java/org/apache/giraph/comm/WorkerClient.java 3759f6bf99e3c418e8c6de25a713b0c96a96f6d4

>   giraph-core/src/main/java/org/apache/giraph/comm/WorkerClientRequestProcessor.java
9bdf9cae20b47b5063b343e1a9d42babfd37df96 
>   giraph-core/src/main/java/org/apache/giraph/comm/WorkerServer.java bed07b9648ba1f6d687fc5d2be38a046dfbcd1db

>   giraph-core/src/main/java/org/apache/giraph/comm/messages/ByteArrayMessagesPerVertexStore.java
6518da6d931db972cab7f95908c50145daf40c31 
>   giraph-core/src/main/java/org/apache/giraph/comm/messages/InMemoryMessageStoreFactory.java
0cdfb733014496b84f26fceb35cb9f509ac1eac7 
>   giraph-core/src/main/java/org/apache/giraph/comm/messages/MessageStore.java 2af764244493f7880c2c42e4a53c809aea290d0e

>   giraph-core/src/main/java/org/apache/giraph/comm/messages/MessageStoreFactory.java
254afd404716ecb4793a2f22dc336ddf53e20242 
>   giraph-core/src/main/java/org/apache/giraph/comm/messages/MessagesIterable.java a466a8dd164f7e8a9f11c6ad6e66e16e33508671

>   giraph-core/src/main/java/org/apache/giraph/comm/messages/OneMessagePerVertexStore.java
4f150daeaf639a6f4de6ba6b45d47f514e7f38cc 
>   giraph-core/src/main/java/org/apache/giraph/comm/messages/SimpleMessageStore.java 13292a2c5f7f291928960f024b244af58075d3fe

>   giraph-core/src/main/java/org/apache/giraph/comm/messages/out_of_core/DiskBackedMessageStore.java
346e3b36046a140a98b7c8ee9b49eedf1befc5d8 
>   giraph-core/src/main/java/org/apache/giraph/comm/messages/out_of_core/PartitionDiskBackedMessageStore.java
7b3e548b08bb394f522943030c8273c54a5b46fc 
>   giraph-core/src/main/java/org/apache/giraph/comm/messages/out_of_core/SequentialFileMessageStore.java
64031c33d62d0db11fe820275876415225c8a6e6 
>   giraph-core/src/main/java/org/apache/giraph/comm/messages/primitives/IntByteArrayMessageStore.java
597e7af56c9d1dcd05eb3e61b7e0c69ec7f1c7ff 
>   giraph-core/src/main/java/org/apache/giraph/comm/messages/primitives/IntFloatMessageStore.java
a193fb97ce6e0a86fbfd61dee6dd3d8249c2ad8b 
>   giraph-core/src/main/java/org/apache/giraph/comm/messages/primitives/LongByteArrayMessageStore.java
3fe6356ae47d65199bed055a23a1a6af9d8361e0 
>   giraph-core/src/main/java/org/apache/giraph/comm/messages/primitives/LongDoubleMessageStore.java
96ed5b4981c670f0534d22bce406b4d39796d4e9 
>   giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyWorkerClient.java 28f365693ce3e8701fa3cb72ea8683733ea3691e

>   giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyWorkerClientRequestProcessor.java
34a3d1ff86a4f73ecefad4891a5d8d04368e653b 
>   giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyWorkerServer.java 3473de1c57c05333c5731775ef85a19c95717a28

>   giraph-core/src/main/java/org/apache/giraph/comm/netty/handler/WorkerRequestServerHandler.java
f64c373c09dd99c1f18538153738d972e3c50023 
>   giraph-core/src/main/java/org/apache/giraph/comm/requests/SendPartitionCurrentMessagesRequest.java
c74b4f5dee13355ee7a91d760bfed2bbaf9b3023 
>   giraph-core/src/main/java/org/apache/giraph/comm/requests/SendPartitionMutationsRequest.java
de0d098d7d7ecc716beabc057e674001f22051c1 
>   giraph-core/src/main/java/org/apache/giraph/comm/requests/SendVertexRequest.java e0cb916668a477d2bebd4df22aa697017b1a2c78

>   giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerDataRequest.java
4f802249b904897dd4491e4553f8f064b12cde65 
>   giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerEdgesRequest.java
793768a1fd0165b02170a5d6988bc89b8bb80ac9 
>   giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerMessagesRequest.java
3ac0962d3e0547d7b3bec41c5c959fa529941c93 
>   giraph-core/src/main/java/org/apache/giraph/comm/requests/SendWorkerOneToAllMessagesRequest.java
8745adbf257ea3fe5d412bc2f6da2cb4ffb48b9b 
>   giraph-core/src/main/java/org/apache/giraph/comm/requests/WorkerRequest.java 0ceb3ebd83915dd2f2cd8eba689869e24a8162d0

>   giraph-core/src/main/java/org/apache/giraph/comm/requests/WritableRequest.java 181e681cf80629b3e2944e616c90c05904cc97b3

>   giraph-core/src/main/java/org/apache/giraph/conf/DefaultImmutableClassesGiraphConfigurable.java
c5096fa634e85b73c9704761436b108fed019ffa 
>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphClasses.java 71fe88551bac7325e79f30eee004a4061a8627cd

>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java 23bcd324196851f2970dd75ff2ccbb3d1e2f3383

>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java c276c2a563ec3372df1be3c3fe47eda0e8bfe2d0

>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphTypes.java 0727270e4e61f7495b1fcd988c9117a3eec21698

>   giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfigurable.java
dbffbc793eb34ca8fc2011cef59265ad8078571d 
>   giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java
49a2ebcf9d0d389185d2f2adee6738e00f1eb040 
>   giraph-core/src/main/java/org/apache/giraph/conf/TypesHolder.java 0deb79fc1003ee451614f616ebba2b8dce6a707a

>   giraph-core/src/main/java/org/apache/giraph/edge/ArrayListEdges.java 4eb33784be351961b6a327eca96a19ae375dbbd8

>   giraph-core/src/main/java/org/apache/giraph/edge/ByteArrayEdges.java b9d1f6cde72fcdcfd7589f4f9d1493076e6b743d

>   giraph-core/src/main/java/org/apache/giraph/edge/ConfigurableOutEdges.java a983ee40d018f34e665b3da3b5ac3a9fedb28294

>   giraph-core/src/main/java/org/apache/giraph/edge/DefaultEdge.java d7cfb2f73ba06735e476ec72bed4e3defa9f54a3

>   giraph-core/src/main/java/org/apache/giraph/edge/Edge.java 4649da148a4c557eee6cd3666538b7400aa64d9b

>   giraph-core/src/main/java/org/apache/giraph/edge/EdgeFactory.java c0d1a0c8aa0741c702a99cbc381a7f3bd6d4236e

>   giraph-core/src/main/java/org/apache/giraph/edge/EdgeNoValue.java 306a4131704c4bb918e648068277e6c60c86081a

>   giraph-core/src/main/java/org/apache/giraph/edge/EdgeStore.java 23df689121944d834803ffcba47cb5f61cb74451

>   giraph-core/src/main/java/org/apache/giraph/edge/HashMapEdges.java 094563408be16aa20e91acb715547aacf21d8bc3

>   giraph-core/src/main/java/org/apache/giraph/edge/HashMultimapEdges.java e5e39de1ec50c6df43fc497a2d0c7b2b2b72beeb

>   giraph-core/src/main/java/org/apache/giraph/edge/MapMutableEdge.java cb8702c40666c1e6f8e4ec613b8e7c0ebcd958ea

>   giraph-core/src/main/java/org/apache/giraph/edge/MultiRandomAccessOutEdges.java e3fc16bb5e5c015d4bfc083c0d11ff3d0e6d8908

>   giraph-core/src/main/java/org/apache/giraph/edge/MutableEdge.java 78e34e6cf8892eda648d551620e69258053a57ef

>   giraph-core/src/main/java/org/apache/giraph/edge/MutableEdgesIterable.java ea55e29e22cafa2df3713dca47e6836eb80571aa

>   giraph-core/src/main/java/org/apache/giraph/edge/MutableEdgesWrapper.java 4e2a2a2e7d8f03d83fd3e0789eeaf619bb15a365

>   giraph-core/src/main/java/org/apache/giraph/edge/MutableOutEdges.java 0dcc018e5665545141b3961b33a81889a181ffbc

>   giraph-core/src/main/java/org/apache/giraph/edge/OutEdges.java 34dc5cbcea66268107037a65717f640b4607a832

>   giraph-core/src/main/java/org/apache/giraph/edge/ReusableEdge.java d55e25bf43de356020aa5c5615293003941c70d6

>   giraph-core/src/main/java/org/apache/giraph/edge/ReuseObjectsOutEdges.java 27cf9cae734729677c01019821c0250d5f8abc06

>   giraph-core/src/main/java/org/apache/giraph/edge/StrictRandomAccessOutEdges.java 800f45b83ab11113542b313ccdacd94f19c9111b

>   giraph-core/src/main/java/org/apache/giraph/factories/AbstractMessageValueFactory.java
dcc286f9154769ba175892c418782d8d0c593d1d 
>   giraph-core/src/main/java/org/apache/giraph/factories/ComputationFactory.java 38f46863c632fd9ec95273dc82b8bd485bcf8274

>   giraph-core/src/main/java/org/apache/giraph/factories/DefaultComputationFactory.java
c13f2af6a0040142c2b7a693471b62b7f2da56d8 
>   giraph-core/src/main/java/org/apache/giraph/factories/DefaultEdgeValueFactory.java
c392c875b2a0a9681fc20127531254c394481a47 
>   giraph-core/src/main/java/org/apache/giraph/factories/DefaultIncomingMessageValueFactory.java
bdf29669321567fd139286b68ae784faddec8d2f 
>   giraph-core/src/main/java/org/apache/giraph/factories/DefaultOutgoingMessageValueFactory.java
a42d5e28ae8e262ac03dbaffb286e4511774cf4b 
>   giraph-core/src/main/java/org/apache/giraph/factories/DefaultVertexIdFactory.java 6dafc7ca593404ce347b887ccb3ab7424a430cfd

>   giraph-core/src/main/java/org/apache/giraph/factories/DefaultVertexValueFactory.java
2fe61ae456289a572f0a580ee3cb30651b99a028 
>   giraph-core/src/main/java/org/apache/giraph/factories/EdgeValueFactory.java 9c5bb076141ef65e5f68d1967c8d18e06d385886

>   giraph-core/src/main/java/org/apache/giraph/factories/MessageValueFactory.java e94745b289018d201e1b14322eb85ced84edd023

>   giraph-core/src/main/java/org/apache/giraph/factories/TestMessageValueFactory.java
806664badbd43f543cb672e37b2dc55255a9a37a 
>   giraph-core/src/main/java/org/apache/giraph/factories/ValueFactories.java 733d5f21eb03b9a15bdc2b3f3eb1630fbb8225de

>   giraph-core/src/main/java/org/apache/giraph/factories/ValueFactory.java 5725061395a4d6b8dc8b595b0ff98b887422e17f

>   giraph-core/src/main/java/org/apache/giraph/factories/VertexIdFactory.java a119dc4e4eec784618a8c245743fbd89cbbab9b8

>   giraph-core/src/main/java/org/apache/giraph/factories/VertexValueFactory.java ba12b8497429e1377c033f18c9ed935c33d4d150

>   giraph-core/src/main/java/org/apache/giraph/graph/AbstractComputation.java e7c30844c3a8cc3c1cd90bde6bc314334680a974

>   giraph-core/src/main/java/org/apache/giraph/graph/BasicComputation.java 80baa4d14bf1325aa2c3cd73769131a8e11e42a4

>   giraph-core/src/main/java/org/apache/giraph/graph/Computation.java 7a7b40f198c365520206e3300d20ca5ef4619541

>   giraph-core/src/main/java/org/apache/giraph/graph/ComputeCallable.java 77d9f5ebc5a283794c1e26b0d5f0a723e018f766

>   giraph-core/src/main/java/org/apache/giraph/graph/DefaultVertex.java 03cb3c16976c2efed16f60dc42785781a1754cce

>   giraph-core/src/main/java/org/apache/giraph/graph/DefaultVertexResolver.java 748c3a6a2b84dc07d17bd453c1d3b680da24da26

>   giraph-core/src/main/java/org/apache/giraph/graph/GiraphTransferRegulator.java 19034caf0a76f481b526f37f3e8a401936e7f63a

>   giraph-core/src/main/java/org/apache/giraph/graph/GraphMapper.java c86a0248776cb8682e1aade66991588912fbaf13

>   giraph-core/src/main/java/org/apache/giraph/graph/GraphTaskManager.java 704fb9e7209203d0f6e9aa0c9e24ff6d9a0ecac8

>   giraph-core/src/main/java/org/apache/giraph/graph/GraphType.java 4a0ac8f15ec0032d1579a2e455a91035855ebb1c

>   giraph-core/src/main/java/org/apache/giraph/graph/RawAbstractComputation.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/graph/RawComputation.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/graph/Vertex.java 5c6ca1d33d30e15c951a31ab8031752e15b8ed38

>   giraph-core/src/main/java/org/apache/giraph/graph/VertexChanges.java 3d09c06b43d2bd54d3c1ee70d2e4d6c9d3396207

>   giraph-core/src/main/java/org/apache/giraph/graph/VertexMutations.java 18104cbfe11106bb8e5634523af0165eaf28a598

>   giraph-core/src/main/java/org/apache/giraph/graph/VertexResolver.java b6659f47c6b6ce33efd0295487d34b0e2a0a3ffc

>   giraph-core/src/main/java/org/apache/giraph/integration/SuperstepHashPartitionerFactory.java
ebc62f6d03238de0b22565e54af6cbba56b3d375 
>   giraph-core/src/main/java/org/apache/giraph/io/BasicVertexValueReader.java 310c39af3b12b24c548c567e48390456d9be06bd

>   giraph-core/src/main/java/org/apache/giraph/io/EdgeInputFormat.java 1f4451ff16c51fbbb904e3d4ab003b8c8997628e

>   giraph-core/src/main/java/org/apache/giraph/io/EdgeReader.java 1bc48e30a58c3a67f93fe4f2197ab6bfcdf1e7d0

>   giraph-core/src/main/java/org/apache/giraph/io/GiraphInputFormat.java 50f3cb15298a918a0c1981eee6db6a0e045636c2

>   giraph-core/src/main/java/org/apache/giraph/io/RawEdgeInputFormat.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/io/RawEdgeReader.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/RawSimpleVertexWriter.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/io/RawVertexInputFormat.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/io/RawVertexOutputFormat.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/io/RawVertexReader.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/RawVertexValueInputFormat.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/io/RawVertexValueReader.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/io/RawVertexWriter.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/ReverseEdgeDuplicator.java e9c113d424a655e9479c5f880391a57cb2f48e7b

>   giraph-core/src/main/java/org/apache/giraph/io/SimpleVertexWriter.java 41a049fe86f17367e83bbc73fb4c44ce1b445fb6

>   giraph-core/src/main/java/org/apache/giraph/io/VertexInputFormat.java 6c8adc2e0ad9f97a57e8cabe312047841c67f27f

>   giraph-core/src/main/java/org/apache/giraph/io/VertexOutputFormat.java ad00a8e8df95047e7ea2fe357dbd01694c5f48e0

>   giraph-core/src/main/java/org/apache/giraph/io/VertexReader.java 94a4083d694d0b8a85e9840a6cef3a7d8b822566

>   giraph-core/src/main/java/org/apache/giraph/io/VertexValueInputFormat.java 29abe7387ec53da09110f0a8f17ea0f61c6848d9

>   giraph-core/src/main/java/org/apache/giraph/io/VertexValueReader.java 6a15ee8269eaa92ae7ba75e54f450a36ac06e2c2

>   giraph-core/src/main/java/org/apache/giraph/io/VertexWriter.java 69fdfc5c0bb37a1fd93c5002425260020e2f9547

>   giraph-core/src/main/java/org/apache/giraph/io/filters/DefaultEdgeInputFilter.java
40ab922679ce19326fc7c4fb1a4c333da77c5a96 
>   giraph-core/src/main/java/org/apache/giraph/io/filters/DefaultVertexInputFilter.java
f35ade585ec1716d2f937277589367be755c1c29 
>   giraph-core/src/main/java/org/apache/giraph/io/filters/EdgeInputFilter.java fa69932ece1ef92b8fd3ff0739561245c4b1bc6e

>   giraph-core/src/main/java/org/apache/giraph/io/filters/VertexInputFilter.java c7d178e0380bfe7cfdccfe7860dc9697054a1adc

>   giraph-core/src/main/java/org/apache/giraph/io/formats/AdjacencyListTextVertexInputFormat.java
faddc24ad04fbeac2f8d2d85c311471672fff1f4 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/AdjacencyListTextVertexOutputFormat.java
8efbfd09af012470d35056763a6d0c7c73a49f97 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/GeneratedVertexInputFormat.java
66137f1c36a7d33d02ae415ca121be013077dd71 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/IdWithValueTextOutputFormat.java
bd69586f47103c8719d9cb958720ce317b3d2098 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/IntIntNullTextInputFormat.java
b15f2222f6a648c6303632c1d8fb550197dc5c7c 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/IntIntTextVertexValueInputFormat.java
1038a3269fc0a4bc04176224edd0de981ce207f4 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/IntNullNullTextInputFormat.java
b56c5868ef0b0b5ce67e28d045b2c56d2d6903ce 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/IntNullReverseTextEdgeInputFormat.java
3aeb753bc5660052636be367514fb7df21ce32a0 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/IntNullTextEdgeInputFormat.java
2b4b5d5e289e2dd518d68cf4c6b276e27f4140f9 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/JsonBase64VertexInputFormat.java
bceb9120e0bfc81795ee07d0273d097f98b0ab17 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/JsonBase64VertexOutputFormat.java
a71cf96b59239e2d140077e49e8698c7a9336d4c 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/LongLongNullTextInputFormat.java
4d47862fa6d646ac3c18c089954e0c5d50113aa6 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/PseudoRandomEdgeInputFormat.java
e379726febc982c8486cbf98197b9b4b905ffb9c 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/PseudoRandomIntNullVertexInputFormat.java
b9f91e2bbdc7b351e20bf5fb200caa3440f85894 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/PseudoRandomVertexInputFormat.java
f55c5af83b018c930ab57b6a42533a90c9ce4dea 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/SequenceFileVertexInputFormat.java
4d8af1f70ba10ead2ea6fb5959c0ec7ebf0e69b7 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/SequenceFileVertexOutputFormat.java
c6ff6d4f9865163053eb08d3e4a91dd347515508 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/TextEdgeInputFormat.java ae688c73685b06648c71fbd2a82d078e3924c474

>   giraph-core/src/main/java/org/apache/giraph/io/formats/TextVertexInputFormat.java 68039a6c79ac87f75e36d55a68816637c4590242

>   giraph-core/src/main/java/org/apache/giraph/io/formats/TextVertexOutputFormat.java
c91d543608679bbdcc53274686549dd569985698 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/TextVertexValueInputFormat.java
6a795a8fe640321b34ef689315436fa6c73132bd 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/multi/EdgeInputFormatDescription.java
acc240d75289afd5017fc7d80c9e0c620eb05b4e 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/multi/MultiEdgeInputFormat.java
a99c651d6a3b1b24ac82e1ac5842af735cfb5a37 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/multi/MultiVertexInputFormat.java
5480619b0a004c5e31dbfc9e92f7248233e63320 
>   giraph-core/src/main/java/org/apache/giraph/io/formats/multi/VertexInputFormatDescription.java
e86f9ed90de3a1ee71fa298cec9b9388e9bf1ba3 
>   giraph-core/src/main/java/org/apache/giraph/io/internal/WrappedEdgeInputFormat.java
ffe765df6fa030098d03f909068bd15d72715aa1 
>   giraph-core/src/main/java/org/apache/giraph/io/internal/WrappedEdgeReader.java 9b5e8c6cdde01d884b70b29058e986ebba62716e

>   giraph-core/src/main/java/org/apache/giraph/io/internal/WrappedVertexInputFormat.java
fddf75bb106ac63b8ec48f325f3c1a33bfe88511 
>   giraph-core/src/main/java/org/apache/giraph/io/internal/WrappedVertexOutputFormat.java
669bbe1c1d27314c65e2ecbdb4280e1fba8a9112 
>   giraph-core/src/main/java/org/apache/giraph/io/internal/WrappedVertexReader.java 8e256026bd8a4e122982ac19b1a45a4dadaf8401

>   giraph-core/src/main/java/org/apache/giraph/io/iterables/EdgeReaderWrapper.java f61ac45d0f194ede3ba3be84281b3f5ce6f24be0

>   giraph-core/src/main/java/org/apache/giraph/io/iterables/EdgeWithSource.java 6f72de3e04171c26bde05b2178a32a0d708ec530

>   giraph-core/src/main/java/org/apache/giraph/io/iterables/IteratorToReaderWrapper.java
409bb99760e3af42c187da739843b42b43d5e237 
>   giraph-core/src/main/java/org/apache/giraph/io/iterables/VertexReaderWrapper.java bf0c238ab84a8360a93a85b754c3d2aa49e332ca

>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/MultiThreadedSuperstepOutput.java
452d93a5cd1fec8a8f690b481a66c83c33e26cc9 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/NoOpSuperstepOutput.java
be981cf47bb9a5eecd4e447f30674cb8dc0b983a 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/RawSuperstepOutput.java
PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/RawSynchronizedSuperstepOutput.java
PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SuperstepOutput.java
107039a7e781e4a9e19021ab1bdd146e7c775b85 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SynchronizedSuperstepOutput.java
7f233e00bd1f82bab0e5e32de77e3b4098d15466 
>   giraph-core/src/main/java/org/apache/giraph/job/GiraphConfigurationValidator.java 5b870c54e92a7ece943bef04e3264e5703cb815a

>   giraph-core/src/main/java/org/apache/giraph/jython/JythonComputation.java 87c823c31f0d4260c524a51dfe8d48ec56eb2c08

>   giraph-core/src/main/java/org/apache/giraph/jython/JythonGiraphComputation.java d1022a7a720da9ac930878bf5e1b8bb95df37e77

>   giraph-core/src/main/java/org/apache/giraph/jython/JythonJob.java 6b2eedf8bf82bf13e10eb20e2d98b8a960348844

>   giraph-core/src/main/java/org/apache/giraph/jython/factories/JythonComputationFactory.java
eae0d5799d2d5adfcdb9879542e4be9ea8607fc6 
>   giraph-core/src/main/java/org/apache/giraph/jython/factories/JythonEdgeValueFactory.java
498b7055caeba0e4875c16afb5df6ea14a08dc15 
>   giraph-core/src/main/java/org/apache/giraph/jython/factories/JythonFactoryBase.java
0d3d34afe4b317512a2c225fa312a9bda5229d06 
>   giraph-core/src/main/java/org/apache/giraph/jython/factories/JythonIncomingMessageValueFactory.java
e77e9c30a4989b103cecfde575913d43ae1a702b 
>   giraph-core/src/main/java/org/apache/giraph/jython/factories/JythonMessageValueFactory.java
d2f8d9f5028e4fb61aa8e179e7b9bced7a91fd39 
>   giraph-core/src/main/java/org/apache/giraph/jython/factories/JythonOutgoingMessageValueFactory.java
45f6387e74ef262d4bd0e7b9f7e678b9afe97c76 
>   giraph-core/src/main/java/org/apache/giraph/jython/factories/JythonVertexIdFactory.java
51aa88c3d669b7437d1a260a9bfb9334ec923255 
>   giraph-core/src/main/java/org/apache/giraph/jython/factories/JythonVertexValueFactory.java
39c084a235907b32add5e82bad55775809bba1ac 
>   giraph-core/src/main/java/org/apache/giraph/master/BspServiceMaster.java 454c934f8b53e96eacb3e0b10dfe2d07712a3ce1

>   giraph-core/src/main/java/org/apache/giraph/master/MasterCompute.java cf7356cf9f98ef120b7d6bd14af421e9bceeacf2

>   giraph-core/src/main/java/org/apache/giraph/master/MasterThread.java ec1733c74b4f9f8a44c13dd2a7b9a5d24b54be67

>   giraph-core/src/main/java/org/apache/giraph/master/SuperstepClasses.java 7a7df052e8b7b937b14d032875f5301a02ea9a8f

>   giraph-core/src/main/java/org/apache/giraph/partition/BasicPartition.java f2b855249c6a126d2e042048489e71baa6d65ea4

>   giraph-core/src/main/java/org/apache/giraph/partition/ByteArrayPartition.java 6eaa6d76efac80c53251ad1037f1c44ed6c4d933

>   giraph-core/src/main/java/org/apache/giraph/partition/DiskBackedPartitionStore.java
110ce9d5520aa76763d925615aea34fafca1dc52 
>   giraph-core/src/main/java/org/apache/giraph/partition/GraphPartitionerFactory.java
4200d79a5f0fa191718239f8a869cef9ab3bfe47 
>   giraph-core/src/main/java/org/apache/giraph/partition/HashMasterPartitioner.java 240687e06948fbaab6d0c1572eb6749e99f3a285

>   giraph-core/src/main/java/org/apache/giraph/partition/HashPartitionerFactory.java 7cc565184a19a7532b49b4fd3408781c2c0eec1a

>   giraph-core/src/main/java/org/apache/giraph/partition/HashRangePartitionerFactory.java
1eeece73f1d95192e0bdaa56a3dc71be208aa908 
>   giraph-core/src/main/java/org/apache/giraph/partition/HashRangeWorkerPartitioner.java
81c3d7d574fa6bb0f8f7a200d94c46c9dc452c62 
>   giraph-core/src/main/java/org/apache/giraph/partition/HashWorkerPartitioner.java d8338951c484849768e00b9b82a82246f2cfcaee

>   giraph-core/src/main/java/org/apache/giraph/partition/MasterGraphPartitioner.java 50c750a1b560d8ff03cb3ee29b4773dec95f13d0

>   giraph-core/src/main/java/org/apache/giraph/partition/Partition.java b6b9551f20fbeb325b9033ea9fe79accc9f4e351

>   giraph-core/src/main/java/org/apache/giraph/partition/PartitionStore.java 763397e0f7e6b7d09c51b1679eed3097d2f89e01

>   giraph-core/src/main/java/org/apache/giraph/partition/RangeMasterPartitioner.java 3911a953c7537978b2b7b243b865b3e14740b564

>   giraph-core/src/main/java/org/apache/giraph/partition/RangePartitionOwner.java e7e03dc26493c7f7cf635b162acee028469aa160

>   giraph-core/src/main/java/org/apache/giraph/partition/RangePartitionStats.java 73af816af92ff3a65b0849e21624785845cd313f

>   giraph-core/src/main/java/org/apache/giraph/partition/RangePartitionerFactory.java
2ec4d4a87c645092d2cd9625f67f536177cfed7b 
>   giraph-core/src/main/java/org/apache/giraph/partition/RangeSplitHint.java 43179441d35e6d49a03a9ca8186c4675972c252c

>   giraph-core/src/main/java/org/apache/giraph/partition/RangeWorkerPartitioner.java cbcd7530613e344a3bb2e3e3a431f1c8f19b4a0f

>   giraph-core/src/main/java/org/apache/giraph/partition/ReusesObjectsPartition.java 405bc5ce32755357b17e3f10de1e54ebbeb30316

>   giraph-core/src/main/java/org/apache/giraph/partition/SimpleIntRangePartitionerFactory.java
7aee84cc2f387d48fc58c9e350a251306efcdcf0 
>   giraph-core/src/main/java/org/apache/giraph/partition/SimpleLongRangePartitionerFactory.java
64efde9557ab1a334444653189cf17714bcd781a 
>   giraph-core/src/main/java/org/apache/giraph/partition/SimplePartition.java 0c1b40439a8891629b60aace4d89997ade42d1b5

>   giraph-core/src/main/java/org/apache/giraph/partition/SimplePartitionStore.java ae17aac19001ccacc147287cc7a303d8cc17c91f

>   giraph-core/src/main/java/org/apache/giraph/partition/SimpleRangeMasterPartitioner.java
37ce8c7718128434f91309b55efc5aef72f5e974 
>   giraph-core/src/main/java/org/apache/giraph/partition/SimpleRangeWorkerPartitioner.java
ab2afd5da3e352ee0f72b49eecf226499c892791 
>   giraph-core/src/main/java/org/apache/giraph/partition/WorkerGraphPartitioner.java 004ea81928f9e826c7ea25b4be2fca86771435f1

>   giraph-core/src/main/java/org/apache/giraph/serde/Deserializer.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/serde/EdgeSerDe.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/serde/SerDe.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/serde/SerDeCache.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/serde/SerDeUtils.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/serde/Serializer.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/serde/VertexSerDe.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/serde/WritableSerDe.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/serde/package-info.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayIterable.java cf2c187621c29dbdf9ab4d540af4a428b9054f2c

>   giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayIterator.java 76ed7892f559995f6da3f52b5a7371399dd62b33

>   giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayOneToAllMessages.java f190c17a8a6d653e1f68517d9d03cc1c145b224b

>   giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayVertexIdData.java 5c5603819f0685f8284e5a290e922894471fa1b3

>   giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayVertexIdEdges.java 762802bce2e1d5e17368c0dbb6d6756518293690

>   giraph-core/src/main/java/org/apache/giraph/utils/ByteArrayVertexIdMessages.java 56cc01c44c45ca461446f78fc42a662721df62c2

>   giraph-core/src/main/java/org/apache/giraph/utils/ComparableComparator.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/utils/ComparatorCache.java PRE-CREATION

>   giraph-core/src/main/java/org/apache/giraph/utils/ConfigurationUtils.java 745764b51d72284f2b0196930153ce4b4b2f427d

>   giraph-core/src/main/java/org/apache/giraph/utils/EdgeComparator.java 75397433ff4585b6c540ea02baf19da62cef9352

>   giraph-core/src/main/java/org/apache/giraph/utils/EdgeIterables.java 0d2b810c527e4fe3a92cd0c4a09ae532e0302c7d

>   giraph-core/src/main/java/org/apache/giraph/utils/InMemoryVertexInputFormat.java 777247b26fb6ae4aa2fa35878799d1067d3f02e9

>   giraph-core/src/main/java/org/apache/giraph/utils/InternalVertexRunner.java 72fab8381c341ee5754fe2288c31dba1f739419e

>   giraph-core/src/main/java/org/apache/giraph/utils/RepresentativeByteArrayIterable.java
e3992ed8845b89b371fecca7e503caa039b28545 
>   giraph-core/src/main/java/org/apache/giraph/utils/RepresentativeByteArrayIterator.java
b6151c53c6ba79ac6a2ccc90a50f771a2343e972 
>   giraph-core/src/main/java/org/apache/giraph/utils/TestGraph.java 312a2873fe4dc8133c186036cd9c6de90b374ea9

>   giraph-core/src/main/java/org/apache/giraph/utils/VertexIdIterator.java bad11d6cdeed7520c0b44bb38983319c5cc929de

>   giraph-core/src/main/java/org/apache/giraph/utils/WritableUtils.java 9163c08c6e4d089ec467f8a223efdaabef2bb995

>   giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java 9311fbd1d6e3ceca8ed1aef8e194555bf387aa8d

>   giraph-core/src/main/java/org/apache/giraph/worker/EdgeInputSplitsCallable.java 8ec04531d4b68009bb86084747f2062829a846fb

>   giraph-core/src/main/java/org/apache/giraph/worker/EdgeInputSplitsCallableFactory.java
f68ac93c7bf91af0725d7065d3015f1e0c871a39 
>   giraph-core/src/main/java/org/apache/giraph/worker/InputSplitsCallable.java 10b1a25f77b6476bb6ea67af610f57a09032cbcc

>   giraph-core/src/main/java/org/apache/giraph/worker/VertexInputSplitsCallable.java 01a6fc5bef76b896adfff87a1b25bebaef929d50

>   giraph-core/src/main/java/org/apache/giraph/worker/VertexInputSplitsCallableFactory.java
c9893d27c6ee61d6f028e776d707131546de0675 
>   giraph-core/src/main/java/org/apache/giraph/yarn/GiraphYarnTask.java f4719ccbd6a8e5252cf4a0042489031242d4dbea

>   giraph-core/src/test/java/org/apache/giraph/comm/RequestFailureTest.java 236bc881d89347f484cc292660563e5af4531bfe

>   giraph-core/src/test/java/org/apache/giraph/comm/RequestTest.java 115c10839a03a01d15a53ccf3e90caeb0db498ee

>   giraph-core/src/test/java/org/apache/giraph/comm/TestMessageStores.java eb2497ba954970ea5df7a7656e1d3dcaaa9fedf5

>   giraph-core/src/test/java/org/apache/giraph/comm/messages/TestIntFloatPrimitiveMessageStores.java
a8f6f70cdb59edf55e2eb441564e9c7ff5376ae5 
>   giraph-core/src/test/java/org/apache/giraph/comm/messages/TestLongDoublePrimitiveMessageStores.java
065926092bc886d680ad07849ad1b614e82b5bab 
>   giraph-core/src/test/java/org/apache/giraph/io/TestTextDoubleDoubleAdjacencyListVertexInputFormat.java
d34f258ae6b3dea4a2e323c88affc85b907fe34e 
>   giraph-core/src/test/java/org/apache/giraph/master/TestComputationCombinerTypes.java
b62775f1c7b3f561b5e7b05bb3ffb66ac42493c2 
>   giraph-core/src/test/java/org/apache/giraph/master/TestSwitchClasses.java 6b0ed35391942f472fca43eeb773ad59715ffa7f

>   giraph-core/src/test/java/org/apache/giraph/partition/TestGiraphTransferRegulator.java
be9db7eb832deb1265f4bca0d2de6d531e6560be 
>   giraph-core/src/test/java/org/apache/giraph/serde/TestSerDes.java PRE-CREATION 
>   giraph-core/src/test/java/org/apache/giraph/utils/MockUtils.java 97e88f8b9024ab0254fac3b3c8004c70028d08cd

>   giraph-core/src/test/java/org/apache/giraph/utils/NoOpComputation.java 630888f65b969e931b186c47203e67a28f8c975a

>   giraph-core/src/test/java/org/apache/giraph/utils/TestReflectionUtils.java 261e7c265d40153b83b6c9ba5c6edcea3317b7b3

>   giraph-examples/src/main/java/org/apache/giraph/examples/AggregatorsTestComputation.java
2251b572c50819c9c086e19f5686c384945b838f 
>   giraph-examples/src/main/java/org/apache/giraph/examples/GeneratedEdgeReader.java 3a3c00f5b52c6cd6ad7ac8aed4b6afc52bf96d3f

>   giraph-examples/src/main/java/org/apache/giraph/examples/GeneratedVertexReader.java
ed5a8d0a074fbc487de115485c3855c1186a04f6 
>   giraph-examples/src/main/java/org/apache/giraph/examples/IdentityComputation.java 12a58d5b800b0edfbca36681e11c65ce7c6ba97c

>   giraph-examples/src/main/java/org/apache/giraph/examples/LongDoubleDoubleTextInputFormat.java
18cc8bc15ec86d75c6b4c80ed12ab654b8319921 
>   giraph-examples/src/main/java/org/apache/giraph/examples/NormalizingLongDoubleDoubleTextInputFormat.java
2dc874e0731afedb1962b5065bf4dfe748aad651 
>   giraph-examples/src/main/java/org/apache/giraph/examples/RandomWalkComputation.java
ed95aaeaab33f2c241e200c12d5ec0e9b392a940 
>   giraph-examples/src/main/java/org/apache/giraph/examples/SimplePageRankComputation.java
f930bb0d582d2cd92207a125cc2bba7cae5afbd4 
>   giraph-examples/src/main/java/org/apache/giraph/examples/SimpleSuperstepComputation.java
353f7dffe9dc23855daf8753950580e39a8971bf 
>   giraph-examples/src/test/java/org/apache/giraph/TestBspBasic.java 115da7e7a0e7c8c0ada15db5dc5b9e229e1d4290

>   giraph-examples/src/test/java/org/apache/giraph/examples/MinimumIntCombinerTest.java
434c7561806fc099f077b526cff9ded1bdc3fa11 
>   giraph-examples/src/test/java/org/apache/giraph/vertex/TestComputationTypes.java 4f74fcb0ff835ee0fbfbf2cc822083c0bfbd0814

>   giraph-hbase/src/main/java/org/apache/giraph/io/hbase/HBaseVertexInputFormat.java 9c12ce36a8f6b435eb4e4f171a0bfcc1e71123fd

>   giraph-hbase/src/main/java/org/apache/giraph/io/hbase/HBaseVertexOutputFormat.java
f875c19fc5bca52415458d81e6d32ce18eeab34b 
>   giraph-hbase/src/test/java/org/apache/giraph/io/hbase/edgemarker/TableEdgeInputFormat.java
8589de8445cdffbf2f360ddeec08774c35028921 
>   giraph-hbase/src/test/java/org/apache/giraph/io/hbase/edgemarker/TableEdgeOutputFormat.java
aa95f96151e96cfc1b4e530f4f388ce4ade12142 
>   giraph-hcatalog/src/main/java/org/apache/giraph/io/hcatalog/HCatGiraphRunner.java 25d100b2549a4c6ae20919f4097c56ae1f34feb2

>   giraph-hcatalog/src/main/java/org/apache/giraph/io/hcatalog/HCatalogEdgeInputFormat.java
256076c80101f2ab62abd55a5848fb9c5b4387de 
>   giraph-hcatalog/src/main/java/org/apache/giraph/io/hcatalog/HCatalogVertexInputFormat.java
edecbff7b977d57e55f1b3568d23797b47334ac2 
>   giraph-hcatalog/src/main/java/org/apache/giraph/io/hcatalog/HCatalogVertexOutputFormat.java
1d234d16240dc6db8dec40add9a2d53fb66dcb04 
>   giraph-hcatalog/src/main/java/org/apache/giraph/io/hcatalog/HCatalogVertexValueInputFormat.java
928e40c194dcbd6c449fa3c13bc7e934e7b4d39a 
>   giraph-hive/src/main/java/org/apache/giraph/hive/HiveGiraphRunner.java 6b8a8e9b7bdec30553b6866398c2bd7682244760

>   giraph-hive/src/main/java/org/apache/giraph/hive/common/DefaultConfigurableAndTableSchemaAware.java
cfc696cfbd9d032e5d2eae69ca3e1c188f9547c6 
>   giraph-hive/src/main/java/org/apache/giraph/hive/common/HiveUtils.java 6e1d62b6421ecb7208d290d474ba1cae78efee1e

>   giraph-hive/src/main/java/org/apache/giraph/hive/input/edge/AbstractHiveToEdge.java
9fe5a399408099563419111d06755fd705f9c9cf 
>   giraph-hive/src/main/java/org/apache/giraph/hive/input/edge/HiveEdgeInputFormat.java
534a773074811629fa6185f34d3da34e315589ab 
>   giraph-hive/src/main/java/org/apache/giraph/hive/input/edge/HiveEdgeReader.java cc1dcd511477a27b3d0abbc4260d9c08eeabd3a9

>   giraph-hive/src/main/java/org/apache/giraph/hive/input/edge/HiveToEdge.java 17821148f62920dc8ac52890c22fc166cfbbd33e

>   giraph-hive/src/main/java/org/apache/giraph/hive/input/edge/SimpleHiveToEdge.java c365a878bc46b68cf3156a87d7f600950bbcffd8

>   giraph-hive/src/main/java/org/apache/giraph/hive/input/vertex/AbstractHiveToVertex.java
87f3cfeabe294b680a4b7fd42639a9d70a1b4b78 
>   giraph-hive/src/main/java/org/apache/giraph/hive/input/vertex/HiveToVertex.java ad2c244ebfef3312c160544e234b1776c2cc5af1

>   giraph-hive/src/main/java/org/apache/giraph/hive/input/vertex/HiveVertexInputFormat.java
d5c12792750a33badb81f94041acad9b29fc347c 
>   giraph-hive/src/main/java/org/apache/giraph/hive/input/vertex/HiveVertexReader.java
679a3e8f03a6bad616550d22ba5dff2b08cf8d0d 
>   giraph-hive/src/main/java/org/apache/giraph/hive/input/vertex/SimpleHiveToVertex.java
5483a6826d945a13a95dbd42eb8fa3e3aaeb2e97 
>   giraph-hive/src/main/java/org/apache/giraph/hive/input/vertex/SimpleNoEdgesHiveToVertex.java
21cc6c4d79e49c8f885da706513c1da26ad18ffb 
>   giraph-hive/src/main/java/org/apache/giraph/hive/jython/HiveJythonUtils.java 334f3828fedc5c077b9492e6f1a31a8e515082e4

>   giraph-hive/src/main/java/org/apache/giraph/hive/jython/JythonColumnWriter.java c4da691630d502dae7db576a3bbea304e8e8a9e7

>   giraph-hive/src/main/java/org/apache/giraph/hive/jython/JythonHiveReader.java 79416da1f9f384204c5549f441c1cec195df62a5

>   giraph-hive/src/main/java/org/apache/giraph/hive/jython/JythonHiveWriter.java 4efe43494bc7ef42637ed3c276d95bb6cccf2826

>   giraph-hive/src/main/java/org/apache/giraph/hive/jython/JythonVertexToHive.java ef721a9a75102bcc9fa11dd0659e019ffe1b49e9

>   giraph-hive/src/main/java/org/apache/giraph/hive/output/AbstractVertexToHive.java 4046bb256fb1909e0f1714b33eb5323eb99f8d48

>   giraph-hive/src/main/java/org/apache/giraph/hive/output/HiveVertexOutputFormat.java
c4813fbb00ad8ced356fef9ba34a36b3374fe2c2 
>   giraph-hive/src/main/java/org/apache/giraph/hive/output/HiveVertexWriter.java 796bc8f27467c3d172d1b5790f29de5599d6c14a

>   giraph-hive/src/main/java/org/apache/giraph/hive/output/SimpleVertexToHive.java f6de715a3eee2d4f59a353ba7794811c4162ee5f

>   giraph-hive/src/main/java/org/apache/giraph/hive/output/VertexToHive.java bf13ec10f85d2f063c4a74e8aa3fac5aab03c913

>   giraph-hive/src/main/java/org/apache/giraph/hive/primitives/PrimitiveValueWriter.java
8cd3ea46f6d9dec6021145c813c1027caeff1ade 
>   giraph-hive/src/main/java/org/apache/giraph/hive/values/HiveValueReader.java e989e28d7974af6eff0e53b8d42a0fc523c4395f

>   giraph-hive/src/main/java/org/apache/giraph/hive/values/HiveValueWriter.java 4b624f65499b4cd5c387f5bd14a01cd412fc08ca

>   giraph-rexster/src/main/java/org/apache/giraph/rexster/io/RexsterEdgeInputFormat.java
4dee078b456723940aeb4d0b3e4555042111744a 
>   giraph-rexster/src/main/java/org/apache/giraph/rexster/io/RexsterVertexInputFormat.java
da45b5b28dc5ba2025bf00f680ebf1f5c92fa4a1 
> 
> Diff: https://reviews.apache.org/r/13306/diff/
> 
> 
> Testing
> -------
> 
> 
> Thanks,
> 
> Nitay Joffe
> 
>


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message