Packages

class EdgeReader extends AnyRef

Reader for edge chunks.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. EdgeReader
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new EdgeReader(prefix: String, edgeInfo: EdgeInfo, adjListType: AdjListType.Value, spark: SparkSession)

    create a new edge reader with edge info and AdjList type.

    create a new edge reader with edge info and AdjList type.

    prefix

    the absolute prefix.

    edgeInfo

    the edge info that describes the edge type.

    adjListType

    the adj list type for the edge.

    spark

    spark session for the reader to read chunks as Spark DataFrame. Note that constructor would raise IllegalArgumentException if edge info does not support given adjListType.

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @HotSpotIntrinsicCandidate()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  9. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  13. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  14. def readAdjListChunk(vertex_chunk_index: Long, chunk_index: Long): DataFrame

    Load a single AdjList chunk as a DataFrame.

    Load a single AdjList chunk as a DataFrame.

    vertex_chunk_index

    index of vertex chunk

    chunk_index

    index of AdjList chunk.

    returns

    AdjList chunk DataFrame

  15. def readAdjListForVertexChunk(vertex_chunk_index: Long, addIndex: Boolean = true): DataFrame

    Load all AdjList chunks for a vertex chunk as a DataFrame.

    Load all AdjList chunks for a vertex chunk as a DataFrame.

    vertex_chunk_index

    index of vertex chunk.

    addIndex

    flag that add edge index column or not in the final DataFrame.

    returns

    DataFrame of all AdjList chunks of vertices in given vertex chunk.

  16. def readAllAdjList(addIndex: Boolean = true): DataFrame

    Load all AdjList chunks for this edge type as a DataFrame.

    Load all AdjList chunks for this edge type as a DataFrame.

    addIndex

    flag that add index column or not in the final DataFrame.

    returns

    DataFrame of all AdjList chunks.

  17. def readAllEdgePropertyGroups(addIndex: Boolean = true): DataFrame

    Load the chunks for all property groups as a DataFrame.

    Load the chunks for all property groups as a DataFrame.

    addIndex

    flag that add edge index column or not in the final DataFrame.

    returns

    DataFrame tha contains all property groups chunks of edge.

  18. def readAllEdgePropertyGroupsForVertexChunk(vertex_chunk_index: Long, addIndex: Boolean = true): DataFrame

    Load the chunks for all property groups of a vertex chunk as a DataFrame.

    Load the chunks for all property groups of a vertex chunk as a DataFrame.

    vertex_chunk_index

    index of vertex chunk.

    addIndex

    flag that add edge index column or not in the final DataFrame.

    returns

    DataFrame that contains all property groups chunks of a vertex chunk.

  19. def readEdgePropertyChunk(propertyGroup: PropertyGroup, vertex_chunk_index: Long, chunk_index: Long): DataFrame

    Load a single edge property chunk as a DataFrame.

    Load a single edge property chunk as a DataFrame.

    propertyGroup

    property group.

    vertex_chunk_index

    index of vertex chunk.

    chunk_index

    index of property group chunk.

    returns

    property group chunk DataFrame. If edge info does not contain the property group, raise an IllegalArgumentException error.

  20. def readEdgePropertyGroup(propertyGroup: PropertyGroup, addIndex: Boolean = true): DataFrame

    Load all chunks for a property group as a DataFrame.

    Load all chunks for a property group as a DataFrame.

    propertyGroup

    property group.

    addIndex

    flag that add edge index column or not in the final DataFrame.

    returns

    DataFrame that contains all chunks of property group. If edge info does not contain the property group, raise an IllegalArgumentException error.

  21. def readEdgePropertyGroupForVertexChunk(propertyGroup: PropertyGroup, vertex_chunk_index: Long, addIndex: Boolean = true): DataFrame

    Load the chunks for a property group of a vertex chunk as a DataFrame.

    Load the chunks for a property group of a vertex chunk as a DataFrame.

    propertyGroup

    property group.

    vertex_chunk_index

    index of vertex chunk.

    addIndex

    flag that add edge index column or not in the final DataFrame.

    returns

    DataFrame that contains all property group chunks of vertices in given vertex chunk. If edge info does not contain the property group, raise an IllegalArgumentException error.

  22. def readEdges(addIndex: Boolean = true): DataFrame

    Load the chunks for the AdjList and all property groups as a DataFrame.

    Load the chunks for the AdjList and all property groups as a DataFrame.

    addIndex

    flag that add edge index column or not in the final DataFrame.

    returns

    DataFrame that contains all chunks of AdjList and property groups of edge.

  23. def readEdgesForVertexChunk(vertex_chunk_index: Long, addIndex: Boolean = true): DataFrame

    Load the chunks for the AdjList and all property groups for a vertex chunk as a DataFrame.

    Load the chunks for the AdjList and all property groups for a vertex chunk as a DataFrame.

    vertex_chunk_index

    index of vertex chunk

    addIndex

    flag that add edge index column or not in the final DataFrame.

    returns

    DataFrame that contains all chunks of AdjList and property groups of vertices in given vertex chunk.

  24. def readEdgesNumber(): Long

    Load the total number of edges for this edge type.

  25. def readEdgesNumber(chunk_index: Long): Long

    Load the number of edges for the vertex chunk.

    Load the number of edges for the vertex chunk.

    chunk_index

    index of vertex chunk

    returns

    the number of edges

  26. def readMultipleEdgePropertyGroups(propertyGroups: ArrayList[PropertyGroup], addIndex: Boolean = true): DataFrame

    Load the chunks for multiple property groups as a DataFrame.

    Load the chunks for multiple property groups as a DataFrame.

    propertyGroups

    list of property groups.

    addIndex

    flag that add edge index column or not in the final DataFrame.

    returns

    DataFrame tha contains all property groups chunks of edge.

  27. def readMultipleEdgePropertyGroupsForVertexChunk(propertyGroups: ArrayList[PropertyGroup], vertex_chunk_index: Long, addIndex: Boolean = true): DataFrame

    Load the chunks for multiple property groups of a vertex chunk as a DataFrame.

    Load the chunks for multiple property groups of a vertex chunk as a DataFrame.

    propertyGroups

    list of property groups.

    vertex_chunk_index

    index of vertex chunk.

    addIndex

    flag that add edge index column or not in the final DataFrame.

    returns

    DataFrame that contains all property groups chunks of a vertex chunk.

  28. def readOffset(chunk_index: Long): DataFrame

    Load a single offset chunk as a DataFrame.

    Load a single offset chunk as a DataFrame.

    chunk_index

    index of offset chunk

    returns

    offset chunk DataFrame. Raise IllegalArgumentException if adjListType is not AdjListType.ordered_by_source or AdjListType.ordered_by_dest.

  29. def readVertexChunkNumber(): Long

    Load the chunk number of src/dst vertices.

  30. def readVerticesNumber(): Long

    Load the total number of src/dst vertices for this edge type.

  31. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  32. def toString(): String
    Definition Classes
    AnyRef → Any
  33. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  34. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  35. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated
    Deprecated

Inherited from AnyRef

Inherited from Any

Ungrouped