Skip to content

Commit b5a45aa

Browse files
committed
update readme file
1 parent b76fe0a commit b5a45aa

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

scala/README.md

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -161,11 +161,18 @@ var credentials = scala.collection.mutable.HashMap[String, String](
161161
"secretKey"->"xx"
162162
)
163163
var bucketName = "myBucket"
164-
var objectname = "mydata"
164+
var objectname = "mydata.csv"
165165

166166
var cos = new CloudObjectStorage(sc, credentials)
167-
var rdd = sc.textFile(cos.url(bucketName , objectname))
168-
rdd.take(5)
167+
val spark = SparkSession.
168+
builder().
169+
getOrCreate()
170+
171+
val dfData1 = spark.
172+
read.format("org.apache.spark.sql.execution.datasources.csv.CSVFileFormat").
173+
option("header", "true").
174+
option("inferSchema", "true").
175+
load(cos.url(bucketName, objectname))
169176
```
170177

171178

0 commit comments

Comments
 (0)