A B C D E F G H I J K L M N O P R S T U V W X Y Z

A

add(int) - Method in class pegasus.mapreduce.common.cache.BitSet

addTo(int, V) - Method in class pegasus.mapreduce.common.cache.BaseVectorCache

addTo(int, BitStrings) - Method in class pegasus.mapreduce.common.cache.BitStringsVectorCache

addTo(int, DoubleWritable) - Method in class pegasus.mapreduce.common.cache.DoubleVectorCache

addTo(int, V) - Method in interface pegasus.mapreduce.common.cache.VectorCache

addTo(long, int) - Method in class pegasus.mapreduce.common.types.LongIntPairMapWritable

AdjacencyListEdgeDelimiter - Static variable in class pegasus.mapreduce.common.Constants

AdjacencyListRecordReader(String, String) - Constructor for class pegasus.mapreduce.common.io.UnweightedAdjacencyListInputFormat.AdjacencyListRecordReader

AdjacencyListVertexDelimiter - Static variable in class pegasus.mapreduce.common.Constants

applyOp(int, VectorCache<V>, VectorCache<PV>) - Method in class pegasus.mapreduce.common.computation.ComputationMapper

applyOp(int, VectorCache<BitStrings>, VectorCache<BitStrings>) - Method in class pegasus.mapreduce.diameter.DiameterComputation.DiameterMapper

applyOp(int, VectorCache<DoubleWritable>, VectorCache<DoubleWritable>) - Method in class pegasus.mapreduce.pagerank.PageRankComputation.PageRankMapper

applyOp(int, VectorCache<DoubleWritable>, VectorCache<DoubleWritable>) - Method in class pegasus.mapreduce.sssp.SSSPComputation.SSSPMapper

availableMemoryBytes() - Static method in class pegasus.mapreduce.common.utils.MemoryUtils

Returns the available heap size in bytes.

availableMemoryBytes(boolean) - Static method in class pegasus.mapreduce.subgraph.PSE.SubgraphEnumerationMapper

availableMemoryBytes(boolean) - Static method in class pegasus.mapreduce.subgraph.VF2_degree

availableMemoryBytes(boolean) - Static method in class pegasus.mapreduce.triangle.deprecated.PTE_cd.TriangleEnumerationMapper

availableMemoryBytes(boolean) - Static method in class pegasus.mapreduce.triangle.PTE.TriangleCountingMapper

calculate available memory

B

Barrier - Interface in pegasus.mapreduce.common.coordination

BarrierRoot - Static variable in class pegasus.mapreduce.common.Constants

BaseMatrixCache<M extends org.apache.hadoop.io.Writable> - Class in pegasus.mapreduce.common.cache

Represents a matrix block contains matrix elements.

BaseMatrixCache(String, Configuration, int, int, int) - Constructor for class pegasus.mapreduce.common.cache.BaseMatrixCache

BaseMatrixIterator<V extends org.apache.hadoop.io.Writable> - Class in pegasus.mapreduce.common.cache

Iterates over all elements in the given matrix block.

BaseMatrixIterator(Path, Configuration) - Constructor for class pegasus.mapreduce.common.cache.BaseMatrixIterator

BaseMatrixOutputFormat<V> - Class in pegasus.mapreduce.common.io

BaseMatrixOutputFormat() - Constructor for class pegasus.mapreduce.common.io.BaseMatrixOutputFormat

BaseMatrixOutputFormat.OutputConfig - Class in pegasus.mapreduce.common.io

BaseVectorCache<V extends org.apache.hadoop.io.Writable> - Class in pegasus.mapreduce.common.cache

BaseVectorCache(int, int, long) - Constructor for class pegasus.mapreduce.common.cache.BaseVectorCache

begin() - Method in class pegasus.mapreduce.common.types.IntArrayWritable

begin() - Method in class pegasus.mapreduce.common.types.IntDoublePairArrayWritable

begin() - Method in class pegasus.mapreduce.common.types.LongArrayWritable

begin() - Method in class pegasus.mapreduce.common.types.LongDoublePairArrayWritable

BitSet - Class in pegasus.mapreduce.common.cache

BitSet(int) - Constructor for class pegasus.mapreduce.common.cache.BitSet

BitStrings - Class in pegasus.mapreduce.common.types

Represents multiple (typically, 32) bitstrings.

BitStrings() - Constructor for class pegasus.mapreduce.common.types.BitStrings

Construct bitstrings with empty values.

BitStrings(long[]) - Constructor for class pegasus.mapreduce.common.types.BitStrings

Construct bitstring with given bit values.

BitStringsVectorCache - Class in pegasus.mapreduce.common.cache

Represents a vector block contains bitstring values.

BitStringsVectorCache(int, int, long, BitStrings) - Constructor for class pegasus.mapreduce.common.cache.BitStringsVectorCache

blockId - Variable in class pegasus.mapreduce.common.cache.BaseVectorCache

blockId(FileSplit) - Static method in class pegasus.mapreduce.common.io.ComputationTaskSplit

bytesToMebibytes(long) - Static method in class pegasus.mapreduce.common.utils.MemoryUtils

Converts the given memory size from bytes to mebibytes.

C

callGCMultipleTimes() - Static method in class pegasus.mapreduce.common.utils.MemoryUtils

Call garbage collector 5 times explicitly.

callGCMultipleTimes(int) - Static method in class pegasus.mapreduce.common.utils.MemoryUtils

Call garbage collector explicitly.

cardinality() - Method in class pegasus.mapreduce.common.types.BitStrings

Returns the cardinality of bitstrings using Flajolet-Martin method.

ccSize - Variable in class pegasus.mapreduce.cc.old.PALargeStarOpt

cleanup(Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.old.PALargeStarOpt.ColorLargeStarReducer

cleanup(Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.old.PASmallStarOpt.ColorSmallStarReducer

cleanup(Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.PALargeStarOpt.ColorLargeStarReducer

cleanup(Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.PASmallStarOpt.PASmallStarReducer

cleanup after execution.

cleanup() - Method in interface pegasus.mapreduce.common.coordination.Barrier

Cleanups this barrier.

cleanup(TaskAttemptContext) - Method in class pegasus.mapreduce.common.coordination.CoordinationService

cleanup() - Method in class pegasus.mapreduce.common.coordination.MutexBarrier

cleanup() - Method in class pegasus.mapreduce.common.coordination.SemaphoreBarrier

cleanup(Reducer<LongWritable, IV, IntWritable, OV>.Context) - Method in class pegasus.mapreduce.common.prepartitioning.GraphPrepartitioningReducer

cleanup(Reducer<LongWritable, IntDoublePairWritable, LongWritable, IntWritable>.Context) - Method in class pegasus.mapreduce.diameter.DiameterComputation.RadiiReducer

cleanup(Mapper<Object, Text, ShortWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.subgraph.PrePartition.PGMapper

Cleanup after execution.

cleanup(Mapper<LongWritable, LongWritable, ShortWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.triangle.PrePartition.PGMapper

Cleanup after execution.

cleanupComputation(Mapper<NullWritable, NullWritable, LongWritable, OV>.Context, CoordinationService) - Method in class pegasus.mapreduce.common.computation.ComputationMapper

cleanupComputation(Mapper<NullWritable, NullWritable, LongWritable, DoubleWritable>.Context, CoordinationService) - Method in class pegasus.mapreduce.pagerank.PageRankComputation.PageRankMapper

clear() - Method in class pegasus.mapreduce.common.cache.BaseVectorCache

clear() - Method in class pegasus.mapreduce.common.cache.BitSet

clear() - Method in class pegasus.mapreduce.common.cache.BitStringsVectorCache

clear() - Method in class pegasus.mapreduce.common.cache.DoubleVectorCache

clear() - Method in interface pegasus.mapreduce.common.cache.VectorCache

clear() - Method in class pegasus.mapreduce.common.types.LongIntPairMapWritable

close() - Method in class pegasus.mapreduce.common.cache.BaseMatrixIterator

close() - Method in class pegasus.mapreduce.common.io.DirectReader

close() - Method in class pegasus.mapreduce.common.io.DirectWriter

close() - Method in class pegasus.mapreduce.common.io.MatrixRecordReader

close() - Method in class pegasus.mapreduce.common.io.UnweightedAdjacencyListInputFormat.AdjacencyListRecordReader

close() - Method in class pegasus.mapreduce.common.io.UnweightedEdgeListInputFormat.EdgeRecordReader

close(TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.UnweightedMatrixOutputFormat.MultiBlockWriter

close() - Method in class pegasus.mapreduce.common.io.VectorRecordReader

close(TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.VectorRecordWriter

close() - Method in class pegasus.mapreduce.common.io.WeightedEdgeListInputFormat.EdgeRecordReader

close(TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.WeightedMatrixOutputFormat.MultiBlockWriter

col - Variable in class pegasus.mapreduce.common.cache.BaseMatrixCache

col - Variable in class pegasus.mapreduce.common.types.ColumnEntry

col - Variable in class pegasus.mapreduce.common.types.WeightedColumnEntry

colList - Variable in class pegasus.mapreduce.common.cache.BaseMatrixCache

ColorLargeStarCombiner() - Constructor for class pegasus.mapreduce.cc.PALargeStarOpt.ColorLargeStarCombiner

ColorLargeStarMapper() - Constructor for class pegasus.mapreduce.cc.old.PALargeStarOpt.ColorLargeStarMapper

ColorLargeStarMapper() - Constructor for class pegasus.mapreduce.cc.PALargeStarOpt.ColorLargeStarMapper

ColorLargeStarReducer() - Constructor for class pegasus.mapreduce.cc.old.PALargeStarOpt.ColorLargeStarReducer

ColorLargeStarReducer() - Constructor for class pegasus.mapreduce.cc.PALargeStarOpt.ColorLargeStarReducer

ColorSmallStarCombiner() - Constructor for class pegasus.mapreduce.cc.old.PASmallStarOpt.ColorSmallStarCombiner

ColorSmallStarMapper() - Constructor for class pegasus.mapreduce.cc.old.PASmallStarOpt.ColorSmallStarMapper

ColorSmallStarReducer() - Constructor for class pegasus.mapreduce.cc.old.PASmallStarOpt.ColorSmallStarReducer

ColumnEntry - Class in pegasus.mapreduce.common.types

ColumnEntry() - Constructor for class pegasus.mapreduce.common.types.ColumnEntry

combine2Op(int, MatrixCache<M>, VectorCache<V>, VectorCache<PV>) - Method in class pegasus.mapreduce.common.computation.ComputationMapper

combine2Op(int, MatrixCache<IntArrayWritable>, VectorCache<BitStrings>, VectorCache<BitStrings>) - Method in class pegasus.mapreduce.diameter.DiameterComputation.DiameterMapper

combine2Op(int, MatrixCache<IntArrayWritable>, VectorCache<DoubleWritable>, VectorCache<DoubleWritable>) - Method in class pegasus.mapreduce.pagerank.PageRankComputation.PageRankMapper

combine2Op(int, MatrixCache<IntDoublePairArrayWritable>, VectorCache<DoubleWritable>, VectorCache<DoubleWritable>) - Method in class pegasus.mapreduce.sssp.SSSPComputation.SSSPMapper

combineAllOp(int, RecordReader<IntWritable, PV>, VectorCache<PV>) - Method in class pegasus.mapreduce.common.computation.ComputationMapper

combineAllOp(int, RecordReader<IntWritable, BitStrings>, VectorCache<BitStrings>) - Method in class pegasus.mapreduce.diameter.DiameterComputation.DiameterMapper

combineAllOp(int, RecordReader<IntWritable, DoubleWritable>, VectorCache<DoubleWritable>) - Method in class pegasus.mapreduce.pagerank.PageRankComputation.PageRankMapper

combineAllOp(int, RecordReader<IntWritable, DoubleWritable>, VectorCache<DoubleWritable>) - Method in class pegasus.mapreduce.sssp.SSSPComputation.SSSPMapper

Comparator() - Constructor for class pegasus.mapreduce.common.io.LongPairWritable.Comparator

compare(byte[], int, int, byte[], int, int) - Method in class pegasus.mapreduce.common.io.LongPairWritable.Comparator

compare(WritableComparable, WritableComparable) - Method in class pegasus.mapreduce.common.io.LongPairWritable.DecreasingComparator

compare(byte[], int, int, byte[], int, int) - Method in class pegasus.mapreduce.common.io.LongPairWritable.DecreasingComparator

compare(byte[], int, int, byte[], int, int) - Method in class pegasus.mapreduce.common.utils.TypeUtils.IntComparator

compare(byte[], int, int, byte[], int, int) - Method in class pegasus.mapreduce.common.utils.TypeUtils.LongComparator

compareTo(LongPairWritable) - Method in class pegasus.mapreduce.common.io.LongPairWritable

compareTo(IntDoublePairWritable) - Method in class pegasus.mapreduce.common.types.IntDoublePairWritable

compareTo(IntIntPairWritable) - Method in class pegasus.mapreduce.common.types.IntIntPairWritable

compareTo(LongIntPairWritable) - Method in class pegasus.mapreduce.common.types.LongIntPairWritable

computationContext() - Method in class pegasus.mapreduce.common.computation.ComputationMapper

ComputationInputFormat - Class in pegasus.mapreduce.common.io

ComputationInputFormat() - Constructor for class pegasus.mapreduce.common.io.ComputationInputFormat

ComputationMapper<M extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable,PV extends org.apache.hadoop.io.Writable,OV extends org.apache.hadoop.io.Writable> - Class in pegasus.mapreduce.common.computation

A base class for PMV algorithm.

ComputationMapper() - Constructor for class pegasus.mapreduce.common.computation.ComputationMapper

ComputationTaskSplit - Class in pegasus.mapreduce.common.io

ComputationTaskSplit() - Constructor for class pegasus.mapreduce.common.io.ComputationTaskSplit

conf - Variable in class pegasus.mapreduce.common.cache.BaseMatrixCache

configStage1(Path, Path) - Method in class pegasus.mapreduce.netray.NetRayScatter

configStage1() - Method in class pegasus.mapreduce.netray.NetRaySpy

configStage2() - Method in class pegasus.mapreduce.netray.NetRayScatter

Constants - Class in pegasus.mapreduce.common

Constants() - Constructor for class pegasus.mapreduce.common.Constants

contains(int) - Method in class pegasus.mapreduce.common.cache.BaseVectorCache

contains(int) - Method in class pegasus.mapreduce.common.cache.BitSet

contains(int) - Method in interface pegasus.mapreduce.common.cache.VectorCache

ContinuousDistributionInputFormat - Class in pegasus.mapreduce.common.io

ContinuousDistributionInputFormat() - Constructor for class pegasus.mapreduce.common.io.ContinuousDistributionInputFormat

CoordinationService - Class in pegasus.mapreduce.common.coordination

CoordinationService() - Constructor for class pegasus.mapreduce.common.coordination.CoordinationService

CoordinationTickTime - Static variable in class pegasus.mapreduce.common.Constants

Counter<T> - Interface in pegasus.mapreduce.common.coordination

CounterGroup - Static variable in class pegasus.mapreduce.common.Constants

CounterRoot - Static variable in class pegasus.mapreduce.common.Constants

Counters - Enum in pegasus.mapreduce.cc

Counters - Enum in pegasus.mapreduce.cc.old

countSubgraphs(int[][], String, long[], int[], int) - Method in class pegasus.mapreduce.subgraph.VF2_degree

createEphemeralNode(ZooKeeper, String) - Static method in class pegasus.mapreduce.common.utils.ZookeeperUtils

createIntermediateVectorCache(int, long) - Method in class pegasus.mapreduce.common.computation.ComputationMapper

createIntermediateVectorCache(int, long) - Method in class pegasus.mapreduce.diameter.DiameterComputation.DiameterMapper

createIntermediateVectorCache(int, long) - Method in class pegasus.mapreduce.pagerank.PageRankComputation.PageRankMapper

createIntermediateVectorCache(int, long) - Method in class pegasus.mapreduce.sssp.SSSPComputation.SSSPMapper

createMatrixCache(String, Configuration, int, int) - Method in class pegasus.mapreduce.common.computation.ComputationMapper

createMatrixCache(String, Configuration, int, int) - Method in class pegasus.mapreduce.diameter.DiameterComputation.DiameterMapper

createMatrixCache(String, Configuration, int, int) - Method in class pegasus.mapreduce.pagerank.PageRankComputation.PageRankMapper

createMatrixCache(String, Configuration, int, int) - Method in class pegasus.mapreduce.sssp.SSSPComputation.SSSPMapper

createOrUpdatePersistentNode(ZooKeeper, String, String) - Static method in class pegasus.mapreduce.common.utils.ZookeeperUtils

createPersistentNode(ZooKeeper, String) - Static method in class pegasus.mapreduce.common.utils.ZookeeperUtils

createRecordReader(InputSplit, TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.ComputationInputFormat

createRecordReader(InputSplit, TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.ContinuousDistributionInputFormat

createRecordReader(InputSplit, TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.DiscreteDistributionInputFormat

createRecordReader(InputSplit, TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.UnweightedAdjacencyListInputFormat

createRecordReader(InputSplit, TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.UnweightedEdgeListInputFormat

createRecordReader(InputSplit, TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.WeightedEdgeListInputFormat

createVectorCache(int, int, long) - Method in class pegasus.mapreduce.common.computation.ComputationMapper

createVectorCache(int, int, long) - Method in class pegasus.mapreduce.diameter.DiameterComputation.DiameterMapper

createVectorCache(int, int, long) - Method in class pegasus.mapreduce.pagerank.PageRankComputation.PageRankMapper

createVectorCache(int, int, long) - Method in class pegasus.mapreduce.sssp.SSSPComputation.SSSPMapper

currentCol() - Method in interface pegasus.mapreduce.common.cache.MatrixIterator

currentId() - Method in interface pegasus.mapreduce.common.cache.VectorIterator

currentIteration() - Method in class pegasus.mapreduce.common.computation.ComputationMapper

currentRows() - Method in interface pegasus.mapreduce.common.cache.MatrixIterator

currentValue() - Method in interface pegasus.mapreduce.common.cache.VectorIterator

currentVector() - Method in class pegasus.mapreduce.common.computation.ComputationMapper

D

dataIn - Variable in class pegasus.mapreduce.common.cache.BaseMatrixIterator

DecreasingComparator() - Constructor for class pegasus.mapreduce.common.io.LongPairWritable.DecreasingComparator

DefaultDenseThreshold - Static variable in class pegasus.mapreduce.common.Constants

DefaultNumBitstrings - Static variable in class pegasus.mapreduce.common.Constants

DefaultPageRankDampingFactor - Static variable in class pegasus.mapreduce.common.Constants

DefaultPageRankThreshold - Static variable in class pegasus.mapreduce.common.Constants

DegreeComputation - Class in pegasus.mapreduce.degree

DegreeComputation() - Constructor for class pegasus.mapreduce.degree.DegreeComputation

DegreeComputation.DegreeReducer - Class in pegasus.mapreduce.degree

DegreeComputation.UnweightedDegreeMapper - Class in pegasus.mapreduce.degree

DegreeComputation.UnweightedInDegreeMapper - Class in pegasus.mapreduce.degree

DegreeComputation.UnweightedOutDegreeMapper - Class in pegasus.mapreduce.degree

DegreeComputation.WeightedDegreeMapper - Class in pegasus.mapreduce.degree

DegreeComputation.WeightedInDegreeMapper - Class in pegasus.mapreduce.degree

DegreeComputation.WeightedOutDegreeMapper - Class in pegasus.mapreduce.degree

DegreeReducer() - Constructor for class pegasus.mapreduce.degree.DegreeComputation.DegreeReducer

degrees - Variable in class pegasus.mapreduce.common.cache.BaseMatrixCache

delete(ZooKeeper, String) - Static method in class pegasus.mapreduce.common.utils.ZookeeperUtils

denseCols - Variable in class pegasus.mapreduce.common.io.ComputationTaskSplit

denseOutput - Variable in class pegasus.mapreduce.common.io.BaseMatrixOutputFormat.OutputConfig

denseRows - Variable in class pegasus.mapreduce.common.io.ComputationTaskSplit

denseSplits - Variable in class pegasus.mapreduce.common.io.ComputationTaskSplit

DenseThreshold - Static variable in class pegasus.mapreduce.common.Constants

denseThreshold - Variable in class pegasus.mapreduce.common.io.BaseMatrixOutputFormat.OutputConfig

DenseVectorKey - Static variable in class pegasus.mapreduce.common.Constants

DFSTemporaryPath - Static variable in class pegasus.mapreduce.common.Constants

DiameterComputation - Class in pegasus.mapreduce.diameter

DiameterComputation() - Constructor for class pegasus.mapreduce.diameter.DiameterComputation

DiameterComputation.DiameterMapper - Class in pegasus.mapreduce.diameter

DiameterComputation.RadiiMapper - Class in pegasus.mapreduce.diameter

DiameterComputation.RadiiReducer - Class in pegasus.mapreduce.diameter

DiameterMapper() - Constructor for class pegasus.mapreduce.diameter.DiameterComputation.DiameterMapper

DiameterNeighborhood - Static variable in class pegasus.mapreduce.common.Constants

DiameterNeighborhoodFile - Static variable in class pegasus.mapreduce.common.Constants

DiameterNumIterations - Static variable in class pegasus.mapreduce.common.Constants

DirectedMapper() - Constructor for class pegasus.mapreduce.common.prepartitioning.UnweightedGraphPrepartitioning.DirectedMapper

DirectedMapper() - Constructor for class pegasus.mapreduce.common.prepartitioning.WeightedGraphPrepartitioning.DirectedMapper

DirectReader - Class in pegasus.mapreduce.common.io

DirectReader(String) - Constructor for class pegasus.mapreduce.common.io.DirectReader

DirectReader(String, int) - Constructor for class pegasus.mapreduce.common.io.DirectReader

DirectWriter - Class in pegasus.mapreduce.common.io

DirectWriter(String) - Constructor for class pegasus.mapreduce.common.io.DirectWriter

DirectWriter(String, int) - Constructor for class pegasus.mapreduce.common.io.DirectWriter

DiscreteDistributionInputFormat - Class in pegasus.mapreduce.common.io

DiscreteDistributionInputFormat() - Constructor for class pegasus.mapreduce.common.io.DiscreteDistributionInputFormat

DistributionDefaultNumBins - Static variable in class pegasus.mapreduce.common.Constants

DistributionMaxValue - Static variable in class pegasus.mapreduce.common.Constants

DistributionMinValue - Static variable in class pegasus.mapreduce.common.Constants

DistributionNumBins - Static variable in class pegasus.mapreduce.common.Constants

DoubleValueZeroThreshold - Static variable in class pegasus.mapreduce.common.Constants

DoubleVectorCache - Class in pegasus.mapreduce.common.cache

DoubleVectorCache(int, int, long, DoubleWritable) - Constructor for class pegasus.mapreduce.common.cache.DoubleVectorCache

dual(int, int) - Static method in class pegasus.mapreduce.subgraph.SeedGenerator

Generate subproblems according to the number of colors and the number of nodes in a given query graph.

dvSplit - Variable in class pegasus.mapreduce.common.io.ComputationTaskSplit

dvWriter - Variable in class pegasus.mapreduce.common.prepartitioning.GraphPrepartitioningReducer

E

edge_path - Variable in class pegasus.mapreduce.netray.NetRaySpy

EdgeListDelimiter - Static variable in class pegasus.mapreduce.common.Constants

EdgeOrder - Class in pegasus.mapreduce.triangle

EdgeOrder() - Constructor for class pegasus.mapreduce.triangle.EdgeOrder

EdgeOrder.EOStep1Mapper - Class in pegasus.mapreduce.triangle

EdgeOrder.EOStep1Reducer - Class in pegasus.mapreduce.triangle

EdgeOrder.EOStep2Mapper - Class in pegasus.mapreduce.triangle

EdgeOrder.EOStep2Reducer - Class in pegasus.mapreduce.triangle

EdgeRecordReader(String) - Constructor for class pegasus.mapreduce.common.io.UnweightedEdgeListInputFormat.EdgeRecordReader

EdgeRecordReader(String) - Constructor for class pegasus.mapreduce.common.io.WeightedEdgeListInputFormat.EdgeRecordReader

end() - Method in class pegasus.mapreduce.common.types.IntArrayWritable

end() - Method in class pegasus.mapreduce.common.types.IntDoublePairArrayWritable

end() - Method in class pegasus.mapreduce.common.types.LongArrayWritable

end() - Method in class pegasus.mapreduce.common.types.LongDoublePairArrayWritable

enumTri(int[][], int[][], int[][], int, int, int) - Method in class pegasus.mapreduce.triangle.PTE.TriangleCountingMapper

Counting triangles.

enumTri(int[][], int[][], int[][], int, int, int) - Method in class pegasus.mapreduce.triangle.PTE.TriangleListingMapper

Listing triangles.

EOStep1Mapper() - Constructor for class pegasus.mapreduce.triangle.EdgeOrder.EOStep1Mapper

EOStep1Reducer() - Constructor for class pegasus.mapreduce.triangle.EdgeOrder.EOStep1Reducer

EOStep2Mapper() - Constructor for class pegasus.mapreduce.triangle.EdgeOrder.EOStep2Mapper

EOStep2Reducer() - Constructor for class pegasus.mapreduce.triangle.EdgeOrder.EOStep2Reducer

equals(Object) - Method in class pegasus.mapreduce.common.io.LongPairWritable

equals(Object) - Method in class pegasus.mapreduce.common.types.BitStrings

equals(Object) - Method in class pegasus.mapreduce.common.types.LongIntPairWritable

ExecutedIterations - Static variable in class pegasus.mapreduce.common.Constants

exists(ZooKeeper, String) - Static method in class pegasus.mapreduce.common.utils.ZookeeperUtils

ExternalSorter - Class in pegasus.mapreduce.common.io

Positive Long Sorter.

ExternalSorter() - Constructor for class pegasus.mapreduce.common.io.ExternalSorter

F

field_ids - Variable in class pegasus.mapreduce.netray.NetRayScatter

FileUtils - Class in pegasus.mapreduce.common.cache

An utility class to manipulate files.

FileUtils() - Constructor for class pegasus.mapreduce.common.cache.FileUtils

Finalization - Class in pegasus.mapreduce.cc

Finalization(Path, int, boolean) - Constructor for class pegasus.mapreduce.cc.Finalization

constructor

Finalization - Class in pegasus.mapreduce.cc.old

Finalization(Path, int, boolean) - Constructor for class pegasus.mapreduce.cc.old.Finalization

Finalization.LargeStarMapper - Class in pegasus.mapreduce.cc

Finalization.LargeStarMapper - Class in pegasus.mapreduce.cc.old

Finalization.LargeStarReducer - Class in pegasus.mapreduce.cc

Finalization.LargeStarReducer - Class in pegasus.mapreduce.cc.old

finalizeOp(int, V) - Method in class pegasus.mapreduce.common.computation.ComputationMapper

finalizeOp(int, BitStrings) - Method in class pegasus.mapreduce.diameter.DiameterComputation.DiameterMapper

finalizeOp(int, DoubleWritable) - Method in class pegasus.mapreduce.pagerank.PageRankComputation.PageRankMapper

find(long) - Method in class pegasus.mapreduce.cc.Finalization.LargeStarReducer

the find function of the union-find algorithm.

find(long) - Method in class pegasus.mapreduce.cc.old.Finalization.LargeStarReducer

find(long) - Method in class pegasus.mapreduce.cc.old.UnionFind

freeze() - Method in class pegasus.mapreduce.common.cache.BaseMatrixCache

freeze() - Method in interface pegasus.mapreduce.common.cache.MatrixCache

G

get(int) - Method in class pegasus.mapreduce.common.cache.BitStringsVectorCache

get(int) - Method in class pegasus.mapreduce.common.cache.DoubleVectorCache

get(int) - Method in interface pegasus.mapreduce.common.cache.VectorCache

get(int) - Method in class pegasus.mapreduce.common.types.IntArrayWritable

get(int) - Method in class pegasus.mapreduce.common.types.LongArrayWritable

get(long) - Method in class pegasus.mapreduce.common.types.LongIntPairMapWritable

getArraySize() - Method in class pegasus.mapreduce.common.cache.BitSet

getBit(int) - Method in class pegasus.mapreduce.common.types.BitStrings

Returns i-th sub-bitstring.

getBits() - Method in class pegasus.mapreduce.common.types.BitStrings

Returns current bit values.

getCardinality() - Method in class pegasus.mapreduce.common.cache.BitSet

getChildren(ZooKeeper, String) - Static method in class pegasus.mapreduce.common.utils.ZookeeperUtils

getCurrentKey() - Method in class pegasus.mapreduce.common.io.MatrixRecordReader

getCurrentKey() - Method in class pegasus.mapreduce.common.io.UnweightedAdjacencyListInputFormat.AdjacencyListRecordReader

getCurrentKey() - Method in class pegasus.mapreduce.common.io.UnweightedEdgeListInputFormat.EdgeRecordReader

getCurrentKey() - Method in class pegasus.mapreduce.common.io.VectorRecordReader

getCurrentKey() - Method in class pegasus.mapreduce.common.io.WeightedEdgeListInputFormat.EdgeRecordReader

getCurrentValue() - Method in class pegasus.mapreduce.common.io.MatrixRecordReader

getCurrentValue() - Method in class pegasus.mapreduce.common.io.UnweightedAdjacencyListInputFormat.AdjacencyListRecordReader

getCurrentValue() - Method in class pegasus.mapreduce.common.io.UnweightedEdgeListInputFormat.EdgeRecordReader

getCurrentValue() - Method in class pegasus.mapreduce.common.io.VectorRecordReader

getCurrentValue() - Method in class pegasus.mapreduce.common.io.WeightedEdgeListInputFormat.EdgeRecordReader

getDouble(int) - Method in class pegasus.mapreduce.common.types.IntDoublePairArrayWritable

getDouble() - Method in class pegasus.mapreduce.common.types.IntDoublePairWritable

getDouble(int) - Method in class pegasus.mapreduce.common.types.LongDoublePairArrayWritable

getDoubles() - Method in class pegasus.mapreduce.common.types.IntDoublePairArrayWritable

getDoubles() - Method in class pegasus.mapreduce.common.types.LongDoublePairArrayWritable

getFirst() - Method in class pegasus.mapreduce.common.types.IntIntPairWritable

getHadoopCounter(String) - Method in class pegasus.mapreduce.common.coordination.CoordinationService

getId() - Method in class pegasus.mapreduce.common.types.LongIntPairWritable

getInt(int) - Method in class pegasus.mapreduce.common.types.IntDoublePairArrayWritable

getInt() - Method in class pegasus.mapreduce.common.types.IntDoublePairWritable

getIntermediateVectorPath(TaskAttemptContext, String, int) - Static method in class pegasus.mapreduce.common.utils.IOUtils

Returns a path of intermediate vector file.

getIntermediateVectorReader(TaskAttemptContext, String, int, Class<T>) - Static method in class pegasus.mapreduce.common.utils.IOUtils

Opens the intermediate vector file and returns a reader object to read values from the file.

getIntermediateVectorReader(TaskAttemptContext, Path, Class<T>) - Static method in class pegasus.mapreduce.common.utils.IOUtils

Opens the intermediate vector file and returns a reader object to read values from the file.

getIntermediateVectorWriter(TaskAttemptContext, String, int) - Static method in class pegasus.mapreduce.common.utils.IOUtils

Opens an intermediate vector file and returns a writer object to write values to the file.

getIntermediateVectorWriter(TaskAttemptContext, Path) - Static method in class pegasus.mapreduce.common.utils.IOUtils

Opens an intermediate vector file and returns a writer object to write values to the file.

getInts() - Method in class pegasus.mapreduce.common.types.IntDoublePairArrayWritable

getLength() - Method in class pegasus.mapreduce.common.io.ComputationTaskSplit

getLocalTemporaryPath(String, TaskAttemptContext) - Static method in class pegasus.mapreduce.common.cache.FileUtils

Returns a temporary directory path.

getLocalTemporaryPath(String, TaskAttemptContext) - Static method in class pegasus.mapreduce.common.utils.IOUtils

Returns a path of local temporary file.

getLocalTemporaryPath(String, int) - Static method in class pegasus.mapreduce.common.utils.IOUtils

Returns a path of local temporary file.

getLocalTemporaryPath(String) - Static method in class pegasus.mapreduce.common.utils.IOUtils

Returns a path of local temporary file.

getLocations() - Method in class pegasus.mapreduce.common.io.ComputationTaskSplit

getLong(int) - Method in class pegasus.mapreduce.common.types.LongDoublePairArrayWritable

getLongs() - Method in class pegasus.mapreduce.common.types.LongDoublePairArrayWritable

getMaximum() - Method in interface pegasus.mapreduce.common.coordination.Counter

getMaximum() - Method in class pegasus.mapreduce.common.coordination.HadoopCounter

getMaximum() - Method in class pegasus.mapreduce.common.coordination.ZookeeperCounter

getMaximumByValue() - Method in class pegasus.mapreduce.common.types.LongIntPairMapWritable

getMinimum() - Method in interface pegasus.mapreduce.common.coordination.Counter

getMinimum() - Method in class pegasus.mapreduce.common.coordination.HadoopCounter

getMinimum() - Method in class pegasus.mapreduce.common.coordination.ZookeeperCounter

getMutexBarrier(String, int, boolean) - Method in class pegasus.mapreduce.common.coordination.CoordinationService

getNodeData(ZooKeeper, String) - Static method in class pegasus.mapreduce.common.utils.ZookeeperUtils

getOutputConfig(TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.BaseMatrixOutputFormat

getPartition(LongWritable, Object, int) - Method in class pegasus.mapreduce.common.prepartitioning.PrepartitioningPartitioner

getPath() - Method in class pegasus.mapreduce.common.io.DirectReader

getPath() - Method in class pegasus.mapreduce.common.io.DirectWriter

getPreferredCompressionCodec(Configuration) - Static method in class pegasus.mapreduce.common.cache.FileUtils

Returns the preferred compression codec.

getPreferredCompressionCodec(TaskAttemptContext) - Static method in class pegasus.mapreduce.common.cache.FileUtils

Returns the preferred compression codec.

getPreferredCompressionCodec(Configuration) - Static method in class pegasus.mapreduce.common.utils.IOUtils

Returns a codec object which is preferred.

getPreferredCompressionCodec(TaskAttemptContext) - Static method in class pegasus.mapreduce.common.utils.IOUtils

Returns a codec object which is preferred.

getProgress() - Method in class pegasus.mapreduce.common.io.MatrixRecordReader

getProgress() - Method in class pegasus.mapreduce.common.io.UnweightedAdjacencyListInputFormat.AdjacencyListRecordReader

getProgress() - Method in class pegasus.mapreduce.common.io.UnweightedEdgeListInputFormat.EdgeRecordReader

getProgress() - Method in class pegasus.mapreduce.common.io.VectorRecordReader

getProgress() - Method in class pegasus.mapreduce.common.io.WeightedEdgeListInputFormat.EdgeRecordReader

getRecordWriter(TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.UnweightedMatrixOutputFormat

getRecordWriter(TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.WeightedMatrixOutputFormat

getSecond() - Method in class pegasus.mapreduce.common.types.IntIntPairWritable

getSemaphoreBarrier(String) - Method in class pegasus.mapreduce.common.coordination.CoordinationService

getServiceAddress() - Method in class pegasus.mapreduce.common.coordination.CoordinationService

getSplits(JobContext) - Method in class pegasus.mapreduce.common.io.ComputationInputFormat

getSum() - Method in interface pegasus.mapreduce.common.coordination.Counter

getSum() - Method in class pegasus.mapreduce.common.coordination.HadoopCounter

getSum() - Method in class pegasus.mapreduce.common.coordination.ZookeeperCounter

getTemporaryFileInputStream(Path, TaskAttemptContext) - Static method in class pegasus.mapreduce.common.cache.FileUtils

Creates an input stream from the given path of a file.

getTemporaryFileInputStream(Path, TaskAttemptContext) - Static method in class pegasus.mapreduce.common.utils.IOUtils

Opens the given local temporary file and returns an input stream object to read values from the file.

getTemporaryFileOutputStream(Path, TaskAttemptContext) - Static method in class pegasus.mapreduce.common.cache.FileUtils

Creates an output stream to the given path of a file.

getTemporaryFileOutputStream(Path, TaskAttemptContext) - Static method in class pegasus.mapreduce.common.utils.IOUtils

Creates a local temporary file and returns an output stream object to write values to the file.

getTempPath(String) - Static method in class pegasus.mapreduce.common.io.LocalPaths

getValue() - Method in class pegasus.mapreduce.common.types.LongIntPairWritable

getValues() - Method in class pegasus.mapreduce.common.types.IntArrayWritable

getValues() - Method in class pegasus.mapreduce.common.types.LongArrayWritable

getWorkerId() - Method in class pegasus.mapreduce.common.coordination.CoordinationService

getZkCounter(String, Class<T>) - Method in class pegasus.mapreduce.common.coordination.CoordinationService

globalToLocal(int, long) - Static method in class pegasus.mapreduce.common.utils.IDUtils

Converts a global vertex ID to local vertex ID.

GraphPrepartitioningReducer<IV,OV> - Class in pegasus.mapreduce.common.prepartitioning

GraphPrepartitioningReducer() - Constructor for class pegasus.mapreduce.common.prepartitioning.GraphPrepartitioningReducer

H

HadoopCounter - Class in pegasus.mapreduce.common.coordination

HadoopCounter(TaskAttemptContext, String) - Constructor for class pegasus.mapreduce.common.coordination.HadoopCounter

hashCode() - Method in class pegasus.mapreduce.common.io.LongPairWritable

hashCode() - Method in class pegasus.mapreduce.common.types.BitStrings

hashCode() - Method in class pegasus.mapreduce.common.types.LongIntPairWritable

hasNext() - Method in class pegasus.mapreduce.common.io.DirectReader

hasNext() - Method in class pegasus.mapreduce.common.io.LongIteratorFromDirectInput

I

i - Variable in class pegasus.mapreduce.common.io.LongPairWritable

IDUtils - Class in pegasus.mapreduce.common.utils

Provides some utility methods about vertex IDs.

IDUtils() - Constructor for class pegasus.mapreduce.common.utils.IDUtils

in - Variable in class pegasus.mapreduce.common.cache.BaseMatrixIterator

init() - Method in class pegasus.mapreduce.common.io.DirectReader

InitArrayWritableSize - Static variable in class pegasus.mapreduce.common.Constants

Initialization - Class in pegasus.mapreduce.cc

Initialization.

Initialization(Path, Path, boolean) - Constructor for class pegasus.mapreduce.cc.Initialization

Initialization - Class in pegasus.mapreduce.cc.old

Initialization.

Initialization(Path, Path, boolean) - Constructor for class pegasus.mapreduce.cc.old.Initialization

Initialization.InitializationMapper - Class in pegasus.mapreduce.cc

Initialization.InitializationMapper - Class in pegasus.mapreduce.cc.old

InitializationMapper() - Constructor for class pegasus.mapreduce.cc.Initialization.InitializationMapper

InitializationMapper() - Constructor for class pegasus.mapreduce.cc.old.Initialization.InitializationMapper

initialize(InputSplit, TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.MatrixRecordReader

initialize(InputSplit, TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.UnweightedAdjacencyListInputFormat.AdjacencyListRecordReader

initialize(InputSplit, TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.UnweightedEdgeListInputFormat.EdgeRecordReader

initialize(InputSplit, TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.VectorRecordReader

initialize(InputSplit, TaskAttemptContext) - Method in class pegasus.mapreduce.common.io.WeightedEdgeListInputFormat.EdgeRecordReader

input_path - Variable in class pegasus.mapreduce.netray.NetRayScatter

inputSize - Variable in class pegasus.mapreduce.cc.Finalization

inputSize - Variable in class pegasus.mapreduce.cc.old.Finalization

inputSize - Variable in class pegasus.mapreduce.cc.old.PALargeStarOpt

inputSize - Variable in class pegasus.mapreduce.cc.old.PASmallStarOpt

inputSize - Variable in class pegasus.mapreduce.cc.PASmallStarOpt

inSize - Variable in class pegasus.mapreduce.cc.old.PASmallStarOpt

inSize - Variable in class pegasus.mapreduce.cc.PASmallStarOpt

IntArrayWritable - Class in pegasus.mapreduce.common.types

Represents an array contains int values.

IntArrayWritable() - Constructor for class pegasus.mapreduce.common.types.IntArrayWritable

IntArrayWritable(int) - Constructor for class pegasus.mapreduce.common.types.IntArrayWritable

IntArrayWritable(int...) - Constructor for class pegasus.mapreduce.common.types.IntArrayWritable

IntComparator(Class<? extends WritableComparable>) - Constructor for class pegasus.mapreduce.common.utils.TypeUtils.IntComparator

IntDoublePairArrayWritable - Class in pegasus.mapreduce.common.types

Represents an array contains (int, double) pair values.

IntDoublePairArrayWritable() - Constructor for class pegasus.mapreduce.common.types.IntDoublePairArrayWritable

IntDoublePairArrayWritable(int[], double[]) - Constructor for class pegasus.mapreduce.common.types.IntDoublePairArrayWritable

IntDoublePairWritable - Class in pegasus.mapreduce.common.types

Represents an (int, double) pair value.

IntDoublePairWritable() - Constructor for class pegasus.mapreduce.common.types.IntDoublePairWritable

IntDoublePairWritable(int, double) - Constructor for class pegasus.mapreduce.common.types.IntDoublePairWritable

IntermediateVectorKey - Static variable in class pegasus.mapreduce.common.Constants

intermediateVectorValueClass() - Method in class pegasus.mapreduce.common.computation.ComputationMapper

intermediateVectorValueClass() - Method in class pegasus.mapreduce.diameter.DiameterComputation.DiameterMapper

intermediateVectorValueClass() - Method in class pegasus.mapreduce.pagerank.PageRankComputation.PageRankMapper

intermediateVectorValueClass() - Method in class pegasus.mapreduce.sssp.SSSPComputation.SSSPMapper

IntIntPairWritable - Class in pegasus.mapreduce.common.types

Represents an (int, int) pair value.

IntIntPairWritable() - Constructor for class pegasus.mapreduce.common.types.IntIntPairWritable

IntIntPairWritable(int, int) - Constructor for class pegasus.mapreduce.common.types.IntIntPairWritable

IOUtils - Class in pegasus.mapreduce.common.utils

IOUtils() - Constructor for class pegasus.mapreduce.common.utils.IOUtils

is_linear - Variable in class pegasus.mapreduce.netray.NetRayScatter

is_linear - Variable in class pegasus.mapreduce.netray.NetRaySpy

isEmpty() - Method in class pegasus.mapreduce.common.types.BitStrings

Returns whether all bitstrings are empty or not.

isSplitable(JobContext, Path) - Method in class pegasus.mapreduce.common.io.ComputationInputFormat

iterator(boolean, BitSet) - Method in class pegasus.mapreduce.common.cache.BitStringsVectorCache

iterator(boolean, BitSet) - Method in class pegasus.mapreduce.common.cache.DoubleVectorCache

iterator() - Method in interface pegasus.mapreduce.common.cache.MatrixCache

iterator() - Method in class pegasus.mapreduce.common.cache.UnweightedMatrixCache

iterator(boolean, BitSet) - Method in interface pegasus.mapreduce.common.cache.VectorCache

iterator() - Method in class pegasus.mapreduce.common.cache.WeightedMatrixCache

J

j - Variable in class pegasus.mapreduce.common.io.LongPairWritable

K

KroneckerGenerator - Class in pegasus.mapreduce.graphgen

KroneckerGenerator() - Constructor for class pegasus.mapreduce.graphgen.KroneckerGenerator

KroneckerGenerator.KroneckerGeneratorMapper - Class in pegasus.mapreduce.graphgen

KroneckerGeneratorMapper() - Constructor for class pegasus.mapreduce.graphgen.KroneckerGenerator.KroneckerGeneratorMapper

L

LargeStarMapper() - Constructor for class pegasus.mapreduce.cc.Finalization.LargeStarMapper

LargeStarMapper() - Constructor for class pegasus.mapreduce.cc.old.Finalization.LargeStarMapper

LargeStarReducer() - Constructor for class pegasus.mapreduce.cc.Finalization.LargeStarReducer

LargeStarReducer() - Constructor for class pegasus.mapreduce.cc.old.Finalization.LargeStarReducer

LocalPaths - Class in pegasus.mapreduce.common.io

LocalPaths() - Constructor for class pegasus.mapreduce.common.io.LocalPaths

localToGlobal(int, int, int) - Static method in class pegasus.mapreduce.common.utils.IDUtils

Converts a local vertex ID to global vertex ID.

LongArrayWritable - Class in pegasus.mapreduce.common.types

Represents an array contains long values.

LongArrayWritable() - Constructor for class pegasus.mapreduce.common.types.LongArrayWritable

LongArrayWritable(long) - Constructor for class pegasus.mapreduce.common.types.LongArrayWritable

LongArrayWritable(long...) - Constructor for class pegasus.mapreduce.common.types.LongArrayWritable

LongComparator(Class<? extends WritableComparable>) - Constructor for class pegasus.mapreduce.common.utils.TypeUtils.LongComparator

LongDoublePairArrayWritable - Class in pegasus.mapreduce.common.types

Represents an array contains (long, double) pair values.

LongDoublePairArrayWritable() - Constructor for class pegasus.mapreduce.common.types.LongDoublePairArrayWritable

LongDoublePairArrayWritable(long[], double[]) - Constructor for class pegasus.mapreduce.common.types.LongDoublePairArrayWritable

LongIntPairMapWritable - Class in pegasus.mapreduce.common.types

Represents a map contains (long, int) pair values.

LongIntPairMapWritable() - Constructor for class pegasus.mapreduce.common.types.LongIntPairMapWritable

LongIntPairMapWritable(int) - Constructor for class pegasus.mapreduce.common.types.LongIntPairMapWritable

LongIntPairMapWritable(LongIntPairMapWritable) - Constructor for class pegasus.mapreduce.common.types.LongIntPairMapWritable

LongIntPairWritable - Class in pegasus.mapreduce.common.types

Represents a (long, int) pair value.

LongIntPairWritable() - Constructor for class pegasus.mapreduce.common.types.LongIntPairWritable

LongIntPairWritable(long, int) - Constructor for class pegasus.mapreduce.common.types.LongIntPairWritable

LongIteratorFromDirectInput - Class in pegasus.mapreduce.common.io

Created by hmpark on 17.

LongIteratorFromDirectInput(String) - Constructor for class pegasus.mapreduce.common.io.LongIteratorFromDirectInput

LongPairWritable - Class in pegasus.mapreduce.common.io

LongPairWritable() - Constructor for class pegasus.mapreduce.common.io.LongPairWritable

LongPairWritable(long, long) - Constructor for class pegasus.mapreduce.common.io.LongPairWritable

LongPairWritable.Comparator - Class in pegasus.mapreduce.common.io

A Comparator optimized for LongWritable.

LongPairWritable.DecreasingComparator - Class in pegasus.mapreduce.common.io

M

main(String[]) - Static method in class pegasus.mapreduce.cc.Initialization

main(String[]) - Static method in class pegasus.mapreduce.cc.old.Initialization

main(String[]) - Static method in class pegasus.mapreduce.cc.old.PACC

main(String[]) - Static method in class pegasus.mapreduce.cc.old.PALargeStarOpt

main(String[]) - Static method in class pegasus.mapreduce.cc.old.PASmallStarOpt

main(String[]) - Static method in class pegasus.mapreduce.cc.PACC

the main entry point

main(String[]) - Static method in class pegasus.mapreduce.cc.PALargeStarOpt

the main entry point

main(String[]) - Static method in class pegasus.mapreduce.cc.PASmallStarOpt

the main entry point

main(String[]) - Static method in class pegasus.mapreduce.common.prepartitioning.UnweightedGraphPrepartitioning

main(String[]) - Static method in class pegasus.mapreduce.common.prepartitioning.WeightedGraphPrepartitioning

main(String[]) - Static method in class pegasus.mapreduce.degree.DegreeComputation

main(String[]) - Static method in class pegasus.mapreduce.diameter.DiameterComputation

main(String[]) - Static method in class pegasus.mapreduce.graphgen.KroneckerGenerator

The main entry point

main(String[]) - Static method in class pegasus.mapreduce.graphgen.RandomGenerator

The main entry point

main(String[]) - Static method in class pegasus.mapreduce.graphgen.RMATGenerator

The main entry point

main(String[]) - Static method in class pegasus.mapreduce.netray.NetRayScatter

main(String[]) - Static method in class pegasus.mapreduce.netray.NetRaySpy

main(String[]) - Static method in class pegasus.mapreduce.pagerank.PageRankComputation

main(String[]) - Static method in class pegasus.mapreduce.sssp.SSSPComputation

main(String[]) - Static method in class pegasus.mapreduce.subgraph.PrePartition

The main entry point

main(String[]) - Static method in class pegasus.mapreduce.subgraph.PSE

The main entry point

main(String[]) - Static method in class pegasus.mapreduce.triangle.deprecated.PTE_cd

main(String[]) - Static method in class pegasus.mapreduce.triangle.EdgeOrder

The main entry point

main(String[]) - Static method in class pegasus.mapreduce.triangle.PrePartition

The main entry point

main(String[]) - Static method in class pegasus.mapreduce.triangle.PTE

The main entry point

makesym - Variable in class pegasus.mapreduce.netray.NetRaySpy

map(LongWritable, LongWritable, Mapper<LongWritable, LongWritable, IntWritable, LongPairWritable>.Context) - Method in class pegasus.mapreduce.cc.Finalization.LargeStarMapper

the map function.

map(Object, Text, Mapper<Object, Text, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.Initialization.InitializationMapper

map(LongWritable, LongWritable, Mapper<LongWritable, LongWritable, IntWritable, LongPairWritable>.Context) - Method in class pegasus.mapreduce.cc.old.Finalization.LargeStarMapper

map(Object, Text, Mapper<Object, Text, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.old.Initialization.InitializationMapper

map(LongWritable, LongWritable, Mapper<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.old.PALargeStarOpt.ColorLargeStarMapper

map(LongWritable, LongWritable, Mapper<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.old.PASmallStarOpt.ColorSmallStarMapper

map(LongWritable, LongWritable, Mapper<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.PALargeStarOpt.ColorLargeStarMapper

the map function of PALargeStarOpt.

map(LongWritable, LongWritable, Mapper<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.PASmallStarOpt.PASmallStarMapper

the map function of PASmallStarOpt.

map(LongWritable, LongArrayWritable, Mapper<LongWritable, LongArrayWritable, LongWritable, LongArrayWritable>.Context) - Method in class pegasus.mapreduce.common.prepartitioning.UnweightedGraphPrepartitioning.DirectedMapper

map(LongWritable, LongArrayWritable, Mapper<LongWritable, LongArrayWritable, LongWritable, LongArrayWritable>.Context) - Method in class pegasus.mapreduce.common.prepartitioning.UnweightedGraphPrepartitioning.TransposedMapper

map(LongWritable, LongArrayWritable, Mapper<LongWritable, LongArrayWritable, LongWritable, LongArrayWritable>.Context) - Method in class pegasus.mapreduce.common.prepartitioning.UnweightedGraphPrepartitioning.UndirectedMapper

map(LongWritable, LongDoublePairArrayWritable, Mapper<LongWritable, LongDoublePairArrayWritable, LongWritable, LongDoublePairArrayWritable>.Context) - Method in class pegasus.mapreduce.common.prepartitioning.WeightedGraphPrepartitioning.DirectedMapper

map(LongWritable, LongDoublePairArrayWritable, Mapper<LongWritable, LongDoublePairArrayWritable, LongWritable, LongDoublePairArrayWritable>.Context) - Method in class pegasus.mapreduce.common.prepartitioning.WeightedGraphPrepartitioning.UndirectedMapper

map(LongWritable, LongArrayWritable, Mapper<LongWritable, LongArrayWritable, LongWritable, IntWritable>.Context) - Method in class pegasus.mapreduce.degree.DegreeComputation.UnweightedDegreeMapper

map(LongWritable, LongArrayWritable, Mapper<LongWritable, LongArrayWritable, LongWritable, IntWritable>.Context) - Method in class pegasus.mapreduce.degree.DegreeComputation.UnweightedInDegreeMapper

map(LongWritable, LongArrayWritable, Mapper<LongWritable, LongArrayWritable, LongWritable, IntWritable>.Context) - Method in class pegasus.mapreduce.degree.DegreeComputation.UnweightedOutDegreeMapper

map(LongWritable, LongDoublePairArrayWritable, Mapper<LongWritable, LongDoublePairArrayWritable, LongWritable, IntWritable>.Context) - Method in class pegasus.mapreduce.degree.DegreeComputation.WeightedDegreeMapper

map(LongWritable, LongDoublePairArrayWritable, Mapper<LongWritable, LongDoublePairArrayWritable, LongWritable, IntWritable>.Context) - Method in class pegasus.mapreduce.degree.DegreeComputation.WeightedInDegreeMapper

map(LongWritable, LongDoublePairArrayWritable, Mapper<LongWritable, LongDoublePairArrayWritable, LongWritable, IntWritable>.Context) - Method in class pegasus.mapreduce.degree.DegreeComputation.WeightedOutDegreeMapper

map(IntWritable, KroneckerGenerator.RegionSlot, Mapper<IntWritable, KroneckerGenerator.RegionSlot, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.graphgen.KroneckerGenerator.KroneckerGeneratorMapper

The map function of the RMAT graph generator.

map(IntWritable, RandomGenerator.RegionSlot, Mapper<IntWritable, RandomGenerator.RegionSlot, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.graphgen.RandomGenerator.RandomGeneratorMapper

The map function of the random graph generator.

map(IntWritable, RMATGenerator.RegionSlot, Mapper<IntWritable, RMATGenerator.RegionSlot, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.graphgen.RMATGenerator.RMATGeneratorMapper

The map function of the RMAT graph generator.

map(LongWritable, Text, Mapper<LongWritable, Text, IntWritable, DoubleWritable>.Context) - Method in class pegasus.mapreduce.netray.NetRayScatter.MapStage1

map(LongWritable, Text, Mapper<LongWritable, Text, Text, LongWritable>.Context) - Method in class pegasus.mapreduce.netray.NetRayScatter.MapStage2

map(LongWritable, Text, Mapper<LongWritable, Text, Text, LongWritable>.Context) - Method in class pegasus.mapreduce.netray.NetRaySpy.MapStage1

map(Object, Text, Mapper<Object, Text, ShortWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.subgraph.PrePartition.PGMapper

The map function of pre-partitioning

map(Object, Text, Mapper<Object, Text, Text, NullWritable>.Context) - Method in class pegasus.mapreduce.subgraph.PSE.SubgraphEnumerationMapper

The map function of PSE

map(Object, Text, Mapper<Object, Text, NullWritable, NullWritable>.Context) - Method in class pegasus.mapreduce.triangle.deprecated.PTE_cd.TriangleEnumerationMapper

map(Object, Text, Mapper<Object, Text, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.triangle.EdgeOrder.EOStep1Mapper

The map function of the first step

map(LongPairWritable, IntWritable, Mapper<LongPairWritable, IntWritable, LongPairWritable, IntWritable>.Context) - Method in class pegasus.mapreduce.triangle.EdgeOrder.EOStep2Mapper

The map function of the second step

map(LongWritable, LongWritable, Mapper<LongWritable, LongWritable, ShortWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.triangle.PrePartition.PGMapper

The map function of pre-partitioning

map(Object, Text, Mapper<Object, Text, Text, NullWritable>.Context) - Method in class pegasus.mapreduce.triangle.PTE.TriangleCountingMapper

the map function of triangle enumeration step of PTE

MapStage1() - Constructor for class pegasus.mapreduce.netray.NetRayScatter.MapStage1

MapStage1() - Constructor for class pegasus.mapreduce.netray.NetRaySpy.MapStage1

MapStage2() - Constructor for class pegasus.mapreduce.netray.NetRayScatter.MapStage2

mark() - Method in class pegasus.mapreduce.common.io.DirectReader

markCompleted() - Method in interface pegasus.mapreduce.common.coordination.Barrier

Marks this barrier completed.

markCompleted() - Method in class pegasus.mapreduce.common.coordination.MutexBarrier

markCompleted() - Method in class pegasus.mapreduce.common.coordination.SemaphoreBarrier

MatrixCache<V extends org.apache.hadoop.io.Writable> - Interface in pegasus.mapreduce.common.cache

MatrixIterator<V extends org.apache.hadoop.io.Writable> - Interface in pegasus.mapreduce.common.cache

MatrixRecordReader<V extends org.apache.hadoop.io.Writable> - Class in pegasus.mapreduce.common.io

MatrixRecordReader(Class<V>, Configuration) - Constructor for class pegasus.mapreduce.common.io.MatrixRecordReader

matrixValueClass() - Method in class pegasus.mapreduce.common.computation.ComputationMapper

matrixValueClass() - Method in class pegasus.mapreduce.diameter.DiameterComputation.DiameterMapper

matrixValueClass() - Method in class pegasus.mapreduce.pagerank.PageRankComputation.PageRankMapper

matrixValueClass() - Method in class pegasus.mapreduce.sssp.SSSPComputation.SSSPMapper

maxIterations() - Method in class pegasus.mapreduce.common.computation.ComputationMapper

MaxIterations - Static variable in class pegasus.mapreduce.common.Constants

maxMemoryBytes() - Static method in class pegasus.mapreduce.common.utils.MemoryUtils

Returns the maximum heap size in bytes.

MaxNumWorkers - Static variable in class pegasus.mapreduce.common.Constants

maxVertex - Variable in class pegasus.mapreduce.common.prepartitioning.GraphPrepartitioningReducer

MemoryUtils - Class in pegasus.mapreduce.common.utils

Provides some memory utility methods to inspect current memory status.

MemoryUtils() - Constructor for class pegasus.mapreduce.common.utils.MemoryUtils

merge(LongIntPairMapWritable) - Method in class pegasus.mapreduce.common.types.LongIntPairMapWritable

minmax_path - Variable in class pegasus.mapreduce.netray.NetRayScatter

MutexBarrier - Class in pegasus.mapreduce.common.coordination

MutexBarrier(ZooKeeper, String, int, boolean) - Constructor for class pegasus.mapreduce.common.coordination.MutexBarrier

N

negativeInfinite() - Method in class pegasus.mapreduce.common.coordination.ZookeeperBooleanCounter

negativeInfinite() - Method in class pegasus.mapreduce.common.coordination.ZookeeperCounter

negativeInfinite() - Method in class pegasus.mapreduce.common.coordination.ZookeeperDoubleCounter

negativeInfinite() - Method in class pegasus.mapreduce.common.coordination.ZookeeperIntegerCounter

negativeInfinite() - Method in class pegasus.mapreduce.common.coordination.ZookeeperLongCounter

NetRayScatter - Class in pegasus.mapreduce.netray

NetRayScatter() - Constructor for class pegasus.mapreduce.netray.NetRayScatter

NetRayScatter.MapStage1 - Class in pegasus.mapreduce.netray

NetRayScatter.MapStage2 - Class in pegasus.mapreduce.netray

NetRayScatter.RedStage1 - Class in pegasus.mapreduce.netray

NetRayScatter.RedStage2 - Class in pegasus.mapreduce.netray

NetRaySpy - Class in pegasus.mapreduce.netray

NetRaySpy() - Constructor for class pegasus.mapreduce.netray.NetRaySpy

NetRaySpy.MapStage1 - Class in pegasus.mapreduce.netray

NetRaySpy.RedStage1 - Class in pegasus.mapreduce.netray

next() - Method in interface pegasus.mapreduce.common.cache.MatrixIterator

next() - Method in interface pegasus.mapreduce.common.cache.VectorIterator

next() - Method in class pegasus.mapreduce.common.io.LongIteratorFromDirectInput

nextKeyValue() - Method in class pegasus.mapreduce.common.io.MatrixRecordReader

nextKeyValue() - Method in class pegasus.mapreduce.common.io.UnweightedAdjacencyListInputFormat.AdjacencyListRecordReader

nextKeyValue() - Method in class pegasus.mapreduce.common.io.UnweightedEdgeListInputFormat.EdgeRecordReader

nextKeyValue() - Method in class pegasus.mapreduce.common.io.VectorRecordReader

nextKeyValue() - Method in class pegasus.mapreduce.common.io.WeightedEdgeListInputFormat.EdgeRecordReader

nodeSize - Variable in class pegasus.mapreduce.subgraph.PrePartition

nodeSize - Variable in class pegasus.mapreduce.triangle.PrePartition

notifyChanged() - Method in class pegasus.mapreduce.common.computation.ComputationMapper

nreducer - Variable in class pegasus.mapreduce.netray.NetRayScatter

nreducer - Variable in class pegasus.mapreduce.netray.NetRaySpy

numBlocks - Variable in class pegasus.mapreduce.common.cache.BaseVectorCache

numBlocks() - Method in class pegasus.mapreduce.common.computation.ComputationMapper

numBlocks - Variable in class pegasus.mapreduce.common.prepartitioning.GraphPrepartitioningReducer

numChanges - Variable in class pegasus.mapreduce.cc.old.PALargeStarOpt

numChanges - Variable in class pegasus.mapreduce.cc.old.PASmallStarOpt

numChanges - Variable in class pegasus.mapreduce.cc.PASmallStarOpt

numDenseCols - Variable in class pegasus.mapreduce.common.prepartitioning.GraphPrepartitioningReducer

numDenseRows - Variable in class pegasus.mapreduce.common.prepartitioning.GraphPrepartitioningReducer

numEntries - Variable in class pegasus.mapreduce.common.types.ColumnEntry

numEntries - Variable in class pegasus.mapreduce.common.types.WeightedColumnEntry

numNonzeros() - Method in interface pegasus.mapreduce.common.cache.MatrixIterator

numSparseCols - Variable in class pegasus.mapreduce.common.prepartitioning.GraphPrepartitioningReducer

numSparseRows - Variable in class pegasus.mapreduce.common.prepartitioning.GraphPrepartitioningReducer

numVertices - Variable in class pegasus.mapreduce.common.cache.BaseVectorCache

numVertices() - Method in class pegasus.mapreduce.common.computation.ComputationMapper

O

or(BitStrings) - Method in class pegasus.mapreduce.common.types.BitStrings

Applies bitwise-or operation on itself and the given bitstrings and assigns the result of operation.

orig_nnodes - Variable in class pegasus.mapreduce.netray.NetRayScatter

orig_nnodes - Variable in class pegasus.mapreduce.netray.NetRaySpy

output_path - Variable in class pegasus.mapreduce.netray.NetRayScatter

output_path - Variable in class pegasus.mapreduce.netray.NetRaySpy

output_prefix - Variable in class pegasus.mapreduce.netray.NetRaySpy

OutputConfig(Output[], Output[], int) - Constructor for class pegasus.mapreduce.common.io.BaseMatrixOutputFormat.OutputConfig

outputSize - Variable in class pegasus.mapreduce.cc.Initialization

outputSize - Variable in class pegasus.mapreduce.cc.old.Initialization

outputSize - Variable in class pegasus.mapreduce.cc.old.UnionFind

outSize - Variable in class pegasus.mapreduce.cc.old.PALargeStarOpt

outSize - Variable in class pegasus.mapreduce.cc.old.PASmallStarOpt

outSize - Variable in class pegasus.mapreduce.cc.PASmallStarOpt

P

PACC - Class in pegasus.mapreduce.cc.old

PACC() - Constructor for class pegasus.mapreduce.cc.old.PACC

PACC - Class in pegasus.mapreduce.cc

PACC() - Constructor for class pegasus.mapreduce.cc.PACC

PageRankComputation - Class in pegasus.mapreduce.pagerank

Computes the PageRank score for the given graph.

PageRankComputation() - Constructor for class pegasus.mapreduce.pagerank.PageRankComputation

PageRankComputation.PageRankMapper - Class in pegasus.mapreduce.pagerank

PageRankDampingFactor - Static variable in class pegasus.mapreduce.common.Constants

PageRankMapper() - Constructor for class pegasus.mapreduce.pagerank.PageRankComputation.PageRankMapper

PageRankSourceVertex - Static variable in class pegasus.mapreduce.common.Constants

PageRankSumBarrier - Static variable in class pegasus.mapreduce.common.Constants

PageRankSumCounter - Static variable in class pegasus.mapreduce.common.Constants

PageRankThreshold - Static variable in class pegasus.mapreduce.common.Constants

PALargeStarOpt - Class in pegasus.mapreduce.cc.old

PALargeStarOpt(Path, Path, boolean) - Constructor for class pegasus.mapreduce.cc.old.PALargeStarOpt

PALargeStarOpt - Class in pegasus.mapreduce.cc

PALargeStarOpt.ColorLargeStarCombiner - Class in pegasus.mapreduce.cc

PALargeStarOpt.ColorLargeStarMapper - Class in pegasus.mapreduce.cc.old

PALargeStarOpt.ColorLargeStarMapper - Class in pegasus.mapreduce.cc

PALargeStarOpt.ColorLargeStarReducer - Class in pegasus.mapreduce.cc.old

PALargeStarOpt.ColorLargeStarReducer - Class in pegasus.mapreduce.cc

Parallelism - Static variable in class pegasus.mapreduce.common.Constants

parsePatternString(String) - Method in class pegasus.mapreduce.subgraph.VF2_degree

partitionGraph(String, String, int) - Method in class pegasus.mapreduce.triangle.PrePartition

partition the graph

PASmallStarCombiner() - Constructor for class pegasus.mapreduce.cc.PASmallStarOpt.PASmallStarCombiner

PASmallStarMapper() - Constructor for class pegasus.mapreduce.cc.PASmallStarOpt.PASmallStarMapper

PASmallStarOpt - Class in pegasus.mapreduce.cc.old

PASmallStarOpt(Path, Path, boolean) - Constructor for class pegasus.mapreduce.cc.old.PASmallStarOpt

PASmallStarOpt - Class in pegasus.mapreduce.cc

PASmallStarOpt(Path, Path, boolean) - Constructor for class pegasus.mapreduce.cc.PASmallStarOpt

constructor

PASmallStarOpt.ColorSmallStarCombiner - Class in pegasus.mapreduce.cc.old

PASmallStarOpt.ColorSmallStarMapper - Class in pegasus.mapreduce.cc.old

PASmallStarOpt.ColorSmallStarReducer - Class in pegasus.mapreduce.cc.old

PASmallStarOpt.PASmallStarCombiner - Class in pegasus.mapreduce.cc

PASmallStarOpt.PASmallStarMapper - Class in pegasus.mapreduce.cc

PASmallStarOpt.PASmallStarReducer - Class in pegasus.mapreduce.cc

PASmallStarReducer() - Constructor for class pegasus.mapreduce.cc.PASmallStarOpt.PASmallStarReducer

path - Variable in class pegasus.mapreduce.common.cache.BaseMatrixCache

pegasus.mapreduce.cc - package pegasus.mapreduce.cc

pegasus.mapreduce.cc.old - package pegasus.mapreduce.cc.old

pegasus.mapreduce.common - package pegasus.mapreduce.common

pegasus.mapreduce.common.cache - package pegasus.mapreduce.common.cache

pegasus.mapreduce.common.computation - package pegasus.mapreduce.common.computation

pegasus.mapreduce.common.coordination - package pegasus.mapreduce.common.coordination

pegasus.mapreduce.common.io - package pegasus.mapreduce.common.io

pegasus.mapreduce.common.prepartitioning - package pegasus.mapreduce.common.prepartitioning

pegasus.mapreduce.common.types - package pegasus.mapreduce.common.types

pegasus.mapreduce.common.utils - package pegasus.mapreduce.common.utils

pegasus.mapreduce.degree - package pegasus.mapreduce.degree

pegasus.mapreduce.diameter - package pegasus.mapreduce.diameter

pegasus.mapreduce.graphgen - package pegasus.mapreduce.graphgen

pegasus.mapreduce.netray - package pegasus.mapreduce.netray

pegasus.mapreduce.pagerank - package pegasus.mapreduce.pagerank

pegasus.mapreduce.sssp - package pegasus.mapreduce.sssp

pegasus.mapreduce.subgraph - package pegasus.mapreduce.subgraph

pegasus.mapreduce.triangle - package pegasus.mapreduce.triangle

pegasus.mapreduce.triangle.deprecated - package pegasus.mapreduce.triangle.deprecated

PersonalizedPageRank - Static variable in class pegasus.mapreduce.common.Constants

PGMapper() - Constructor for class pegasus.mapreduce.subgraph.PrePartition.PGMapper

PGMapper() - Constructor for class pegasus.mapreduce.triangle.PrePartition.PGMapper

PGReducer() - Constructor for class pegasus.mapreduce.subgraph.PrePartition.PGReducer

PGReducer() - Constructor for class pegasus.mapreduce.triangle.PrePartition.PGReducer

PHI - Static variable in class pegasus.mapreduce.common.Constants

positiveInfinite() - Method in class pegasus.mapreduce.common.coordination.ZookeeperBooleanCounter

positiveInfinite() - Method in class pegasus.mapreduce.common.coordination.ZookeeperCounter

positiveInfinite() - Method in class pegasus.mapreduce.common.coordination.ZookeeperDoubleCounter

positiveInfinite() - Method in class pegasus.mapreduce.common.coordination.ZookeeperIntegerCounter

positiveInfinite() - Method in class pegasus.mapreduce.common.coordination.ZookeeperLongCounter

PrePartition - Class in pegasus.mapreduce.subgraph

PrePartition() - Constructor for class pegasus.mapreduce.subgraph.PrePartition

PrePartition - Class in pegasus.mapreduce.triangle

PrePartition() - Constructor for class pegasus.mapreduce.triangle.PrePartition

PrePartition.PGMapper - Class in pegasus.mapreduce.subgraph

PrePartition.PGMapper - Class in pegasus.mapreduce.triangle

PrePartition.PGReducer - Class in pegasus.mapreduce.subgraph

PrePartition.PGReducer - Class in pegasus.mapreduce.triangle

PrepartitioningCombiner() - Constructor for class pegasus.mapreduce.common.prepartitioning.UnweightedGraphPrepartitioning.PrepartitioningCombiner

PrepartitioningCombiner() - Constructor for class pegasus.mapreduce.common.prepartitioning.WeightedGraphPrepartitioning.PrepartitioningCombiner

PrepartitioningPartitioner - Class in pegasus.mapreduce.common.prepartitioning

PrepartitioningPartitioner() - Constructor for class pegasus.mapreduce.common.prepartitioning.PrepartitioningPartitioner

PrepartitioningReducer() - Constructor for class pegasus.mapreduce.common.prepartitioning.UnweightedGraphPrepartitioning.PrepartitioningReducer

PrepartitioningReducer() - Constructor for class pegasus.mapreduce.common.prepartitioning.WeightedGraphPrepartitioning.PrepartitioningReducer

print(String, String) - Method in class pegasus.mapreduce.common.io.ExternalSorter

printUsage() - Static method in class pegasus.mapreduce.netray.NetRayScatter

printUsage() - Static method in class pegasus.mapreduce.netray.NetRaySpy

process(WatchedEvent) - Method in class pegasus.mapreduce.common.coordination.CoordinationService

process(WatchedEvent) - Method in class pegasus.mapreduce.common.coordination.MutexBarrier

process(WatchedEvent) - Method in class pegasus.mapreduce.common.coordination.SemaphoreBarrier

PSE - Class in pegasus.mapreduce.subgraph

PSE() - Constructor for class pegasus.mapreduce.subgraph.PSE

PSE.SubgraphEnumerationMapper - Class in pegasus.mapreduce.subgraph

PTE - Class in pegasus.mapreduce.triangle

PTE() - Constructor for class pegasus.mapreduce.triangle.PTE

PTE.TriangleCountingMapper - Class in pegasus.mapreduce.triangle

PTE.TriangleListingMapper - Class in pegasus.mapreduce.triangle

PTE_cd - Class in pegasus.mapreduce.triangle.deprecated

PTE_cd() - Constructor for class pegasus.mapreduce.triangle.deprecated.PTE_cd

PTE_cd.TriangleEnumerationMapper - Class in pegasus.mapreduce.triangle.deprecated

put(IntIntPairWritable, M) - Method in class pegasus.mapreduce.common.cache.BaseMatrixCache

put(int, V) - Method in class pegasus.mapreduce.common.cache.BaseVectorCache

put(int, BitStrings) - Method in class pegasus.mapreduce.common.cache.BitStringsVectorCache

put(int, DoubleWritable) - Method in class pegasus.mapreduce.common.cache.DoubleVectorCache

put(IntIntPairWritable, V) - Method in interface pegasus.mapreduce.common.cache.MatrixCache

put(int, V) - Method in interface pegasus.mapreduce.common.cache.VectorCache

putToMemory(IntIntPairWritable, M) - Method in class pegasus.mapreduce.common.cache.BaseMatrixCache

putToMemory(IntIntPairWritable, IntArrayWritable) - Method in class pegasus.mapreduce.common.cache.UnweightedMatrixCache

putToMemory(IntIntPairWritable, IntDoublePairArrayWritable) - Method in class pegasus.mapreduce.common.cache.WeightedMatrixCache

R

RadiiMapper() - Constructor for class pegasus.mapreduce.diameter.DiameterComputation.RadiiMapper

RadiiReducer() - Constructor for class pegasus.mapreduce.diameter.DiameterComputation.RadiiReducer

RandomGenerator - Class in pegasus.mapreduce.graphgen

RandomGenerator() - Constructor for class pegasus.mapreduce.graphgen.RandomGenerator

RandomGenerator.RandomGeneratorMapper - Class in pegasus.mapreduce.graphgen

RandomGeneratorMapper() - Constructor for class pegasus.mapreduce.graphgen.RandomGenerator.RandomGeneratorMapper

readFields(DataInput) - Method in class pegasus.mapreduce.common.io.ComputationTaskSplit

readFields(DataInput) - Method in class pegasus.mapreduce.common.io.LongPairWritable

readFields(DataInput) - Method in class pegasus.mapreduce.common.types.BitStrings

Read bitstring values from an input stream.

readFields(DataInput) - Method in class pegasus.mapreduce.common.types.IntArrayWritable

readFields(DataInput) - Method in class pegasus.mapreduce.common.types.IntDoublePairArrayWritable

readFields(DataInput) - Method in class pegasus.mapreduce.common.types.IntDoublePairWritable

readFields(DataInput) - Method in class pegasus.mapreduce.common.types.IntIntPairWritable

readFields(DataInput) - Method in class pegasus.mapreduce.common.types.LongArrayWritable

readFields(DataInput) - Method in class pegasus.mapreduce.common.types.LongDoublePairArrayWritable

readFields(DataInput) - Method in class pegasus.mapreduce.common.types.LongIntPairMapWritable

readFields(DataInput) - Method in class pegasus.mapreduce.common.types.LongIntPairWritable

readInt() - Method in class pegasus.mapreduce.common.io.DirectReader

readLong() - Method in class pegasus.mapreduce.common.io.DirectReader

readMinMax(String) - Method in class pegasus.mapreduce.netray.NetRayScatter

RedStage1() - Constructor for class pegasus.mapreduce.netray.NetRayScatter.RedStage1

RedStage1() - Constructor for class pegasus.mapreduce.netray.NetRaySpy.RedStage1

RedStage2() - Constructor for class pegasus.mapreduce.netray.NetRayScatter.RedStage2

reduce(IntWritable, Iterable<LongPairWritable>, Reducer<IntWritable, LongPairWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.Finalization.LargeStarReducer

the reduce function.

reduce(IntWritable, Iterable<LongPairWritable>, Reducer<IntWritable, LongPairWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.old.Finalization.LargeStarReducer

reduce(LongWritable, Iterable<LongWritable>, Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.old.PALargeStarOpt.ColorLargeStarReducer

reduce(LongWritable, Iterable<LongWritable>, Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.old.PASmallStarOpt.ColorSmallStarCombiner

reduce(LongWritable, Iterable<LongWritable>, Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.old.PASmallStarOpt.ColorSmallStarReducer

reduce(LongWritable, Iterable<LongWritable>, Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.PALargeStarOpt.ColorLargeStarCombiner

the combiner function of PALargeStarOpt

reduce(LongWritable, Iterable<LongWritable>, Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.PALargeStarOpt.ColorLargeStarReducer

the reduce function of PALargeStarOpt

reduce(LongWritable, Iterable<LongWritable>, Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.PASmallStarOpt.PASmallStarCombiner

the combiner function of PASmallStarOpt

reduce(LongWritable, Iterable<LongWritable>, Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.PASmallStarOpt.PASmallStarReducer

the reudce function of PASmallStarOpt

reduce(LongWritable, Iterable<LongArrayWritable>, Reducer<LongWritable, LongArrayWritable, LongWritable, LongArrayWritable>.Context) - Method in class pegasus.mapreduce.common.prepartitioning.UnweightedGraphPrepartitioning.PrepartitioningCombiner

reduce(LongWritable, Iterable<LongArrayWritable>, Reducer<LongWritable, LongArrayWritable, IntWritable, ColumnEntry>.Context) - Method in class pegasus.mapreduce.common.prepartitioning.UnweightedGraphPrepartitioning.PrepartitioningReducer

reduce(LongWritable, Iterable<LongDoublePairArrayWritable>, Reducer<LongWritable, LongDoublePairArrayWritable, LongWritable, LongDoublePairArrayWritable>.Context) - Method in class pegasus.mapreduce.common.prepartitioning.WeightedGraphPrepartitioning.PrepartitioningCombiner

reduce(LongWritable, Iterable<LongDoublePairArrayWritable>, Reducer<LongWritable, LongDoublePairArrayWritable, IntWritable, WeightedColumnEntry>.Context) - Method in class pegasus.mapreduce.common.prepartitioning.WeightedGraphPrepartitioning.PrepartitioningReducer

reduce(LongWritable, Iterable<IntWritable>, Reducer<LongWritable, IntWritable, LongWritable, IntWritable>.Context) - Method in class pegasus.mapreduce.degree.DegreeComputation.DegreeReducer

reduce(LongWritable, Iterable<IntDoublePairWritable>, Reducer<LongWritable, IntDoublePairWritable, LongWritable, IntWritable>.Context) - Method in class pegasus.mapreduce.diameter.DiameterComputation.RadiiReducer

reduce(IntWritable, Iterable<DoubleWritable>, Reducer<IntWritable, DoubleWritable, IntWritable, DoubleWritable>.Context) - Method in class pegasus.mapreduce.netray.NetRayScatter.RedStage1

reduce(Text, Iterable<LongWritable>, Reducer<Text, LongWritable, Text, LongWritable>.Context) - Method in class pegasus.mapreduce.netray.NetRayScatter.RedStage2

reduce(Text, Iterable<LongWritable>, Reducer<Text, LongWritable, Text, LongWritable>.Context) - Method in class pegasus.mapreduce.netray.NetRaySpy.RedStage1

reduce(ShortWritable, Iterable<LongWritable>, Reducer<ShortWritable, LongWritable, NullWritable, NullWritable>.Context) - Method in class pegasus.mapreduce.subgraph.PrePartition.PGReducer

The reduce function of pre-partitioning

reduce(LongWritable, Iterable<LongWritable>, Reducer<LongWritable, LongWritable, LongPairWritable, IntWritable>.Context) - Method in class pegasus.mapreduce.triangle.EdgeOrder.EOStep1Reducer

The reduce function of the first step

reduce(LongPairWritable, Iterable<IntWritable>, Reducer<LongPairWritable, IntWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.triangle.EdgeOrder.EOStep2Reducer

The reduce function of the second step

reduce(ShortWritable, Iterable<LongWritable>, Reducer<ShortWritable, LongWritable, NullWritable, NullWritable>.Context) - Method in class pegasus.mapreduce.triangle.PrePartition.PGReducer

The reduce function of pre-partitioning

remove(int) - Method in class pegasus.mapreduce.common.cache.BitSet

reportStats(String, long) - Method in class pegasus.mapreduce.common.computation.ComputationMapper

reset() - Method in class pegasus.mapreduce.common.io.DirectReader

rewind(int) - Method in class pegasus.mapreduce.common.io.DirectReader

RMATGenerator - Class in pegasus.mapreduce.graphgen

RMATGenerator() - Constructor for class pegasus.mapreduce.graphgen.RMATGenerator

RMATGenerator.RMATGeneratorMapper - Class in pegasus.mapreduce.graphgen

RMATGeneratorMapper() - Constructor for class pegasus.mapreduce.graphgen.RMATGenerator.RMATGeneratorMapper

rowList - Variable in class pegasus.mapreduce.common.cache.BaseMatrixCache

rows - Variable in class pegasus.mapreduce.common.types.ColumnEntry

rows - Variable in class pegasus.mapreduce.common.types.WeightedColumnEntry

rowSizes - Variable in class pegasus.mapreduce.common.cache.BaseMatrixCache

run(String[]) - Method in class pegasus.mapreduce.cc.Finalization

submit the hadoop job

run(String[]) - Method in class pegasus.mapreduce.cc.Initialization

run(String[]) - Method in class pegasus.mapreduce.cc.old.Finalization

run(String[]) - Method in class pegasus.mapreduce.cc.old.Initialization

run(String[]) - Method in class pegasus.mapreduce.cc.old.PACC

run(String[]) - Method in class pegasus.mapreduce.cc.old.PALargeStarOpt

run(String[]) - Method in class pegasus.mapreduce.cc.old.PASmallStarOpt

run(String[]) - Method in class pegasus.mapreduce.cc.old.UnionFind

run(String[]) - Method in class pegasus.mapreduce.cc.PACC

submit the hadoop job

run(String[]) - Method in class pegasus.mapreduce.cc.PALargeStarOpt

submit the hadoop job

run(String[]) - Method in class pegasus.mapreduce.cc.PASmallStarOpt

submit the hadoop job

run(String[]) - Method in class pegasus.mapreduce.cc.UnionFind

run union-find.

run(Mapper<NullWritable, NullWritable, LongWritable, OV>.Context) - Method in class pegasus.mapreduce.common.computation.ComputationMapper

run(String[]) - Method in class pegasus.mapreduce.common.prepartitioning.UnweightedGraphPrepartitioning

run(String[]) - Method in class pegasus.mapreduce.common.prepartitioning.WeightedGraphPrepartitioning

run(String[]) - Method in class pegasus.mapreduce.degree.DegreeComputation

run(String[]) - Method in class pegasus.mapreduce.diameter.DiameterComputation

run(String[]) - Method in class pegasus.mapreduce.graphgen.KroneckerGenerator

submit the hadoop job of the Kronecker graph generator.

run(String[]) - Method in class pegasus.mapreduce.graphgen.RandomGenerator

Submit the hadoop job of generating a random graph.

run(String[]) - Method in class pegasus.mapreduce.graphgen.RMATGenerator

Submit the hadoop job of RMAT generator.

run(String[]) - Method in class pegasus.mapreduce.netray.NetRayScatter

run(String[]) - Method in class pegasus.mapreduce.netray.NetRaySpy

run(String[]) - Method in class pegasus.mapreduce.pagerank.PageRankComputation

run(String[]) - Method in class pegasus.mapreduce.sssp.SSSPComputation

run(String[]) - Method in class pegasus.mapreduce.subgraph.PrePartition

submit the hadoop job for pre-partitioning

run(String[]) - Method in class pegasus.mapreduce.subgraph.PSE

Submit the hadoop job of PSE

run(String[]) - Method in class pegasus.mapreduce.triangle.deprecated.PTE_cd

run(String[]) - Method in class pegasus.mapreduce.triangle.EdgeOrder

run(String[]) - Method in class pegasus.mapreduce.triangle.PrePartition

submit the hadoop job for pre-partitioning

run(String[]) - Method in class pegasus.mapreduce.triangle.PTE

submit the hadoop job of PTE

S

s_over_n - Variable in class pegasus.mapreduce.netray.NetRaySpy

SeedGenerator - Class in pegasus.mapreduce.subgraph

SeedGenerator() - Constructor for class pegasus.mapreduce.subgraph.SeedGenerator

SemaphoreBarrier - Class in pegasus.mapreduce.common.coordination

SemaphoreBarrier(ZooKeeper, String, int, int, boolean) - Constructor for class pegasus.mapreduce.common.coordination.SemaphoreBarrier

set(long, long) - Method in class pegasus.mapreduce.common.io.LongPairWritable

set(int) - Method in class pegasus.mapreduce.common.types.IntArrayWritable

set(int[]) - Method in class pegasus.mapreduce.common.types.IntArrayWritable

set(int[], int, int) - Method in class pegasus.mapreduce.common.types.IntArrayWritable

set(IntArrayList) - Method in class pegasus.mapreduce.common.types.IntArrayWritable

set(int, double) - Method in class pegasus.mapreduce.common.types.IntDoublePairArrayWritable

set(int[], double[], int, int) - Method in class pegasus.mapreduce.common.types.IntDoublePairArrayWritable

set(IntArrayList, DoubleArrayList) - Method in class pegasus.mapreduce.common.types.IntDoublePairArrayWritable

set(int, double) - Method in class pegasus.mapreduce.common.types.IntDoublePairWritable

set(int, int) - Method in class pegasus.mapreduce.common.types.IntIntPairWritable

set(long) - Method in class pegasus.mapreduce.common.types.LongArrayWritable

set(long[]) - Method in class pegasus.mapreduce.common.types.LongArrayWritable

set(long[], int, int) - Method in class pegasus.mapreduce.common.types.LongArrayWritable

set(LongArrayList) - Method in class pegasus.mapreduce.common.types.LongArrayWritable

set(long, double) - Method in class pegasus.mapreduce.common.types.LongDoublePairArrayWritable

set(long[], double[], int, int) - Method in class pegasus.mapreduce.common.types.LongDoublePairArrayWritable

set(LongArrayList, DoubleArrayList) - Method in class pegasus.mapreduce.common.types.LongDoublePairArrayWritable

setBasePaths(String[]) - Static method in class pegasus.mapreduce.common.io.LocalPaths

setBit(int, long) - Method in class pegasus.mapreduce.common.types.BitStrings

Sets i-th sub-bitstring to the given bit values.

setBits(long[]) - Method in class pegasus.mapreduce.common.types.BitStrings

Sets the value of bitstring to the given bit values.

setContext(Mapper<Object, Text, Text, NullWritable>.Context) - Method in class pegasus.mapreduce.subgraph.VF2_degree

setEstimatedSize(Job) - Static method in class pegasus.mapreduce.common.computation.ComputationMapper

setFirst(int) - Method in class pegasus.mapreduce.common.types.IntIntPairWritable

setId(long) - Method in class pegasus.mapreduce.common.types.LongIntPairWritable

setSecond(int) - Method in class pegasus.mapreduce.common.types.IntIntPairWritable

setup(Mapper<LongWritable, LongWritable, IntWritable, LongPairWritable>.Context) - Method in class pegasus.mapreduce.cc.Finalization.LargeStarMapper

setup before execution

setup(Mapper<LongWritable, LongWritable, IntWritable, LongPairWritable>.Context) - Method in class pegasus.mapreduce.cc.old.Finalization.LargeStarMapper

setup(Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.old.PALargeStarOpt.ColorLargeStarReducer

setup(Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.old.PASmallStarOpt.ColorSmallStarReducer

setup(Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.PALargeStarOpt.ColorLargeStarCombiner

setup before execution

setup(Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.PALargeStarOpt.ColorLargeStarReducer

setup before execution

setup(Reducer<LongWritable, LongWritable, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.cc.PASmallStarOpt.PASmallStarReducer

setup before execution

setup() - Method in interface pegasus.mapreduce.common.coordination.Barrier

Initializes the barrier.

setup(TaskAttemptContext) - Method in class pegasus.mapreduce.common.coordination.CoordinationService

setup() - Method in class pegasus.mapreduce.common.coordination.MutexBarrier

setup() - Method in class pegasus.mapreduce.common.coordination.SemaphoreBarrier

setup(Reducer<LongWritable, IV, IntWritable, OV>.Context) - Method in class pegasus.mapreduce.common.prepartitioning.GraphPrepartitioningReducer

setup(Reducer<LongWritable, LongArrayWritable, IntWritable, ColumnEntry>.Context) - Method in class pegasus.mapreduce.common.prepartitioning.UnweightedGraphPrepartitioning.PrepartitioningReducer

setup(Reducer<LongWritable, LongDoublePairArrayWritable, IntWritable, WeightedColumnEntry>.Context) - Method in class pegasus.mapreduce.common.prepartitioning.WeightedGraphPrepartitioning.PrepartitioningReducer

setup(Reducer<LongWritable, IntDoublePairWritable, LongWritable, IntWritable>.Context) - Method in class pegasus.mapreduce.diameter.DiameterComputation.RadiiReducer

setup(Mapper<IntWritable, KroneckerGenerator.RegionSlot, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.graphgen.KroneckerGenerator.KroneckerGeneratorMapper

Setup before execution.

setup(Mapper<IntWritable, RandomGenerator.RegionSlot, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.graphgen.RandomGenerator.RandomGeneratorMapper

Setup before execution

setup(Mapper<IntWritable, RMATGenerator.RegionSlot, LongWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.graphgen.RMATGenerator.RMATGeneratorMapper

Setup before execution.

setup(Mapper<LongWritable, Text, IntWritable, DoubleWritable>.Context) - Method in class pegasus.mapreduce.netray.NetRayScatter.MapStage1

setup(Mapper<LongWritable, Text, Text, LongWritable>.Context) - Method in class pegasus.mapreduce.netray.NetRayScatter.MapStage2

setup(Mapper<LongWritable, Text, Text, LongWritable>.Context) - Method in class pegasus.mapreduce.netray.NetRaySpy.MapStage1

setup(Mapper<Object, Text, ShortWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.subgraph.PrePartition.PGMapper

setup before execution.

setup(Reducer<ShortWritable, LongWritable, NullWritable, NullWritable>.Context) - Method in class pegasus.mapreduce.subgraph.PrePartition.PGReducer

setup before execution.

setup(Mapper<Object, Text, Text, NullWritable>.Context) - Method in class pegasus.mapreduce.subgraph.PSE.SubgraphEnumerationMapper

setup before execution.

setup(Mapper<Object, Text, NullWritable, NullWritable>.Context) - Method in class pegasus.mapreduce.triangle.deprecated.PTE_cd.TriangleEnumerationMapper

setup(Mapper<LongWritable, LongWritable, ShortWritable, LongWritable>.Context) - Method in class pegasus.mapreduce.triangle.PrePartition.PGMapper

setup before execution.

setup(Reducer<ShortWritable, LongWritable, NullWritable, NullWritable>.Context) - Method in class pegasus.mapreduce.triangle.PrePartition.PGReducer

setup before execution.

setup(Mapper<Object, Text, Text, NullWritable>.Context) - Method in class pegasus.mapreduce.triangle.PTE.TriangleCountingMapper

setup before execution

setup(Mapper<Object, Text, Text, NullWritable>.Context) - Method in class pegasus.mapreduce.triangle.PTE.TriangleListingMapper

setup before execution.

setupComputation(Mapper<NullWritable, NullWritable, LongWritable, OV>.Context, CoordinationService) - Method in class pegasus.mapreduce.common.computation.ComputationMapper

setupComputation(Mapper<NullWritable, NullWritable, LongWritable, DoubleWritable>.Context, CoordinationService) - Method in class pegasus.mapreduce.pagerank.PageRankComputation.PageRankMapper

setupComputation(Mapper<NullWritable, NullWritable, LongWritable, DoubleWritable>.Context, CoordinationService) - Method in class pegasus.mapreduce.sssp.SSSPComputation.SSSPMapper

setValue(int) - Method in class pegasus.mapreduce.common.types.LongIntPairWritable

size - Variable in class pegasus.mapreduce.common.cache.BaseVectorCache

size() - Method in class pegasus.mapreduce.common.cache.BaseVectorCache

size() - Method in interface pegasus.mapreduce.common.cache.VectorCache

size() - Method in class pegasus.mapreduce.common.types.IntArrayWritable

size() - Method in class pegasus.mapreduce.common.types.IntDoublePairArrayWritable

size() - Method in class pegasus.mapreduce.common.types.LongArrayWritable

size() - Method in class pegasus.mapreduce.common.types.LongDoublePairArrayWritable

size() - Method in class pegasus.mapreduce.common.types.LongIntPairMapWritable

SizeOfMemoryBarrier - Static variable in class pegasus.mapreduce.common.Constants

SizeOfVector - Static variable in class pegasus.mapreduce.common.Constants

sm1_over_logn - Variable in class pegasus.mapreduce.netray.NetRaySpy

sm1_over_logxmax_m_logxmin - Variable in class pegasus.mapreduce.netray.NetRayScatter

sm1_over_logymax_m_logymin - Variable in class pegasus.mapreduce.netray.NetRayScatter

sm1_over_xmax_m_xmin - Variable in class pegasus.mapreduce.netray.NetRayScatter

sm1_over_ymax_m_ymin - Variable in class pegasus.mapreduce.netray.NetRayScatter

sort(Iterator<Long>, String[]) - Static method in class pegasus.mapreduce.common.io.ExternalSorter

sparseCols - Variable in class pegasus.mapreduce.common.io.ComputationTaskSplit

sparseOutput - Variable in class pegasus.mapreduce.common.io.BaseMatrixOutputFormat.OutputConfig

sparseRows - Variable in class pegasus.mapreduce.common.io.ComputationTaskSplit

sparseSplits - Variable in class pegasus.mapreduce.common.io.ComputationTaskSplit

SparseVectorKey - Static variable in class pegasus.mapreduce.common.Constants

SSSPComputation - Class in pegasus.mapreduce.sssp

Computes the shortest path from given single source.

SSSPComputation() - Constructor for class pegasus.mapreduce.sssp.SSSPComputation

SSSPComputation.SSSPMapper - Class in pegasus.mapreduce.sssp

SSSPMapper() - Constructor for class pegasus.mapreduce.sssp.SSSPComputation.SSSPMapper

SSSPSourceVertex - Static variable in class pegasus.mapreduce.common.Constants

StatPath - Static variable in class pegasus.mapreduce.common.Constants

statusMessage(String) - Method in class pegasus.mapreduce.common.computation.ComputationMapper

SubgraphEnumerationMapper() - Constructor for class pegasus.mapreduce.subgraph.PSE.SubgraphEnumerationMapper

sumOp() - Method in class pegasus.mapreduce.common.coordination.ZookeeperBooleanCounter

sumOp() - Method in class pegasus.mapreduce.common.coordination.ZookeeperCounter

sumOp() - Method in class pegasus.mapreduce.common.coordination.ZookeeperDoubleCounter

sumOp() - Method in class pegasus.mapreduce.common.coordination.ZookeeperIntegerCounter

sumOp() - Method in class pegasus.mapreduce.common.coordination.ZookeeperLongCounter

svSplit - Variable in class pegasus.mapreduce.common.io.ComputationTaskSplit

svWriter - Variable in class pegasus.mapreduce.common.prepartitioning.GraphPrepartitioningReducer

T

target_nnodes - Variable in class pegasus.mapreduce.netray.NetRayScatter

target_nnodes - Variable in class pegasus.mapreduce.netray.NetRaySpy

taskId - Variable in class pegasus.mapreduce.common.io.ComputationTaskSplit

toString() - Method in class pegasus.mapreduce.common.coordination.MutexBarrier

toString() - Method in class pegasus.mapreduce.common.coordination.SemaphoreBarrier

toString() - Method in class pegasus.mapreduce.common.io.LongPairWritable

toString() - Method in class pegasus.mapreduce.common.types.BitStrings

TransposedMapper() - Constructor for class pegasus.mapreduce.common.prepartitioning.UnweightedGraphPrepartitioning.TransposedMapper

TriangleCountingMapper() - Constructor for class pegasus.mapreduce.triangle.PTE.TriangleCountingMapper

TriangleEnumerationMapper() - Constructor for class pegasus.mapreduce.triangle.deprecated.PTE_cd.TriangleEnumerationMapper

TriangleListingMapper() - Constructor for class pegasus.mapreduce.triangle.PTE.TriangleListingMapper

TypeUtils - Class in pegasus.mapreduce.common.utils

TypeUtils() - Constructor for class pegasus.mapreduce.common.utils.TypeUtils

TypeUtils.IntComparator - Class in pegasus.mapreduce.common.utils

TypeUtils.LongComparator - Class in pegasus.mapreduce.common.utils

U

UndirectedMapper() - Constructor for class pegasus.mapreduce.common.prepartitioning.UnweightedGraphPrepartitioning.UndirectedMapper

UndirectedMapper() - Constructor for class pegasus.mapreduce.common.prepartitioning.WeightedGraphPrepartitioning.UndirectedMapper

union(long, long) - Method in class pegasus.mapreduce.cc.Finalization.LargeStarReducer

the union function of the union-find algorithm.

union(long, long) - Method in class pegasus.mapreduce.cc.old.Finalization.LargeStarReducer

union(long, long) - Method in class pegasus.mapreduce.cc.old.UnionFind

UnionFind - Class in pegasus.mapreduce.cc.old

UnionFind(Path, Path) - Constructor for class pegasus.mapreduce.cc.old.UnionFind

UnionFind - Class in pegasus.mapreduce.cc

UnweightedAdjacencyListInputFormat - Class in pegasus.mapreduce.common.io

UnweightedAdjacencyListInputFormat() - Constructor for class pegasus.mapreduce.common.io.UnweightedAdjacencyListInputFormat

UnweightedAdjacencyListInputFormat.AdjacencyListRecordReader - Class in pegasus.mapreduce.common.io

UnweightedDegreeMapper() - Constructor for class pegasus.mapreduce.degree.DegreeComputation.UnweightedDegreeMapper

UnweightedEdgeListInputFormat - Class in pegasus.mapreduce.common.io

UnweightedEdgeListInputFormat() - Constructor for class pegasus.mapreduce.common.io.UnweightedEdgeListInputFormat

UnweightedEdgeListInputFormat.EdgeRecordReader - Class in pegasus.mapreduce.common.io

UnweightedGraphPrepartitioning - Class in pegasus.mapreduce.common.prepartitioning

Partitions the input unweighted matrix.

UnweightedGraphPrepartitioning() - Constructor for class pegasus.mapreduce.common.prepartitioning.UnweightedGraphPrepartitioning

UnweightedGraphPrepartitioning.DirectedMapper - Class in pegasus.mapreduce.common.prepartitioning

UnweightedGraphPrepartitioning.PrepartitioningCombiner - Class in pegasus.mapreduce.common.prepartitioning

UnweightedGraphPrepartitioning.PrepartitioningReducer - Class in pegasus.mapreduce.common.prepartitioning

UnweightedGraphPrepartitioning.TransposedMapper - Class in pegasus.mapreduce.common.prepartitioning

UnweightedGraphPrepartitioning.UndirectedMapper - Class in pegasus.mapreduce.common.prepartitioning

UnweightedInDegreeMapper() - Constructor for class pegasus.mapreduce.degree.DegreeComputation.UnweightedInDegreeMapper

UnweightedMatrixCache - Class in pegasus.mapreduce.common.cache

UnweightedMatrixCache(String, Configuration, int, int) - Constructor for class pegasus.mapreduce.common.cache.UnweightedMatrixCache

UnweightedMatrixOutputFormat - Class in pegasus.mapreduce.common.io

UnweightedMatrixOutputFormat() - Constructor for class pegasus.mapreduce.common.io.UnweightedMatrixOutputFormat

UnweightedMatrixOutputFormat.MultiBlockWriter - Class in pegasus.mapreduce.common.io

UnweightedOutDegreeMapper() - Constructor for class pegasus.mapreduce.degree.DegreeComputation.UnweightedOutDegreeMapper

update(T) - Method in interface pegasus.mapreduce.common.coordination.Counter

update(Long) - Method in class pegasus.mapreduce.common.coordination.HadoopCounter

update(T) - Method in class pegasus.mapreduce.common.coordination.ZookeeperCounter

V

valueFromString(String) - Method in class pegasus.mapreduce.common.coordination.ZookeeperBooleanCounter

valueFromString(String) - Method in class pegasus.mapreduce.common.coordination.ZookeeperCounter

valueFromString(String) - Method in class pegasus.mapreduce.common.coordination.ZookeeperDoubleCounter

valueFromString(String) - Method in class pegasus.mapreduce.common.coordination.ZookeeperIntegerCounter

valueFromString(String) - Method in class pegasus.mapreduce.common.coordination.ZookeeperLongCounter

valueOf(String) - Static method in enum pegasus.mapreduce.cc.Counters

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum pegasus.mapreduce.cc.old.Counters

Returns the enum constant of this type with the specified name.

values() - Static method in enum pegasus.mapreduce.cc.Counters

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum pegasus.mapreduce.cc.old.Counters

Returns an array containing the constants of this enum type, in the order they are declared.

valueToString(Boolean) - Method in class pegasus.mapreduce.common.coordination.ZookeeperBooleanCounter

valueToString(T) - Method in class pegasus.mapreduce.common.coordination.ZookeeperCounter

valueToString(Double) - Method in class pegasus.mapreduce.common.coordination.ZookeeperDoubleCounter

valueToString(Integer) - Method in class pegasus.mapreduce.common.coordination.ZookeeperIntegerCounter

valueToString(Long) - Method in class pegasus.mapreduce.common.coordination.ZookeeperLongCounter

VectorCache<V extends org.apache.hadoop.io.Writable> - Interface in pegasus.mapreduce.common.cache

VectorIterator<V extends org.apache.hadoop.io.Writable> - Interface in pegasus.mapreduce.common.cache

VectorOutputFormat<V extends org.apache.hadoop.io.Writable> - Class in pegasus.mapreduce.common.io

VectorOutputFormat() - Constructor for class pegasus.mapreduce.common.io.VectorOutputFormat

VectorRecordReader<V extends org.apache.hadoop.io.Writable> - Class in pegasus.mapreduce.common.io

VectorRecordReader(InputStream, TaskAttemptContext, Class<V>) - Constructor for class pegasus.mapreduce.common.io.VectorRecordReader

VectorRecordWriter<V extends org.apache.hadoop.io.Writable> - Class in pegasus.mapreduce.common.io

VectorRecordWriter(OutputStream, TaskAttemptContext) - Constructor for class pegasus.mapreduce.common.io.VectorRecordWriter

vectorValueClass() - Method in class pegasus.mapreduce.common.computation.ComputationMapper

vectorValueClass() - Method in class pegasus.mapreduce.diameter.DiameterComputation.DiameterMapper

vectorValueClass() - Method in class pegasus.mapreduce.pagerank.PageRankComputation.PageRankMapper

vectorValueClass() - Method in class pegasus.mapreduce.sssp.SSSPComputation.SSSPMapper

vf2(int) - Method in class pegasus.mapreduce.subgraph.VF2_degree

VF2_degree - Class in pegasus.mapreduce.subgraph

VF2_degree() - Constructor for class pegasus.mapreduce.subgraph.VF2_degree

W

waitBarrier() - Method in interface pegasus.mapreduce.common.coordination.Barrier

Waits until this barrier is marked as completed.

waitBarrier() - Method in class pegasus.mapreduce.common.coordination.MutexBarrier

waitBarrier() - Method in class pegasus.mapreduce.common.coordination.SemaphoreBarrier

WeightedColumnEntry - Class in pegasus.mapreduce.common.types

WeightedColumnEntry() - Constructor for class pegasus.mapreduce.common.types.WeightedColumnEntry

WeightedDegreeMapper() - Constructor for class pegasus.mapreduce.degree.DegreeComputation.WeightedDegreeMapper

WeightedEdgeListInputFormat - Class in pegasus.mapreduce.common.io

WeightedEdgeListInputFormat() - Constructor for class pegasus.mapreduce.common.io.WeightedEdgeListInputFormat

WeightedEdgeListInputFormat.EdgeRecordReader - Class in pegasus.mapreduce.common.io

WeightedGraphPrepartitioning - Class in pegasus.mapreduce.common.prepartitioning

WeightedGraphPrepartitioning() - Constructor for class pegasus.mapreduce.common.prepartitioning.WeightedGraphPrepartitioning

WeightedGraphPrepartitioning.DirectedMapper - Class in pegasus.mapreduce.common.prepartitioning

WeightedGraphPrepartitioning.PrepartitioningCombiner - Class in pegasus.mapreduce.common.prepartitioning

WeightedGraphPrepartitioning.PrepartitioningReducer - Class in pegasus.mapreduce.common.prepartitioning

WeightedGraphPrepartitioning.UndirectedMapper - Class in pegasus.mapreduce.common.prepartitioning

WeightedInDegreeMapper() - Constructor for class pegasus.mapreduce.degree.DegreeComputation.WeightedInDegreeMapper

WeightedMatrixCache - Class in pegasus.mapreduce.common.cache

WeightedMatrixCache(String, Configuration, int, int) - Constructor for class pegasus.mapreduce.common.cache.WeightedMatrixCache

WeightedMatrixOutputFormat - Class in pegasus.mapreduce.common.io

WeightedMatrixOutputFormat() - Constructor for class pegasus.mapreduce.common.io.WeightedMatrixOutputFormat

WeightedMatrixOutputFormat.MultiBlockWriter - Class in pegasus.mapreduce.common.io

WeightedOutDegreeMapper() - Constructor for class pegasus.mapreduce.degree.DegreeComputation.WeightedOutDegreeMapper

weights - Variable in class pegasus.mapreduce.common.types.WeightedColumnEntry

write(DataOutput) - Method in class pegasus.mapreduce.common.io.ComputationTaskSplit

write(int) - Method in class pegasus.mapreduce.common.io.DirectWriter

write(long) - Method in class pegasus.mapreduce.common.io.DirectWriter

write(DataOutput) - Method in class pegasus.mapreduce.common.io.LongPairWritable

write(IntWritable, ColumnEntry) - Method in class pegasus.mapreduce.common.io.UnweightedMatrixOutputFormat.MultiBlockWriter

write(IntWritable, V) - Method in class pegasus.mapreduce.common.io.VectorRecordWriter

write(IntWritable, WeightedColumnEntry) - Method in class pegasus.mapreduce.common.io.WeightedMatrixOutputFormat.MultiBlockWriter

write(DataOutput) - Method in class pegasus.mapreduce.common.types.BitStrings

Writes bitstring values to an output stream.

write(DataOutput) - Method in class pegasus.mapreduce.common.types.IntArrayWritable

write(DataOutput) - Method in class pegasus.mapreduce.common.types.IntDoublePairArrayWritable

write(DataOutput) - Method in class pegasus.mapreduce.common.types.IntDoublePairWritable

write(DataOutput) - Method in class pegasus.mapreduce.common.types.IntIntPairWritable

write(DataOutput) - Method in class pegasus.mapreduce.common.types.LongArrayWritable

write(DataOutput) - Method in class pegasus.mapreduce.common.types.LongDoublePairArrayWritable

write(DataOutput) - Method in class pegasus.mapreduce.common.types.LongIntPairMapWritable

write(DataOutput) - Method in class pegasus.mapreduce.common.types.LongIntPairWritable

writeIntermediateVecOp(VectorCache<T>, String, int) - Method in class pegasus.mapreduce.common.computation.ComputationMapper

writeOutputVecOp(int, VectorCache<V>) - Method in class pegasus.mapreduce.common.computation.ComputationMapper

writeOutputVecOp(int, VectorCache<BitStrings>) - Method in class pegasus.mapreduce.diameter.DiameterComputation.DiameterMapper

X

x_max - Variable in class pegasus.mapreduce.netray.NetRayScatter

x_min - Variable in class pegasus.mapreduce.netray.NetRayScatter

Y

y_max - Variable in class pegasus.mapreduce.netray.NetRayScatter

y_min - Variable in class pegasus.mapreduce.netray.NetRayScatter

Z

zero() - Method in class pegasus.mapreduce.common.coordination.ZookeeperBooleanCounter

zero() - Method in class pegasus.mapreduce.common.coordination.ZookeeperCounter

zero() - Method in class pegasus.mapreduce.common.coordination.ZookeeperDoubleCounter

zero() - Method in class pegasus.mapreduce.common.coordination.ZookeeperIntegerCounter

zero() - Method in class pegasus.mapreduce.common.coordination.ZookeeperLongCounter

ZookeeperBooleanCounter - Class in pegasus.mapreduce.common.coordination

ZookeeperBooleanCounter(ZooKeeper, String, int) - Constructor for class pegasus.mapreduce.common.coordination.ZookeeperBooleanCounter

ZookeeperCounter<T extends java.lang.Comparable<T>> - Class in pegasus.mapreduce.common.coordination

ZookeeperCounter(ZooKeeper, String, int) - Constructor for class pegasus.mapreduce.common.coordination.ZookeeperCounter

ZookeeperDoubleCounter - Class in pegasus.mapreduce.common.coordination

ZookeeperDoubleCounter(ZooKeeper, String, int) - Constructor for class pegasus.mapreduce.common.coordination.ZookeeperDoubleCounter

ZookeeperIntegerCounter - Class in pegasus.mapreduce.common.coordination

ZookeeperIntegerCounter(ZooKeeper, String, int) - Constructor for class pegasus.mapreduce.common.coordination.ZookeeperIntegerCounter

ZookeeperLongCounter - Class in pegasus.mapreduce.common.coordination

ZookeeperLongCounter(ZooKeeper, String, int) - Constructor for class pegasus.mapreduce.common.coordination.ZookeeperLongCounter

ZookeeperUtils - Class in pegasus.mapreduce.common.utils

ZookeeperUtils() - Constructor for class pegasus.mapreduce.common.utils.ZookeeperUtils

A B C D E F G H I J K L M N O P R S T U V W X Y Z