Documentation
¶
Index ¶
Constants ¶
View Source
const EDGE_FORMAT = "(%d,%d,%d,%v)\n"
EDGE_FORMAT This format is src, label, destination, incoming
View Source
const FILE_FORMAT string = "s_%d_e_%d.csv"
Variables ¶
View Source
var FileTooLarge = fmt.Errorf("File too large to split")
Functions ¶
func RunAdjacencyStage ¶
We separate out the logic for edge reading and writing to file.
EdgeProducer reads edges one by one while also mapping string labels to integers.
Parititioner creates partitions for every edge and adds every edge to its correct partition.
Types ¶
type EdgeProducer ¶
type EdgeProducer struct {
// contains filtered or unexported fields
}
type Partition ¶
type Partition struct {
// contains filtered or unexported fields
}
End is exclusive for all but the last partition.
type Partitioner ¶
type Partitioner []Partition
func (Partitioner) Close ¶
func (p Partitioner) Close()
Source Files
Click to show internal directories.
Click to hide internal directories.