亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定

Spark SQL中的Encoder

標簽:
Spark

以下错误,想必在做Spark的DateSet操作时一定是见过吧?

Error:(58, 17) Unable to find encoder for type stored in a Dataset.  Primitive types (Int, String, etc) and Product types (case classes) are supported by importing spark.implicits._  Support for serializing other types will be added in future releases.
    peopleDF.map(row => row.get(0)).show()

这是因为在作map转换时需要指定一个转换的Encorder,在Scala代码中是通过隐式转换进行的,而在Java代码中则需要在代码中指明。
为了更好理解写了一个Java的代码供学习加深理解。

代码如下:

public static void main(String[] args) {

        SparkSession spark = SparkSession.builder().master("local[2]").appName("DataSetEncoderExample").getOrCreate();

        List<String> data = Arrays.asList("chen", "li", "huang");        //创建DataSet的时候指明数据是String类型

        Dataset<String> ds = spark.createDataset(data, Encoders.STRING());        /***操作一:**/

        //map操作:把string类型的变换成string类型
        //此时MapFunction<String, String> 这两个地方都应该是String
        Dataset<String> dsString2String = ds.map((MapFunction<String, String>) v -> "Hi," + v, Encoders.STRING());
        dsString2String.show();        /***操作二:**/

        //map操作:把string类型的变换成int类型
        //注意此时MapFunction<String, Integer> 这两个地方的类型变化
        //第一个类型String为原来的DataSet的类型,第二个类型为输出的类型
        Dataset<Integer> dsString2Int = ds.map(new MapFunction<String, Integer>(){
            @Override
            public Integer call(String value) throws Exception {                return value.length();
            }
        }, Encoders.INT());
        dsString2Int.show();        /***操作三:**/
        //map操作:把string类型的变换成自定义的对象类型
        //注意此时MapFunction<String, People> 这两个地方的类型变化
        //第一个类型String为原来的DataSet的类型,第二个类型People为输出的类型
        Encoder<People> peopleEncoder = Encoders.kryo(People.class);
        Dataset<People> dsString2Object = ds.map(new MapFunction<String, People>(){
            @Override
            public People call(String value) throws Exception {                return new People(value, value.length());
            }
        }, peopleEncoder);
        dsString2Object.show();
        dsString2Object.map((MapFunction<People, String>) item -> item.getName(), Encoders.STRING()).show();        /***操作四:**/
        //map操作:把string类型的变换成Row对象类型
        //注意此时MapFunction<String, Row> 这两个地方的类型变化
        //第一个类型String为原来的DataSet的类型,第二个类型Row为输出的类型//        Encoder<Row> rowEncoder = Encoders.kryo(Row.class);
        Encoder<Row> rowEncoder = Encoders.javaSerialization(Row.class);
        Dataset<Row> dsString2Row = ds.map(
                (MapFunction<String, Row>) value -> RowFactory.create(value, value.length())
            , rowEncoder);
        dsString2Row.show();
        dsString2Row.map((MapFunction<Row, String>) item -> item.getString(0), Encoders.STRING()).show();


        spark.stop();
    }

上述代码中需要创建一下Java类

public class People {
    String name;
    Integer age;    public People( String name, Integer age){        this.name = name;        this.age = age;
    }    public String getName() {        return name;
    }    public void setName(String name) {        this.name = name;
    }    public Integer getAge() {        return age;
    }    public void setAge(Integer age) {        this.age = age;
    }
}



作者:代码足迹
链接:https://www.jianshu.com/p/d3c35e18af44


點擊查看更多內容
TA 點贊

若覺得本文不錯,就分享一下吧!

評論

作者其他優質文章

正在加載中
數據庫工程師
手記
粉絲
42
獲贊與收藏
204

關注作者,訂閱最新文章

閱讀免費教程

  • 推薦
  • 評論
  • 收藏
  • 共同學習,寫下你的評論
感謝您的支持,我會繼續努力的~
掃碼打賞,你說多少就多少
贊賞金額會直接到老師賬戶
支付方式
打開微信掃一掃,即可進行掃碼打賞哦
今天注冊有機會得

100積分直接送

付費專欄免費學

大額優惠券免費領

立即參與 放棄機會
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號

舉報

0/150
提交
取消