Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Sotera/distributed-graph-analytics
/ functions
Functions
367 in github.com/Sotera/distributed-graph-analytics
⨍
Functions
367
◇
Types & classes
78
↓ 1 callers
Method
calculateBestCommunity
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 callers
Method
calculateQDelta
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 callers
Method
compareHighBetweennessSet
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 callers
Method
createVertexWriter
(TaskAttemptContext context)
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/HBSEOutputFormatTest.java:61
↓ 1 callers
Method
distributeRank
(Vertex<Text, DoubleWritable, Text> vertex)
dga-giraph/src/main/java/com/soteradefense/dga/pr/PageRankComputation.java:78
↓ 1 callers
Method
getActualQ
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMasterCompute.java:109
↓ 1 callers
Method
getAndSendCommunityInfo
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 callers
Method
getBiggerGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/louvain/giraph/LouvainTests.java:115
↓ 1 callers
Method
getChanged
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:82
↓ 1 callers
Method
getCommunitySigmaTotal
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:66
↓ 1 callers
Method
getCurrentGlobalState
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 callers
Method
getCyclicGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/louvain/giraph/LouvainTests.java:105
↓ 1 callers
Method
getDistance
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 callers
Method
getEdgeValueAsString
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 callers
Method
getFirstTestGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/hbse/HBSEComputeTest.java:152
↓ 1 callers
Method
getGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/louvain/giraph/LouvainTests.java:100
↓ 1 callers
Method
getGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/wcc/WeaklyConnectedComponentComputationTest.java:49
↓ 1 callers
Method
getHighBetweennessSet
@return the ids of the stored items, as a set.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessList.java:154
↓ 1 callers
Method
getHighPageRankGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/pr/PageRankTest.java:82
↓ 1 callers
Method
getMaxSize
@return the maxSize of this list.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessList.java:220
↓ 1 callers
Method
getNewHighBetweennessList
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 callers
Method
getPingMessage
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 callers
Method
getPreviousQvalue
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMasterCompute.java:173
↓ 1 callers
Method
getQueue
@return the priority queue backing this list.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessList.java:194
↓ 1 callers
Method
getRandomWithSeed
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 callers
Method
getShortestPathOneTestGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/hbse/HBSEComputeTest.java:133
↓ 1 callers
Method
getSuccessors
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 callers
Method
getTestGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/pr/PageRankTest.java:94
↓ 1 callers
Method
getTwoCriticalPointGraph
(GiraphConfiguration conf)
dga-giraph/src/test/java/com/soteradefense/dga/hbse/HBSEComputeTest.java:112
↓ 1 callers
Method
getVertexValueAsString
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 callers
Method
getWasPivotPoint
()
dga-giraph/src/main/java/com/soteradefense/dga/hbse/VertexData.java:199
↓ 1 callers
Method
getWeight
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainVertexWritable.java:67
↓ 1 callers
Method
initialize
(InputSplit inputSplit, TaskAttemptContext context)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAAbstractEdgeInputFormat.java:89
↓ 1 callers
Method
isComplete
(String path)
dga-giraph/src/main/java/com/soteradefense/dga/LouvainRunner.java:67
↓ 1 callers
Method
isFromLouvainVertexReader
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:102
↓ 1 callers
Method
isPivotPoint
(String id)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEComputation.java:299
↓ 1 callers
Method
isPossiblePivotPoint
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 callers
Method
markPipeLineComplete
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 callers
Method
readFields
(DataInput in)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/ShortestPathList.java:120
↓ 1 callers
Method
readFields
(DataInput in)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PartialDependency.java:125
↓ 1 callers
Method
readFile
(String path)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMasterCompute.java:205
↓ 1 callers
Method
replaceNodeEdgesWithCommunityEdges
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 callers
Method
runUntilComplete
(String inputPath, String outputPath, DGAConfiguration partiallyCoalescedConfiguration)
dga-giraph/src/main/java/com/soteradefense/dga/LouvainRunner.java:73
↓ 1 callers
Method
sendEdges
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 callers
Method
setDependency
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 callers
Method
setDistance
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 callers
Method
setDistance
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 callers
Method
setEdges
(Map<String, Long> edges)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainVertexWritable.java:79
↓ 1 callers
Method
setFrom
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 callers
Method
setFromLouvainVertexReader
(boolean fromLouvainVertexReader)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:106
↓ 1 callers
Method
setInternalWeight
(long internalWeight)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:78
↓ 1 callers
Method
setPredecessorPathCountMap
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 callers
Method
setSourceId
(String sourceId)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMessage.java:85
↓ 1 callers
Method
setWeight
(long weight)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainVertexWritable.java:71
↓ 1 callers
Method
setup
(Context context)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/mapreduce/CommunityCompression.java:97
↓ 1 callers
Method
update
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 callers
Method
updateCommunities
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 callers
Method
validateEdgeValue
(RawEdge edge)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAAbstractEdgeInputFormat.java:114
↓ 1 callers
Method
writeHighBetweennessSet
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 callers
Method
writeQvalue
(String message)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMasterCompute.java:161
↓ 1 callers
Method
writeStats
Writes the various statistics when computation finishes.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEMasterCompute.java:377
Method
BcTuple
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
Method
CommunityCompression
(String inputPath, String outputPath, DGAConfiguration dgaConfiguration)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/mapreduce/CommunityCompression.java:60
Method
DGAConfiguration
()
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:39
Method
ExitException
(int status)
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:40
Method
ExitException
(int status)
dga-giraph/src/test/java/com/soteradefense/dga/DGARunnerExitTests.java:35
Method
HighBetweennessList
Creates a new HighBetweennessList with Max size 1.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessList.java:88
Method
LouvainMessage
(String communityId, long sigmaTotal, long weight, String sourceId)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMessage.java:38
Method
LouvainNodeState
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:53
Method
LouvainRunner
()
dga-giraph/src/main/java/com/soteradefense/dga/LouvainRunner.java:54
Method
LouvainTableSynthesizer
(String basePath, DGAConfiguration dgaConfiguration)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/mapreduce/LouvainTableSynthesizer.java:47
Method
LouvainVertexWritable
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainVertexWritable.java:43
Method
PartialDependency
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
Method
PathData
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
Method
PivotList
()
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PivotList.java:33
Method
RawEdge
(final String delimiter, final String defaultEdgeValue, final boolean ignoreThird)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/RawEdge.java:35
Method
ShortestPathList
Create a new shortest empty Path List
dga-giraph/src/main/java/com/soteradefense/dga/hbse/ShortestPathList.java:52
Method
accept
(File dir, String name)
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:91
Method
aggregate
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
Method
aggregate
(PivotList value)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PivotListAggregator.java:25
Method
checkExit
(int status)
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:59
Method
checkExit
(int status)
dga-giraph/src/test/java/com/soteradefense/dga/DGARunnerExitTests.java:52
Method
checkPermission
(Permission perm)
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:49
Method
checkPermission
(Permission perm)
dga-giraph/src/test/java/com/soteradefense/dga/DGARunnerExitTests.java:42
Method
cleanUp
()
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:185
Method
cleanUp
()
dga-giraph/src/test/java/com/soteradefense/dga/DGARunnerExitTests.java:84
Method
compare
(BcTuple arg0, BcTuple arg1)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessList.java:68
Method
compute
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMasterCompute.java:68
Method
compute
(Vertex<Text, LouvainNodeState, LongWritable> vertex, Iterable<LouvainMessage> messages)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainComputation.java:84
Method
compute
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
Method
compute
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
Method
compute
(Vertex<Text, Text, Text> vertex, Iterable<Text> messages)
dga-giraph/src/main/java/com/soteradefense/dga/wcc/WeaklyConnectedComponentComputation.java:48
Method
compute
(Vertex<Text, Text, Text> vertex, Iterable<Text> messages)
dga-giraph/src/main/java/com/soteradefense/dga/lc/LeafCompressionComputation.java:51
Method
compute
(Vertex<Text, DoubleWritable, Text> vertex, Iterable<DoubleWritable> messages)
dga-giraph/src/main/java/com/soteradefense/dga/pr/PageRankComputation.java:50
Method
compute
()
dga-giraph/src/main/java/com/soteradefense/dga/pr/PageRankMasterCompute.java:40
Method
convertEdgeToLine
(I sourceId, V vertexValue, Edge<I, E> edge)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAAbstractEdgeOutputFormat.java:116
Method
createEdgeReader
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
Method
createEdgeReader
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
Method
createEdgeWriter
(TaskAttemptContext context)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAEdgeTDTOutputFormat.java:31
Method
createEdgeWriter
(TaskAttemptContext context)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAEdgeTTTOutputFormat.java:31
← previous
next →
101–200 of 367, ranked by callers