Package com.alibaba.graphscope.factory

Class GiraphComputationFactory

java.lang.Object

com.alibaba.graphscope.factory.GiraphComputationFactory

public class GiraphComputationFactory
extends Object

Constructor Summary

Constructors

Constructor	Description
GiraphComputationFactory()

Method Summary

Modifier and Type	Method	Description
static <VDATA_T extends org.apache.hadoop.io.Writable,GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> VertexDataManager<VDATA_T>	createDefaultVertexDataManager(ImmutableClassesGiraphConfiguration conf, IFragment<GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> frag, long innerVerticesNum)
static <OID_T extends org.apache.hadoop.io.WritableComparable,GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> GiraphVertexIdManager<GRAPE_VID_T,OID_T>	createDefaultVertexIdManager(ImmutableClassesGiraphConfiguration conf, IFragment<GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> frag, long fragVerticesNum)
static <OID_T,VID_T,VDATA_T,EDATA_T> GiraphComputationAdaptor	createGiraphComputationAdaptor(String className, ImmutableEdgecutFragmentAdaptor<OID_T,VID_T,VDATA_T,EDATA_T> fragment)	Create the giraph computation adaptor for the input fragment.
static <OID_T,VID_T,VDATA_T,EDATA_T> GiraphComputationAdaptorContext	createGiraphComputationAdaptorContext(String className, ImmutableEdgecutFragmentAdaptor<OID_T,VID_T,VDATA_T,EDATA_T> fragment)	Create the giraph computation adaptor context for the input fragment.
static <OID_T extends org.apache.hadoop.io.WritableComparable,EDATA_T extends org.apache.hadoop.io.Writable,GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> GiraphEdgeManager<OID_T,EDATA_T>	createImmutableEdgeManager(ImmutableClassesGiraphConfiguration conf, IFragment<GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> fragment, GiraphVertexIdManager<GRAPE_VID_T,OID_T> vertexIdManager)

Methods inherited from class java.lang.Object

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

Constructor Detail

GiraphComputationFactory

public GiraphComputationFactory()

Method Detail

createGiraphComputationAdaptor

public static <OID_T,VID_T,VDATA_T,EDATA_T> GiraphComputationAdaptor createGiraphComputationAdaptor(String className,
                                                                                                                      ImmutableEdgecutFragmentAdaptor<OID_T,VID_T,VDATA_T,EDATA_T> fragment)

Create the giraph computation adaptor for the input fragment. Use fragment's actual type parameters to initiate a generic adaptor.

Parameters:

className - adaptor class name

fragment - simple fragment, which is parameterized.

Returns:

created adaptor.

createGiraphComputationAdaptorContext

public static <OID_T,VID_T,VDATA_T,EDATA_T> GiraphComputationAdaptorContext createGiraphComputationAdaptorContext(String className,
                                                                                                                                    ImmutableEdgecutFragmentAdaptor<OID_T,VID_T,VDATA_T,EDATA_T> fragment)

Create the giraph computation adaptor context for the input fragment. Use fragment's actual type parameters to initiate a generic adaptor context.

Parameters:

className - adaptor class name

fragment - simple fragment, which is parameterized.

Returns:

created adaptor.

createDefaultVertexDataManager

public static <VDATA_T extends org.apache.hadoop.io.Writable,GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> VertexDataManager<VDATA_T> createDefaultVertexDataManager(ImmutableClassesGiraphConfiguration conf,
                                                                                                                                                                                                    IFragment<GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> frag,
                                                                                                                                                                                                    long innerVerticesNum)

createDefaultVertexIdManager

public static <OID_T extends org.apache.hadoop.io.WritableComparable,GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> GiraphVertexIdManager<GRAPE_VID_T,OID_T> createDefaultVertexIdManager(ImmutableClassesGiraphConfiguration conf,
                                                                                                                                                                                                                              IFragment<GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> frag,
                                                                                                                                                                                                                              long fragVerticesNum)

createImmutableEdgeManager

public static <OID_T extends org.apache.hadoop.io.WritableComparable,EDATA_T extends org.apache.hadoop.io.Writable,GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> GiraphEdgeManager<OID_T,EDATA_T> createImmutableEdgeManager(ImmutableClassesGiraphConfiguration conf,
                                                                                                                                                                                                                                                                        IFragment<GRAPE_OID_T,GRAPE_VID_T,GRAPE_VDATA_T,GRAPE_EDATA_T> fragment,
                                                                                                                                                                                                                                                                        GiraphVertexIdManager<GRAPE_VID_T,OID_T> vertexIdManager)