spark/java上的if/else条件

kx7yvsdv  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(298)

我正在尝试运行以下代码:

for (java.util.Iterator<Row> iter = dataframe1.toLocalIterator(); iter.hasNext();) {
    Row it = (iter.next());
    String item = it.get(2).toString();
    String rayon = it.get(6).toString();
    Double d = Double.parseDouble(rayon)/100000;
    String geomType = it.get(14).toString();
    Dataset<Row> res_f = null;

    if(geomType.equalsIgnoreCase("Polygon")) {
        res_f= dataframe2.withColumn("ST_WITHIN",expr("ST_WITHIN(ST_GeomFromText(CONCAT('POINT(',longitude,' ',latitude,')',4326)),ST_GeomFromWKT('"+item+"'))"));

    } else {
        res_f = dataframe2.withColumn("ST_BUFFERR",expr("ST_Buffer(ST_GeomFromWKT('"+item+"'),"+d+")")).withColumn("ST_WITHIN",expr("ST_WITHIN(ST_GeomFromText(CONCAT('POINT(',longitude,' ',latitude,')',4326)),ST_BUFFERR)"));

    }
    res_f.show();
 }

但是 res_f 不返回任何内容,并且始终为空。
我在用 SparkJava .
编辑
我解决了这个问题,只要把这行从 Dataset<Row> res_f = null;Dataset<Row> res_f; 我需要你的帮助。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题