File tree Expand file tree Collapse file tree
wayang-api/wayang-api-sql/src/test/java/org/apache/wayang/api/sql Expand file tree Collapse file tree Original file line number Diff line number Diff line change 7575import org .apache .wayang .api .sql .calcite .rules .WayangRules ;
7676import org .apache .wayang .api .sql .calcite .schema .SchemaUtils ;
7777import org .apache .wayang .api .sql .calcite .utils .ModelParser ;
78- import org .apache .wayang .api .sql .calcite .utils .PrintUtils ;
7978import org .apache .wayang .api .sql .context .SqlContext ;
8079import org .apache .wayang .basic .data .Record ;
8180import org .apache .wayang .basic .data .Tuple2 ;
@@ -150,8 +149,6 @@ void javaFilterWithCast() throws Exception {
150149
151150 sqlContext .execute (wayangPlan );
152151
153- PrintUtils .print ("" , wayangPlan );
154- System .out .println ("results: " + result );
155152 assertTrue (!result .isEmpty ());
156153 assertTrue (result .stream ().allMatch (field -> field .getField (1 ).equals ("test1" )));
157154 }
You can’t perform that action at this time.
0 commit comments