Package com.alibaba.graphscope.graph

Class AbstractEdgeManager<VID_T,GRAPE_OID_T,BIZ_OID_T,GRAPE_ED_T,BIZ_EDATA_T>

java.lang.Object

com.alibaba.graphscope.graph.AbstractEdgeManager<VID_T,GRAPE_OID_T,BIZ_OID_T,GRAPE_ED_T,BIZ_EDATA_T>

Direct Known Subclasses:

DefaultImmutableEdgeManager

public abstract class AbstractEdgeManager<VID_T,GRAPE_OID_T,BIZ_OID_T,GRAPE_ED_T,BIZ_EDATA_T>
extends Object

Defines common behavior for abstract edge manager. Notice about the type parameters, since giraph rely on writable.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	AbstractEdgeManager.CSRHolder
class	AbstractEdgeManager.TupleIterable
class	AbstractEdgeManager.TupleIterator

Field Summary

Fields

Modifier and Type	Field	Description
AbstractEdgeManager.CSRHolder	csrHolder
protected AbstractEdgeManager.TupleIterable	edgeIterable
protected List<AbstractEdgeManager.TupleIterable>	edgeIterables

Constructor Summary

Constructors

Constructor	Description
AbstractEdgeManager()

Method Summary

Modifier and Type	Method	Description
int	getNumEdgesImpl(long lid)
void	init(IFragment<GRAPE_OID_T,VID_T,?,GRAPE_ED_T> fragment, VertexIdManager<VID_T,BIZ_OID_T> vertexIdManager, Class<? extends BIZ_OID_T> bizOidClass, Class<? extends VID_T> vidClass, Class<? extends GRAPE_ED_T> grapeEdataClass, Class<? extends BIZ_EDATA_T> bizEdataClass, BiConsumer<FFIByteVectorInputStream,PrimitiveArray<BIZ_EDATA_T>> consumer)
void	init(IFragment<GRAPE_OID_T,VID_T,?,GRAPE_ED_T> fragment, VertexIdManager<VID_T,BIZ_OID_T> vertexIdManager, Class<? extends BIZ_OID_T> bizOidClass, Class<? extends VID_T> vidClass, Class<? extends GRAPE_ED_T> grapeEdataClass, Class<? extends BIZ_EDATA_T> bizEdataClass, BiConsumer<FFIByteVectorInputStream,PrimitiveArray<BIZ_EDATA_T>> consumer, int numCores)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

csrHolder

public AbstractEdgeManager.CSRHolder csrHolder

edgeIterable

protected AbstractEdgeManager.TupleIterable edgeIterable

edgeIterables

protected List<AbstractEdgeManager.TupleIterable> edgeIterables

Constructor Detail

AbstractEdgeManager

public AbstractEdgeManager()

Method Detail

init

public void init(IFragment<GRAPE_OID_T,VID_T,?,GRAPE_ED_T> fragment,
                 VertexIdManager<VID_T,BIZ_OID_T> vertexIdManager,
                 Class<? extends BIZ_OID_T> bizOidClass,
                 Class<? extends VID_T> vidClass,
                 Class<? extends GRAPE_ED_T> grapeEdataClass,
                 Class<? extends BIZ_EDATA_T> bizEdataClass,
                 BiConsumer<FFIByteVectorInputStream,PrimitiveArray<BIZ_EDATA_T>> consumer)

init

public void init(IFragment<GRAPE_OID_T,VID_T,?,GRAPE_ED_T> fragment,
                 VertexIdManager<VID_T,BIZ_OID_T> vertexIdManager,
                 Class<? extends BIZ_OID_T> bizOidClass,
                 Class<? extends VID_T> vidClass,
                 Class<? extends GRAPE_ED_T> grapeEdataClass,
                 Class<? extends BIZ_EDATA_T> bizEdataClass,
                 BiConsumer<FFIByteVectorInputStream,PrimitiveArray<BIZ_EDATA_T>> consumer,
                 int numCores)

getNumEdgesImpl

public int getNumEdgesImpl(long lid)