Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- case object EdgePartition1D extends PartitionStrategy {
- override def getPartition(src: VertexId, dst: VertexId, numParts: PartitionID): PartitionID = {
- val mixingPrime: VertexId = 1125899906842597L
- (math.abs(src * mixingPrime) % numParts).toInt
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement