MCPcopy Create free account

hub / github.com/Sotera/distributed-graph-analytics / functions

Functions367 in github.com/Sotera/distributed-graph-analytics

↓ 1 callersMethodcalculateBestCommunity
Based on community of each of its neighbors, each vertex determimnes if it should retain its currenty community or swtich to a neighboring communinity
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainComputation.java:222
↓ 1 callersMethodcalculateQDelta
determine the change in q if a node were to move to the given community. @param currCommunityId @param testCommunityId @param testSigmaTotal @param e
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainComputation.java:289
↓ 1 callersMethodcompareHighBetweennessSet
Find the number of changes in the high betweenness set. Compares the previous run to the newest computation. @param incomingSet A new set of high bet
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEMasterCompute.java:459
↓ 1 callersMethodcreateVertexWriter
(TaskAttemptContext context)
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/HBSEOutputFormatTest.java:61
↓ 1 callersMethoddistributeRank
(Vertex<Text, DoubleWritable, Text> vertex)
dga-giraph/src/main/java/com/soteradefense/dga/pr/PageRankComputation.java:78
↓ 1 callersMethodgetActualQ
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMasterCompute.java:109
↓ 1 callersMethodgetAndSendCommunityInfo
Each vertex will recieve its own communities sigma_total (if updated), and then send its currenty community info to each of its neighbors. @param mes
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainComputation.java:183
↓ 1 callersMethodgetBiggerGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/louvain/giraph/LouvainTests.java:115
↓ 1 callersMethodgetChanged
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:82
↓ 1 callersMethodgetCommunitySigmaTotal
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:66
↓ 1 callersMethodgetCurrentGlobalState
Return the current global state @return State that stores the current global state
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEComputation.java:259
↓ 1 callersMethodgetCyclicGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/louvain/giraph/LouvainTests.java:105
↓ 1 callersMethodgetDistance
Gets the distance from source to a predecessor. @return The distance value.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:155
↓ 1 callersMethodgetEdgeValueAsString
The implementing classes must convert their Writable object into a String that can be appended to the String of text that will become our Text output
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAAbstractEdgeOutputFormat.java:114
↓ 1 callersMethodgetFirstTestGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/hbse/HBSEComputeTest.java:152
↓ 1 callersMethodgetGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/louvain/giraph/LouvainTests.java:100
↓ 1 callersMethodgetGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/wcc/WeaklyConnectedComponentComputationTest.java:49
↓ 1 callersMethodgetHighBetweennessSet
@return the ids of the stored items, as a set.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessList.java:154
↓ 1 callersMethodgetHighPageRankGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/pr/PageRankTest.java:82
↓ 1 callersMethodgetMaxSize
@return the maxSize of this list.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessList.java:220
↓ 1 callersMethodgetNewHighBetweennessList
Get a new HighBetweennessList object, configured with the betweenness.set.maxSize option from the job conf. If not set size will default to 1. @param
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEComputation.java:273
↓ 1 callersMethodgetPingMessage
Get a new PathData message for sending successor / predecessor information to neighbors @param source The source that the ping came from. @return A n
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:105
↓ 1 callersMethodgetPreviousQvalue
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMasterCompute.java:173
↓ 1 callersMethodgetQueue
@return the priority queue backing this list.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessList.java:194
↓ 1 callersMethodgetRandomWithSeed
Gets a Random Object With A possible Seed based on a Configuration. @param name Configuration Key @return Random which is either seeded or not.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEComputation.java:311
↓ 1 callersMethodgetShortestPathOneTestGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/hbse/HBSEComputeTest.java:133
↓ 1 callersMethodgetSuccessors
Gets the number of successors that need to be processed. @return The successors value.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PartialDependency.java:86
↓ 1 callersMethodgetTestGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/pr/PageRankTest.java:94
↓ 1 callersMethodgetTwoCriticalPointGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/hbse/HBSEComputeTest.java:112
↓ 1 callersMethodgetVertexValueAsString
The implementing classes must convert their Writable object into a String that can be appended to the String of text that will become our Text output
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAAbstractEdgeOutputFormat.java:107
↓ 1 callersMethodgetWasPivotPoint
()
dga-giraph/src/main/java/com/soteradefense/dga/hbse/VertexData.java:199
↓ 1 callersMethodgetWeight
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainVertexWritable.java:67
↓ 1 callersMethodinitialize
(InputSplit inputSplit, TaskAttemptContext context)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAAbstractEdgeInputFormat.java:89
↓ 1 callersMethodisComplete
(String path)
dga-giraph/src/main/java/com/soteradefense/dga/LouvainRunner.java:67
↓ 1 callersMethodisFromLouvainVertexReader
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:102
↓ 1 callersMethodisPivotPoint
(String id)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEComputation.java:299
↓ 1 callersMethodisPossiblePivotPoint
Determines if a vertex can be a pivot point. @param id Vertex Id @return True if it is a pivot point.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEComputation.java:290
↓ 1 callersMethodmarkPipeLineComplete
Saves a file in the hdfs output dir to make that computation is complete. Writes final q value to the file. @param message
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMasterCompute.java:151
↓ 1 callersMethodreadFields
(DataInput in)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/ShortestPathList.java:120
↓ 1 callersMethodreadFields
(DataInput in)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PartialDependency.java:125
↓ 1 callersMethodreadFile
(String path)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMasterCompute.java:205
↓ 1 callersMethodreplaceNodeEdgesWithCommunityEdges
Replace each edge to a neighbor with an edge to that neigbors community instead. Done just before exiting computation. In the next state of the piple
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainComputation.java:369
↓ 1 callersMethodrunUntilComplete
(String inputPath, String outputPath, DGAConfiguration partiallyCoalescedConfiguration)
dga-giraph/src/main/java/com/soteradefense/dga/LouvainRunner.java:73
↓ 1 callersMethodsendEdges
Inform each node we are connected to if we only have one edge so that we can be purged from the graph, or vote to halt @param vertex The current vert
dga-giraph/src/main/java/com/soteradefense/dga/lc/LeafCompressionComputation.java:80
↓ 1 callersMethodsetDependency
Sets the dependency value. @param dependency The value to set dependency to.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:218
↓ 1 callersMethodsetDistance
Sets the distance from a source to this vertex. @param distance The distance to set it to.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/ShortestPathList.java:142
↓ 1 callersMethodsetDistance
Sets the distance from a source to a predecessor. @param distance Distance value to set it to.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:164
↓ 1 callersMethodsetEdges
(Map<String, Long> edges)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainVertexWritable.java:79
↓ 1 callersMethodsetFrom
Sets the value of from. @param from The value to set from to.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:200
↓ 1 callersMethodsetFromLouvainVertexReader
(boolean fromLouvainVertexReader)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:106
↓ 1 callersMethodsetInternalWeight
(long internalWeight)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:78
↓ 1 callersMethodsetPredecessorPathCountMap
Sets the Predecessor Path Count Map. @param predPathCountMap The Map to set it to.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/ShortestPathList.java:160
↓ 1 callersMethodsetSourceId
(String sourceId)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMessage.java:85
↓ 1 callersMethodsetWeight
(long weight)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainVertexWritable.java:71
↓ 1 callersMethodsetup
(Context context)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/mapreduce/CommunityCompression.java:97
↓ 1 callersMethodupdate
Update This shortest path list based on a new shortest path message @param data A new path data message. @return true if the ShortestPathList is modi
dga-giraph/src/main/java/com/soteradefense/dga/hbse/ShortestPathList.java:86
↓ 1 callersMethodupdateCommunities
Each community hub aggregates the values from each of its members to update the node's sigma total, and then sends this back to each of its members.
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainComputation.java:317
↓ 1 callersMethodvalidateEdgeValue
(RawEdge edge)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAAbstractEdgeInputFormat.java:114
↓ 1 callersMethodwriteHighBetweennessSet
Write the high betweenness set to a file in hdfs @param set A set of vertices that contain the highest highbetweenness value.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEMasterCompute.java:417
↓ 1 callersMethodwriteQvalue
(String message)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMasterCompute.java:161
↓ 1 callersMethodwriteStats
Writes the various statistics when computation finishes.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEMasterCompute.java:377
MethodBcTuple
Constructor for a New BcTuple @param id Vertex Id @param value Betweenness Value
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessList.java:57
MethodCommunityCompression
(String inputPath, String outputPath, DGAConfiguration dgaConfiguration)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/mapreduce/CommunityCompression.java:60
MethodDGAConfiguration
()
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:39
MethodExitException
(int status)
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:40
MethodExitException
(int status)
dga-giraph/src/test/java/com/soteradefense/dga/DGARunnerExitTests.java:35
MethodHighBetweennessList
Creates a new HighBetweennessList with Max size 1.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessList.java:88
MethodLouvainMessage
(String communityId, long sigmaTotal, long weight, String sourceId)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMessage.java:38
MethodLouvainNodeState
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:53
MethodLouvainRunner
()
dga-giraph/src/main/java/com/soteradefense/dga/LouvainRunner.java:54
MethodLouvainTableSynthesizer
(String basePath, DGAConfiguration dgaConfiguration)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/mapreduce/LouvainTableSynthesizer.java:47
MethodLouvainVertexWritable
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainVertexWritable.java:43
MethodPartialDependency
Default Constructor for a PartialDependency. Dependency and Successors are both set to 0.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PartialDependency.java:48
MethodPathData
The Default Constructor for PathData: <ul> <li>Sets Distance to the Max long value.</li> <li>Sets source to -1.</li> <li>Sets from to -1.</li> <li>Set
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:73
MethodPivotList
()
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PivotList.java:33
MethodRawEdge
(final String delimiter, final String defaultEdgeValue, final boolean ignoreThird)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/RawEdge.java:35
MethodShortestPathList
Create a new shortest empty Path List
dga-giraph/src/main/java/com/soteradefense/dga/hbse/ShortestPathList.java:52
Methodaccept
(File dir, String name)
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:91
Methodaggregate
Takes the old aggregated value and compares it to a new value wanting to be aggregated. @param value New Aggregated Value.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessListAggregator.java:32
Methodaggregate
(PivotList value)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PivotListAggregator.java:25
MethodcheckExit
(int status)
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:59
MethodcheckExit
(int status)
dga-giraph/src/test/java/com/soteradefense/dga/DGARunnerExitTests.java:52
MethodcheckPermission
(Permission perm)
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:49
MethodcheckPermission
(Permission perm)
dga-giraph/src/test/java/com/soteradefense/dga/DGARunnerExitTests.java:42
MethodcleanUp
()
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:185
MethodcleanUp
()
dga-giraph/src/test/java/com/soteradefense/dga/DGARunnerExitTests.java:84
Methodcompare
(BcTuple arg0, BcTuple arg1)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessList.java:68
Methodcompute
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMasterCompute.java:68
Methodcompute
(Vertex<Text, LouvainNodeState, LongWritable> vertex, Iterable<LouvainMessage> messages)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainComputation.java:84
Methodcompute
Coordinates the computation phases of SBVertex by monitoring for the completion of each state and moving to the next state. <ol> <li>selects pivots</l
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEMasterCompute.java:267
Methodcompute
Works in two major stages which are repeated and coordinated by the setting of a global state (set by the master compute class) <p/> <p/> <ul> <li>Sta
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEComputation.java:72
Methodcompute
(Vertex<Text, Text, Text> vertex, Iterable<Text> messages)
dga-giraph/src/main/java/com/soteradefense/dga/wcc/WeaklyConnectedComponentComputation.java:48
Methodcompute
(Vertex<Text, Text, Text> vertex, Iterable<Text> messages)
dga-giraph/src/main/java/com/soteradefense/dga/lc/LeafCompressionComputation.java:51
Methodcompute
(Vertex<Text, DoubleWritable, Text> vertex, Iterable<DoubleWritable> messages)
dga-giraph/src/main/java/com/soteradefense/dga/pr/PageRankComputation.java:50
Methodcompute
()
dga-giraph/src/main/java/com/soteradefense/dga/pr/PageRankMasterCompute.java:40
MethodconvertEdgeToLine
(I sourceId, V vertexValue, Edge<I, E> edge)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAAbstractEdgeOutputFormat.java:116
MethodcreateEdgeReader
The create edge reader first determines if we should reverse each edge; some data sets are undirected graphs and need the input format to reverse thei
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGATextEdgeValueInputFormat.java:47
MethodcreateEdgeReader
The create edge reader first determines if we should reverse each edge; some data sets are undirected graphs and need the input format to reverse thei
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGALongEdgeValueInputFormat.java:47
MethodcreateEdgeWriter
(TaskAttemptContext context)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAEdgeTDTOutputFormat.java:31
MethodcreateEdgeWriter
(TaskAttemptContext context)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAEdgeTTTOutputFormat.java:31
← previousnext →101–200 of 367, ranked by callers