MCPcopy Create free account

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

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

⨍ Functions 367◇ Types & classes 78
↓ 195 callersMethodgetValue
(RawEdge edge)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGATextEdgeValueInputFormat.java:65
↓ 59 callersMethodtoString
Return a string representation of the list.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessList.java:202
↓ 57 callersMethodequals
(Object obj)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainVertexWritable.java:47
↓ 44 callersMethodwrite
(DataOutput out)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:127
↓ 41 callersMethodgetConf
()
dga-giraph/src/test/java/com/soteradefense/dga/pr/PageRankTest.java:36
↓ 37 callersMethodsetDGAGiraphProperty
(String key, String value)
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:53
↓ 36 callersMethodgetTargetVertexId
(RawEdge edge)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAAbstractEdgeInputFormat.java:116
↓ 36 callersMethodinitialize
(GraphState graphState, WorkerClientRequestProcessor<Text, VertexData, Text> workerClientRequestProcessor, Cen
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEComputation.java:56
↓ 34 callersMethodgetApproxBetweenness
Gets the Approx Betweenness Value @return The approx betweenness value.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/VertexData.java:167
↓ 34 callersMethodgetCommunity
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:58
↓ 30 callersMethodgetCustomArgumentProperties
()
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:69
↓ 30 callersMethodgetGiraphProperties
()
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:65
↓ 19 callersMethodrun
(String[] args)
dga-giraph/src/main/java/com/soteradefense/dga/DGARunner.java:54
↓ 16 callersMethodsetCustomProperty
(String key, String value)
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:57
↓ 16 callersMethodsetDGALogLevel
(Configuration conf)
dga-giraph/src/main/java/com/soteradefense/dga/DGALoggingUtil.java:31
↓ 14 callersMethodgetSystemProperties
()
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:73
↓ 13 callersMethodconvertToCommandLineArguments
(String computationClassName)
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:120
↓ 13 callersMethodgenerateOptions
()
dga-giraph/src/main/java/com/soteradefense/dga/DGACommandLineUtil.java:52
↓ 13 callersMethodparseCommandLine
(String[] args, Options options)
dga-giraph/src/main/java/com/soteradefense/dga/DGACommandLineUtil.java:64
↓ 13 callersMethodsetGiraphProperty
(String key, String value)
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:45
↓ 11 callersMethodcoalesce
This method returns a new DGAConfiguration object containing the resulting coalescing activity of all provided DGAConfigurations The order of the conf
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:187
↓ 10 callersMethodaggregate
(PivotList other)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PivotList.java:43
↓ 10 callersMethodcreateEdgeReader
(final RecordReader<LongWritable,Text> rr)
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGATextEdgeValueInputFormatTest.java:55
↓ 10 callersMethodgetEdgeValue
()
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/RawEdge.java:66
↓ 10 callersMethodgetEdges
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainVertexWritable.java:75
↓ 10 callersMethodparse
(InputStream is)
dga-giraph/src/main/java/com/soteradefense/dga/DGAXMLConfigurationParser.java:42
↓ 9 callersMethodcreateEdgeReader
(final RecordReader<LongWritable,Text> rr)
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGALongEdgeValueInputFormatTest.java:57
↓ 9 callersMethodfromText
(final Text line)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/RawEdge.java:47
↓ 9 callersMethodgetCommunityId
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMessage.java:53
↓ 8 callersMethodcheckConnectionsFromVertex
(TestGraph graph, String vertex, String ... edges)
dga-giraph/src/test/java/com/soteradefense/dga/lc/LeafCompressionComputationTest.java:121
↓ 8 callersMethodcreateEdgeWriter
(final RecordWriter<Text, Text> rw)
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGAEdgeTDTOutputFormatTest.java:79
↓ 8 callersMethodcreateEdgeWriter
(final RecordWriter<Text, Text> rw)
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGAEdgeTTTOutputFormatTest.java:79
↓ 8 callersMethodgetPathDataMap
Gets the Path Data Map. @return The path data map.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/VertexData.java:185
↓ 8 callersMethodsetGlobalState
Set the value of the state aggregator @param state The current state of computation.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEMasterCompute.java:447
↓ 8 callersMethodsetLibDir
(String libDir)
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:77
↓ 8 callersMethodtoString
()
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:147
↓ 7 callersMethodgetInternalWeight
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:74
↓ 7 callersMethodmain
(String[] args)
dga-giraph/src/main/java/com/soteradefense/dga/DGARunner.java:172
↓ 6 callersMethodgetEdgeWeight
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMessage.java:73
↓ 6 callersMethodgetFrom
Gets the predecessor/successor value. @return The value of from.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:191
↓ 6 callersMethodgetNumPaths
Gets the number of shortest paths. @return The value in numPaths.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:227
↓ 6 callersMethodgetSourceId
()
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/RawEdge.java:58
↓ 6 callersMethodgetTargetId
()
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/RawEdge.java:62
↓ 6 callersMethodtrim
(int totalLength)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PivotList.java:70
↓ 5 callersMethodgetCommunitySigmaTotal
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMessage.java:61
↓ 5 callersMethodgetDistance
@return The distance from a source to this vertex.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/ShortestPathList.java:133
↓ 5 callersMethodgetPivots
()
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PivotList.java:66
↓ 5 callersMethodsetCommunity
(String community)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:62
↓ 5 callersMethodsetSystemProperty
(String key, String value)
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:61
↓ 5 callersMethodwrite
(DataOutput out)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMessage.java:97
↓ 4 callersMethodargsExistInArray
(String[] args, String key, String value)
dga-giraph/src/test/java/com/soteradefense/dga/DGAConfigurationTest.java:147
↓ 4 callersMethodgetNodeWeight
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:94
↓ 4 callersMethodgetSource
Gets the source value. @return The source value.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:173
↓ 3 callersMethodbuildLibJarsFromLibPath
()
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:85
↓ 3 callersMethodfromTokens
(String weight, String edges)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainVertexWritable.java:104
↓ 3 callersMethodgetConf
()
dga-giraph/src/test/java/com/soteradefense/dga/louvain/giraph/LouvainTests.java:36
↓ 3 callersMethodgetConf
()
dga-giraph/src/test/java/com/soteradefense/dga/hbse/HBSEComputeTest.java:33
↓ 3 callersMethodgetDefaultFS
Get the default file system. used to create a valid hdfs path @param conf Configuration for the current job. @return the default hdfs file system.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEMasterCompute.java:475
↓ 3 callersMethodgetLibDir
()
dga-giraph/src/main/java/com/soteradefense/dga/DGAConfiguration.java:81
↓ 3 callersMethodgetOptionalHBSEConfiguration
Gets an optional configuration value and only logs a NumberFormatException. @param name The configuration name to get. @param defaultValue Th
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEMasterCompute.java:243
↓ 3 callersMethodgetPredecessorPathCountMap
Gets the Predecessor Count Map. @return The HashMap
dga-giraph/src/main/java/com/soteradefense/dga/hbse/ShortestPathList.java:151
↓ 3 callersMethodgetShortestPathCount
@return The number of shortest paths from source to this vertex
dga-giraph/src/main/java/com/soteradefense/dga/hbse/ShortestPathList.java:72
↓ 3 callersMethodgetShortestPathMessage
Get a new PathData message for shortest path computation. @param source The source Id @param from The predecessor Id. @param distance The dista
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:90
↓ 3 callersMethodgetSourceId
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMessage.java:81
↓ 3 callersMethodgetVertexValue
Converts a vertex value from a string to an int. @param value vertex value as a string. @return integer vertex value.
dga-giraph/src/main/java/com/soteradefense/dga/lc/LeafCompressionComputation.java:102
↓ 3 callersMethodprintUsageAndExit
(Options options)
dga-giraph/src/main/java/com/soteradefense/dga/DGACommandLineUtil.java:35
↓ 3 callersMethodsetApproxBetweenness
Sets the Approx. Betweenness value. @param approxBetweenness The approx. value to set it to.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/VertexData.java:176
↓ 3 callersMethodsetCommunitySigmaTotal
(long communitySigmaTotal)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:70
↓ 3 callersMethodsetEdgeWeight
(long edgeWeight)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMessage.java:77
↓ 3 callersMethodsetNodeWeight
(long nodeWeight)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:98
↓ 3 callersMethodsetSource
Sets the source value. @param source The value to set the source to.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:182
↓ 2 callersMethodaddPartialDep
Updates pair dependency data @param src The source vertex @param dep The partial dependency value of this vertex on the source
dga-giraph/src/main/java/com/soteradefense/dga/hbse/VertexData.java:87
↓ 2 callersMethodaddPathData
Add the new path to the list of shortest paths, if it is indeed a shortest path @param data A shortest path message @return The updated ShortestPathL
dga-giraph/src/main/java/com/soteradefense/dga/hbse/VertexData.java:64
↓ 2 callersMethodaggregateQ
(Double q)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainComputation.java:74
↓ 2 callersMethodareAllPivotsSelected
(int numberOfPivots)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEMasterCompute.java:479
↓ 2 callersMethodbroadcastUpdates
Sends a message to all neighbors if the greatest value has changed. @param vertex The current vertex. @param changed Has the greatest value changed?
dga-giraph/src/main/java/com/soteradefense/dga/wcc/WeaklyConnectedComponentComputation.java:94
↓ 2 callersMethodcalculateActualQ
Calculate this nodes contribution for the actual q value of the graph.
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainComputation.java:335
↓ 2 callersMethoddecideToHalt
Determine if progress is still being made or if the computation should halt. @param history @return
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMasterCompute.java:122
↓ 2 callersMethodgetChangeHistory
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:90
↓ 2 callersMethodgetDefaultEdgeValue
()
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAAbstractEdgeInputFormat.java:112
↓ 2 callersMethodgetDependency
Gets the dependency value. @return The value in dependency.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:209
↓ 2 callersMethodgetDependency
Gets the dependency. @return The dependency value.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PartialDependency.java:68
↓ 2 callersMethodgetDependencyMessage
Get a new PathData message for accumulating pair dependency values @param source The source that the ping came from. @param dependency The pair d
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:119
↓ 2 callersMethodgetEdgeValue
Parses the Edge Value from a string. @param s Edge value as a string @return long edge value
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEComputation.java:244
↓ 2 callersMethodgetPartialDependencyMap
Gets the Partial Dependency Map @return The Partial Dependency Map
dga-giraph/src/main/java/com/soteradefense/dga/hbse/VertexData.java:149
↓ 2 callersMethodgetRequiredHBSEConfiguration
Gets a Require Configuration value. @param name The configuration name to get. @return A valid integer @throws java.lang.NumberFormatException if it
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEMasterCompute.java:226
↓ 2 callersMethodgetTotalEdgeWeight
Get the total edge weight of the graph. @return 2 the total graph weight.
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainComputation.java:172
↓ 2 callersMethodsetChanged
(long changed)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:86
↓ 2 callersMethodsetCommunityId
(String l)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMessage.java:57
↓ 2 callersMethodsetCommunitySigmaTotal
(long communitySigmaTotal)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMessage.java:65
↓ 2 callersMethodsetNumPaths
Set the number of paths. @param numPaths The value to set numPaths to.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:236
↓ 2 callersMethodsetWasPivotPoint
(boolean wasPivotPoint)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/VertexData.java:203
↓ 2 callersMethodwriteFile
(String path, String message)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMasterCompute.java:190
↓ 2 callersMethodwriteVertex
Writes a Vertex @param vertex Vertex to Write @throws IOException @throws InterruptedException
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/HBSEOutputFormat.java:52
↓ 1 callersMethodaddDependency
Add to the accumulated dependency value by a delta @param diff Value to accumulate by.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PartialDependency.java:114
↓ 1 callersMethodaddSuccessors
Update the successor count by a delta @param diff Value to increase the successors by.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PartialDependency.java:105
↓ 1 callersMethodaddToSigmaTotal
(long partial)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMessage.java:69
↓ 1 callersMethodaggregate
Add items from other to this. Keeping only the top N (maxSize) items. @param other Another Highbetweenness set.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessList.java:132
↓ 1 callersMethodbroadcastGreatestNeighbor
Only called during the first superstep. For Each Edge, find the one who has the greatest id and broadcast that to all neighbors. @param vertex The cu
dga-giraph/src/main/java/com/soteradefense/dga/wcc/WeaklyConnectedComponentComputation.java:76
↓ 1 callersMethodbuildLookup
(Vertex<Text, Text, Text> vertex)
dga-giraph/src/test/java/com/soteradefense/dga/lc/LeafCompressionComputationTest.java:106
next →1–100 of 367, ranked by callers