This is an automated email from the ASF dual-hosted git repository.
weibin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-graphar.git
The following commit(s) were added to refs/heads/main by this push:
new cfb6d5f0 chore(spark): fix typo in writer (#648)
cfb6d5f0 is described below
commit cfb6d5f06dbf1268ae0610a267ab227dc08f08f7
Author: Liu Jiajun <[email protected]>
AuthorDate: Sat Oct 26 23:59:08 2024 +0800
chore(spark): fix typo in writer (#648)
* fix typo in writer
* fix typo
---
.../src/main/scala/org/apache/graphar/graph/GraphWriter.scala | 2 +-
.../src/main/scala/org/apache/graphar/writer/EdgeWriter.scala | 6 +++---
.../src/main/scala/org/apache/graphar/writer/VertexWriter.scala | 6 +++---
3 files changed, 7 insertions(+), 7 deletions(-)
diff --git
a/maven-projects/spark/graphar/src/main/scala/org/apache/graphar/graph/GraphWriter.scala
b/maven-projects/spark/graphar/src/main/scala/org/apache/graphar/graph/GraphWriter.scala
index e231c419..872c5ff2 100644
---
a/maven-projects/spark/graphar/src/main/scala/org/apache/graphar/graph/GraphWriter.scala
+++
b/maven-projects/spark/graphar/src/main/scala/org/apache/graphar/graph/GraphWriter.scala
@@ -185,7 +185,7 @@ class GraphWriter() {
* @param spark
* the spark session for the writing.
* @param name
- * the name of graph, default is 'grpah'
+ * the name of graph, default is 'graph'
* @param vertex_chunk_size
* the chunk size for vertices, default is 2^18
* @param edge_chunk_size
diff --git
a/maven-projects/spark/graphar/src/main/scala/org/apache/graphar/writer/EdgeWriter.scala
b/maven-projects/spark/graphar/src/main/scala/org/apache/graphar/writer/EdgeWriter.scala
index e5119d94..d2b3c511 100644
---
a/maven-projects/spark/graphar/src/main/scala/org/apache/graphar/writer/EdgeWriter.scala
+++
b/maven-projects/spark/graphar/src/main/scala/org/apache/graphar/writer/EdgeWriter.scala
@@ -240,11 +240,11 @@ class EdgeWriter(
)
}
// check the src index and dst index column exist
- val src_filed = StructField(GeneralParams.srcIndexCol, LongType)
- val dst_filed = StructField(GeneralParams.dstIndexCol, LongType)
+ val src_field = StructField(GeneralParams.srcIndexCol, LongType)
+ val dst_field = StructField(GeneralParams.dstIndexCol, LongType)
val schema = edgeDf.schema
if (
- schema.contains(src_filed) == false || schema.contains(dst_filed) ==
false
+ schema.contains(src_field) == false || schema.contains(dst_field) ==
false
) {
throw new IllegalArgumentException(
"edge DataFrame must contain src index column and dst index column."
diff --git
a/maven-projects/spark/graphar/src/main/scala/org/apache/graphar/writer/VertexWriter.scala
b/maven-projects/spark/graphar/src/main/scala/org/apache/graphar/writer/VertexWriter.scala
index dda26114..28d62b48 100644
---
a/maven-projects/spark/graphar/src/main/scala/org/apache/graphar/writer/VertexWriter.scala
+++
b/maven-projects/spark/graphar/src/main/scala/org/apache/graphar/writer/VertexWriter.scala
@@ -94,9 +94,9 @@ class VertexWriter(
chunks.persist(GeneralParams.defaultStorageLevel)
private def validate(): Unit = {
- // check if vertex DataFrame contains the index_filed
- val index_filed = StructField(GeneralParams.vertexIndexCol, LongType)
- if (vertexDf.schema.contains(index_filed) == false) {
+ // check if vertex DataFrame contains the index_field
+ val index_field = StructField(GeneralParams.vertexIndexCol, LongType)
+ if (vertexDf.schema.contains(index_field) == false) {
throw new IllegalArgumentException(
"vertex DataFrame must contain index column."
)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
