Type Parameters:: OID_T - original id type; VID_T - vertex id type; VDATA_T - vertex data type; EDATA_T - edge data type; C - context type

All Superinterfaces:: AppBase<OID_T,VID_T,VDATA_T,EDATA_T,C>

All Known Implementing Classes:: BFS, GraphXParallelAdaptor, PageRank, SSSP, StringApp, Traverse, WCC

public interface ParallelAppBase<OID_T,VID_T,VDATA_T,EDATA_T,C extends ParallelContextBase<OID_T,VID_T,VDATA_T,EDATA_T>>
extends AppBase<OID_T,VID_T,VDATA_T,EDATA_T,C>

The base interface for all parallel PIE apps which work along with ImmutableEdgecutFragment and ParallelMessageManager

To define your sequential graph algorithms, you should implement this interface and provide the corresponding implementation for PEval(IFragment, ParallelContextBase, ParallelMessageManager) and IncEval(IFragment, ParallelContextBase, ParallelMessageManager)

User-defined app shall work along with user-defined context, which should be an implementation of ParallelContextBase.

For example, you can implement your app like this.

{
 class MyContext implements ParallelContextBase<Long, Long, Long, Double>{
      public void Init(ImmutableEdgecutFragment<Long, Long, Long, Double>
 frag, ParallelMessageManager messageManager, StdVector<FFIByteString> args) {

      }

      public void Output(ImmutableEdgecutFragment<Long, Long, Long, Double>
 frag) {

      }
  }
  class MyApp implements ParallelAppBase<Long,Long,Long,Double, MyContext>{
      public void PEval(ImmutableEdgecutFragment<Long, Long, Long, Double>
 graph, ParallelContextBase<Long,Long,Long,Double> context,
 ParallelMessageManager messageManager) {

      }
      public void IncEval(ImmutableEdgecutFragment<Long, Long, Long, Double>
 graph, ParallelContextBase<Long,Long,Long,Double> context,
 ParallelMessageManager messageManager) {

      }
  }
 }

For more examples, please refer to module com.alibaba.graphscope.graphscope-demo

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`IncEval(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> graph, ParallelContextBase<OID_T,VID_T,VDATA_T,EDATA_T> context, ParallelMessageManager messageManager)`	Incremental Evaluation to implement.
`void`	`PEval(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> graph, ParallelContextBase<OID_T,VID_T,VDATA_T,EDATA_T> context, ParallelMessageManager messageManager)`	Partial Evaluation to implement.

- Method Detail
  - PEval
```
void PEval(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> graph,
           ParallelContextBase<OID_T,VID_T,VDATA_T,EDATA_T> context,
           ParallelMessageManager messageManager)
```
    Partial Evaluation to implement.
    
    Parameters:
    
    graph - fragment. The graph fragment providing accesses to graph data.
    
    context - context. User defined context which manages data during the whole computations.
    
    messageManager - The message manger which manages messages between fragments.
    
    See Also:
    
    IFragment, ParallelContextBase, ParallelMessageManager
  - IncEval
```
void IncEval(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> graph,
             ParallelContextBase<OID_T,VID_T,VDATA_T,EDATA_T> context,
             ParallelMessageManager messageManager)
```
    Incremental Evaluation to implement.
    
    Parameters:
    
    graph - fragment. The graph fragment providing accesses to graph data.
    
    context - context. User defined context which manages data during the whole computations.
    
    messageManager - The message manger which manages messages between fragments.
    
    See Also:
    
    IFragment, ParallelContextBase, ParallelMessageManager

Interface ParallelAppBase<OID_T,​VID_T,​VDATA_T,​EDATA_T,​C extends ParallelContextBase<OID_T,​VID_T,​VDATA_T,​EDATA_T>>

Method Summary

Method Detail

PEval

IncEval

Interface ParallelAppBase<OID_T,VID_T,VDATA_T,EDATA_T,C extends ParallelContextBase<OID_T,VID_T,VDATA_T,EDATA_T>>