class GraphWriter extends AnyRef
GraphWriter is a class to help to write graph data in graph format.
- Alphabetic
- By Inheritance
- GraphWriter
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new GraphWriter()
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
-
def
PutEdgeData(relation: (String, String, String), df: DataFrame): Unit
Put the edge dataframe into writer.
Put the edge dataframe into writer.
- relation
3-Tuple (source label, edge label, target label) to indicate edge type.
- df
data frame of edge type.
-
def
PutVertexData(label: String, df: DataFrame, primaryKey: String = ""): Unit
Put the vertex DataFrame into writer.
Put the vertex DataFrame into writer.
- label
label of vertex.
- df
DataFrame of the vertex type.
- primaryKey
primary key of the vertex type, default is empty, which take the first property column as primary key.
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @HotSpotIntrinsicCandidate()
- val edges: Map[(String, String, String), DataFrame]
-
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()
- val primaryKeys: Map[String, String]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
- val vertexNums: Map[String, Long]
- val vertices: Map[String, DataFrame]
-
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( ... )
-
def
write(path: String, spark: SparkSession, name: String = "graph", vertex_chunk_size: Long = ..., edge_chunk_size: Long = GeneralParams.defaultEdgeChunkSize, file_type: String = GeneralParams.defaultFileType, version: String = GeneralParams.defaultVersion): Unit
Write graph data in GraphAr format.
Write graph data in GraphAr format.
- path
the directory to write.
- spark
the spark session for the writing.
- name
the name of graph, default is 'grpah'
- vertex_chunk_size
the chunk size for vertices, default is 2^18
- edge_chunk_size
the chunk size for edges, default is 2^22
- file_type
the file type for data payload file, support [parquet, orc, csv], default is parquet.
- version
version of GraphAr format, default is v1.
-
def
write(graphInfoPath: String, spark: SparkSession): Unit
Write the graph data in GraphAr format with path of the graph info yaml.
Write the graph data in GraphAr format with path of the graph info yaml.
- graphInfoPath
the path of the graph info yaml.
- spark
the spark session for the writing.
-
def
write(graphInfo: GraphInfo, spark: SparkSession): Unit
Write the graph data in GraphAr format with graph info.
Write the graph data in GraphAr format with graph info.
- graphInfo
the graph info object for the graph.
- spark
the spark session for the writing.
Deprecated Value Members
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] ) @Deprecated
- Deprecated