Package com.alibaba.graphscope.factory

Class GiraphComputationFactory

  • public class GiraphComputationFactory
extends Object

    • 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)