File tree Expand file tree Collapse file tree 1 file changed +0
-18
lines changed
sql/core/src/test/scala/org/apache/spark/sql/parquet Expand file tree Collapse file tree 1 file changed +0
-18
lines changed Original file line number Diff line number Diff line change @@ -243,24 +243,6 @@ class ParquetQuerySuite extends QueryTest with FunSuite with BeforeAndAfterAll {
243
243
assert(true )
244
244
}
245
245
246
- test(" SELECT WHERE" ) {
247
- val result = sql(" SELECT * FROM testsource WHERE myint = 5" ).collect()
248
- /* test("SELECT WHERE") {
249
- //val result = parquetFile("/home/andre/input.adam").registerAsTable("adamtable")
250
- //sql("SELECT * FROM adamtable WHERE mapq = 0").collect()
251
- //assert(result != null)
252
- //val result = sql("SELECT * FROM testsource WHERE myint = 5").collect()
253
- // TODO: ADD larger case SchemaRDD with filtering on REQUIRED field!
254
- implicit def anyToRow(value: Any): Row = value.asInstanceOf[Row]
255
- TestSQLContext
256
- .parquetFile(ParquetTestData.testNestedDir1.toString)
257
- .toSchemaRDD.registerAsTable("xtmptable")
258
- val result = sql("SELECT * FROM xtmptable WHERE owner = \"Julien Le Dem\"").collect()
259
- >>>>>>> Extending ParquetFilters
260
- assert(result != null)
261
- }*/
262
- }
263
-
264
246
test(" create RecordFilter for simple predicates" ) {
265
247
val attribute1 = new AttributeReference (" first" , IntegerType , false )()
266
248
val predicate1 = new Equals (attribute1, new Literal (1 , IntegerType ))
You can’t perform that action at this time.
0 commit comments