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
Method
createInitialValue
Creates an Initial HighBetweennessList @return A New HighBetweennessList.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessListAggregator.java:42
Method
createInitialValue
()
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PivotListAggregator.java:31
Method
createLineRecordReader
(InputSplit inputSplit, TaskAttemptContext context)
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGATextEdgeValueInputFormatTest.java:57
Method
createLineRecordReader
(InputSplit inputSplit, TaskAttemptContext context)
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGALongEdgeValueInputFormatTest.java:59
Method
createLineRecordWriter
( TaskAttemptContext context)
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/HBSEOutputFormatTest.java:65
Method
createLineRecordWriter
(TaskAttemptContext context)
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGAEdgeTDTOutputFormatTest.java:81
Method
createLineRecordWriter
(TaskAttemptContext context)
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGAEdgeTTTOutputFormatTest.java:81
Method
createVertexReader
(InputSplit inputSplit, TaskAttemptContext taskAttemptContext)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/LouvainVertexInputFormat.java:51
Method
createVertexWriter
(TaskAttemptContext context)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/HBSEOutputFormat.java:34
Method
createVertexWriter
(TaskAttemptContext context)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAVertexOutputFormat.java:30
Method
createVertexWriter
(TaskAttemptContext arg0)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/LouvainVertexOutputFormat.java:42
Method
getCurrentVertex
()
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/LouvainVertexInputFormat.java:59
Method
getDefaultEdgeValue
()
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGATextEdgeValueInputFormat.java:56
Method
getDefaultEdgeValue
()
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGALongEdgeValueInputFormat.java:56
Method
getEdgeValueAsString
(Text edgeValue)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAEdgeTDTOutputFormat.java:47
Method
getEdgeValueAsString
(Text edgeValue)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAEdgeTTTOutputFormat.java:47
Method
getSourceVertexId
(RawEdge edge)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAAbstractEdgeInputFormat.java:121
Method
getValue
(RawEdge edge)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGALongEdgeValueInputFormat.java:68
Method
getVertexValueAsString
(DoubleWritable vertexValue)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAEdgeTDTOutputFormat.java:42
Method
getVertexValueAsString
(Text vertexValue)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAEdgeTTTOutputFormat.java:42
Method
initialize
()
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMasterCompute.java:59
Method
initialize
(GraphState graphState, WorkerClientRequestProcessor<Text, LouvainNodeState, LongWritable> workerClientRequest
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainComputation.java:78
Method
initialize
Read options from configuration file and set up aggregators (global communication) @throws InstantiationException if it is unable to register an aggr
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HBSEMasterCompute.java:161
Method
initialize
(GraphState graphState, WorkerClientRequestProcessor<Text, Text, Text> workerClientRequestProcessor, Centraliz
dga-giraph/src/main/java/com/soteradefense/dga/wcc/WeaklyConnectedComponentComputation.java:42
Method
initialize
Upon intialization, determines the field separator and default weight to use from the GiraphConfiguration @param context @throws java.io.IOException
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAAbstractEdgeOutputFormat.java:94
Method
initialize
(GraphState graphState, WorkerClientRequestProcessor<Text, Text, Text> workerClientRequestProcessor, Centraliz
dga-giraph/src/main/java/com/soteradefense/dga/lc/LeafCompressionComputation.java:45
Method
initialize
(GraphState graphState, WorkerClientRequestProcessor<Text, DoubleWritable, Text> workerClientRequestProcessor,
dga-giraph/src/main/java/com/soteradefense/dga/pr/PageRankComputation.java:44
Method
initialize
()
dga-giraph/src/main/java/com/soteradefense/dga/pr/PageRankMasterCompute.java:33
Method
main
(final String [] args)
dga-giraph/src/main/java/com/soteradefense/dga/DGAYarnRunner.java:26
Method
map
(LongWritable key, Text value, Context context)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/mapreduce/CommunityCompression.java:103
Method
map
(LongWritable key, Text value, Context context)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/mapreduce/LouvainTableSynthesizerMapper.java:35
Method
nextVertex
()
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/LouvainVertexInputFormat.java:113
Method
preprocessLine
(Text line)
dga-giraph/src/main/java/com/soteradefense/dga/io/formats/DGAAbstractEdgeInputFormat.java:104
Method
readFields
(DataInput in)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainMessage.java:89
Method
readFields
(DataInput in)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainVertexWritable.java:83
Method
readFields
(DataInput in)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/giraph/LouvainNodeState.java:110
Method
readFields
Read fields
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessList.java:181
Method
readFields
(DataInput in)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PathData.java:137
Method
readFields
(DataInput dataInput)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PivotList.java:56
Method
readFields
(DataInput in)
dga-giraph/src/main/java/com/soteradefense/dga/hbse/VertexData.java:118
Method
reduce
(Text key, Iterable<Text> values, Context context)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/mapreduce/LouvainTableSynthesizerReducer.java:35
Method
reduce
(Text key, Iterable<LouvainVertexWritable> values, Context context)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/mapreduce/CommunityCompression.java:127
Method
run
()
dga-giraph/src/main/java/com/soteradefense/dga/DGAYarnRunner.java:29
Method
run
(String[] args)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/mapreduce/LouvainTableSynthesizer.java:52
Method
run
(String[] args)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/mapreduce/CommunityCompression.java:66
Method
runMapreduceJob
(String inputPath, String outputPath, DGAConfiguration conf)
dga-giraph/src/main/java/com/soteradefense/dga/LouvainRunner.java:134
Method
setDependency
Sets the dependency value. @param dependency The value to set dependency to.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PartialDependency.java:77
Method
setMaxSize
Set the maxSize of this list @param maxSize The maximum size of the priority queue.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/HighBetweennessList.java:230
Method
setPartialDepMap
Sets the Partial Dependency Map @param partialDepMap The Partial Dependency map to set it to.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/VertexData.java:158
Method
setPathDataMap
Sets the path data map. @param pathDataMap The path data map to set it to.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/VertexData.java:194
Method
setSuccessors
Sets the number of successors. @param successors The value to set successors to.
dga-giraph/src/main/java/com/soteradefense/dga/hbse/PartialDependency.java:95
Method
setUp
()
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:68
Method
setUp
()
dga-giraph/src/test/java/com/soteradefense/dga/DGARunnerExitTests.java:58
Method
setUp
()
dga-giraph/src/test/java/com/soteradefense/dga/louvain/mapreduce/LouvainTableSynthesizerTest.java:41
Method
setUp
()
dga-giraph/src/test/java/com/soteradefense/dga/louvain/mapreduce/CommunityCompressionTest.java:38
Method
setUp
()
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGATextEdgeValueInputFormatTest.java:44
Method
setUp
()
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGALongEdgeValueInputFormatTest.java:46
Method
setUp
()
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/HBSEOutputFormatTest.java:45
Method
setUp
()
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGAEdgeTDTOutputFormatTest.java:50
Method
setUp
()
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGAEdgeTTTOutputFormatTest.java:49
Method
setUp
()
dga-giraph/src/test/java/com/soteradefense/dga/lc/LeafCompressionComputationTest.java:43
Method
setup
()
dga-giraph/src/test/java/com/soteradefense/dga/DGAConfigurationTest.java:35
Method
setup
(Context context)
dga-giraph/src/main/java/com/soteradefense/dga/louvain/mapreduce/CommunityCompression.java:121
Method
testActualTextNodes
()
dga-giraph/src/test/java/com/soteradefense/dga/lc/LeafCompressionComputationTest.java:154
Method
testAllAllowedGiraphProperties
()
dga-giraph/src/test/java/com/soteradefense/dga/DGAConfigurationTest.java:113
Method
testAllGiraphPropertiesThatCanBePresent
()
dga-giraph/src/test/java/com/soteradefense/dga/DGAXMLConfigurationParserTest.java:264
Method
testBadCommandLineArguments
()
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:74
Method
testBadCommandLineArguments1
()
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:81
Method
testBadCommandLineArguments2
()
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:90
Method
testBadCommandLineArguments3
()
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:97
Method
testBadCommandLineArguments4
()
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:106
Method
testBadCommandLineArguments5
()
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:115
Method
testBadData
()
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/RawEdgeTest.java:59
Method
testBadXML
()
dga-giraph/src/test/java/com/soteradefense/dga/DGAXMLConfigurationParserTest.java:67
Method
testBiggerGraph
()
dga-giraph/src/test/java/com/soteradefense/dga/louvain/giraph/LouvainTests.java:61
Method
testCACommandNoSpace
()
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:155
Method
testCoalesce
()
dga-giraph/src/test/java/com/soteradefense/dga/DGAConfigurationTest.java:59
Method
testComputationGoodData
()
dga-giraph/src/test/java/com/soteradefense/dga/lc/LeafCompressionComputationTest.java:51
Method
testComputationUnconnectedGraph
()
dga-giraph/src/test/java/com/soteradefense/dga/lc/LeafCompressionComputationTest.java:131
Method
testComputeOutput
()
dga-giraph/src/test/java/com/soteradefense/dga/hbse/HBSEComputeTest.java:47
Method
testComputeOutput
()
dga-giraph/src/test/java/com/soteradefense/dga/wcc/WeaklyConnectedComponentComputationTest.java:32
Method
testCustomDelimiter
()
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:133
Method
testCyclicGraph
()
dga-giraph/src/test/java/com/soteradefense/dga/louvain/giraph/LouvainTests.java:87
Method
testDCommandNoSpace
()
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:143
Method
testDisallowedGiraphProperties
()
dga-giraph/src/test/java/com/soteradefense/dga/DGAXMLConfigurationParserTest.java:223
Method
testDisallowedGiraphProperties
()
dga-giraph/src/test/java/com/soteradefense/dga/DGAConfigurationTest.java:107
Method
testEmptyFields
()
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/RawEdgeTest.java:66
Method
testEqualPageRankForSevenNodes
()
dga-giraph/src/test/java/com/soteradefense/dga/pr/PageRankTest.java:45
Method
testForDefault
()
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/RawEdgeTest.java:83
Method
testGenerateArguments
()
dga-giraph/src/test/java/com/soteradefense/dga/DGAConfigurationTest.java:123
Method
testGoodCommandLineArguments
()
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:124
Method
testGoodData
()
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/RawEdgeTest.java:32
Method
testGoodXML
()
dga-giraph/src/test/java/com/soteradefense/dga/DGAXMLConfigurationParserTest.java:30
Method
testGraphWithShortestPathOne
()
dga-giraph/src/test/java/com/soteradefense/dga/hbse/HBSEComputeTest.java:65
Method
testGraphWriteWithEmptyEdgeWeight
()
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGAEdgeTDTOutputFormatTest.java:179
Method
testGraphWriteWithEmptyEdgeWeight
()
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGAEdgeTTTOutputFormatTest.java:131
Method
testGraphWriteWithEmptyEdgeWeightAndOverriddenDelimiter
()
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGAEdgeTDTOutputFormatTest.java:196
Method
testGraphWriteWithEmptyEdgeWeightAndOverriddenDelimiter
()
dga-giraph/src/test/java/com/soteradefense/dga/io/formats/DGAEdgeTTTOutputFormatTest.java:148
Method
testHBSEDefaults
()
dga-giraph/src/test/java/com/soteradefense/dga/DGARunnerTests.java:73
Method
testHelpCommand
()
dga-giraph/src/test/java/com/soteradefense/dga/DGACommandLineUtilTest.java:167
← previous
next →
201–300 of 367, ranked by callers