@@ -121,9 +121,6 @@ mvn clean scala:compile compile package
121
121
122
122
```scala
123
123
import cn.edu.thu.tsfile._
124
- import org.apache.spark.sql.SparkSession
125
-
126
- val spark = SparkSession.builder().master("local").getOrCreate()
127
124
128
125
//read data in TsFile and create a table
129
126
val df = spark.read.tsfile("test.tsfile")
@@ -140,9 +137,6 @@ mvn clean scala:compile compile package
140
137
141
138
```scala
142
139
import cn.edu.thu.tsfile._
143
- import org.apache.spark.sql.SparkSession
144
-
145
- val spark = SparkSession.builder().master("local").getOrCreate()
146
140
val df = spark.read
147
141
.format("cn.edu.thu.tsfile")
148
142
.load("test.tsfile")
@@ -154,9 +148,6 @@ mvn clean scala:compile compile package
154
148
155
149
```scala
156
150
import cn.edu.thu.tsfile._
157
- import org.apache.spark.sql.SparkSession
158
-
159
- val spark = SparkSession.builder().master("local").getOrCreate()
160
151
161
152
//create a table in SparkSQL and build relation with a TsFile
162
153
spark.sql("create temporary view TsFile using cn.edu.thu.tsfile options(path = \"test.tsfile\")")
@@ -169,10 +160,6 @@ mvn clean scala:compile compile package
169
160
170
161
```scala
171
162
import cn.edu.thu.tsfile._
172
- import org.apache.spark.sql.SparkSession
173
- import scala.collection.mutable
174
-
175
- val spark = SparkSession.builder().master("local").getOrCreate()
176
163
177
164
val df = spark.read.option("delta_object_name", "root.device.turbine").tsfile("test.tsfile")
178
165
@@ -186,9 +173,6 @@ mvn clean scala:compile compile package
186
173
187
174
```scala
188
175
import cn.edu.thu.tsfile._
189
- import org.apache.spark.sql.SparkSession
190
-
191
- val spark = SparkSession.builder().master("local").getOrCreate()
192
176
193
177
val df = spark.read.tsfile("test.tsfile").write.tsfile("out")
194
178
@@ -198,10 +182,6 @@ mvn clean scala:compile compile package
198
182
199
183
```scala
200
184
import cn.edu.thu.tsfile._
201
- import org.apache.spark.sql.SparkSession
202
- import scala.collection.mutable
203
-
204
- val spark = SparkSession.builder().master("local").getOrCreate()
205
185
206
186
val df = spark.read.option("delta_object_name", "root.device.turbine").tsfile("test.tsfile")
207
187
@@ -212,9 +192,9 @@ mvn clean scala:compile compile package
212
192
### 6.2 spark-shell
213
193
214
194
```
215
- $ bin/spark-shell --jars tsfile-spark-connector-0.1 .0.jar,tsfile-0.1 .0.jar
195
+ $ bin/spark-shell --jars tsfile-spark-connector-0.4 .0.jar,tsfile-0.4 .0.jar
216
196
217
- scala> sql("CREATE TEMPORARY TABLE TsFile_table USING cn.edu.thu.tsfile OPTIONS (path \"hdfs://localhost:9000/test1 .tsfile\")")
197
+ scala> sql("CREATE TEMPORARY TABLE TsFile_table USING cn.edu.thu.tsfile OPTIONS (path \"hdfs://localhost:9000/test .tsfile\")")
218
198
219
199
scala> val df = sql("select * from TsFile_table")
220
200
0 commit comments