object GraphReader
The helper object for reading graph through the definitions of graph info.
- Alphabetic
- By Inheritance
- GraphReader
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @HotSpotIntrinsicCandidate()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
read(graphInfoPath: String, spark: SparkSession): (Map[String, DataFrame], Map[(String, String, String), Map[String, DataFrame]])
Reading the graph as vertex and edge DataFrames with the graph info yaml file.
Reading the graph as vertex and edge DataFrames with the graph info yaml file.
- graphInfoPath
The path of the graph info yaml.
- spark
The Spark session for the loading.
- returns
Pair of vertex DataFrames and edge DataFrames, the vertex DataFrames are stored as the map of (vertex_label -> DataFrame) the edge DataFrames are stored as a map of (srcLabel_edgeLabel_dstLabel -> (adj_list_type_str -> DataFrame))
-
def
readWithGraphInfo(graphInfo: GraphInfo, spark: SparkSession): (Map[String, DataFrame], Map[(String, String, String), Map[String, DataFrame]])
Reading the graph as vertex and edge DataFrames with the graph info object.
Reading the graph as vertex and edge DataFrames with the graph info object.
- graphInfo
The info object for the graph.
- spark
The Spark session for the loading.
- returns
Pair of vertex DataFrames and edge DataFrames, the vertex DataFrames are stored as the map of (vertex_label -> DataFrame) the edge DataFrames are stored as a map of ((srcLabel, edgeLabel, dstLabel) -> (adj_list_type_str -> DataFrame))
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
Deprecated Value Members
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] ) @Deprecated
- Deprecated