pyspark.sql.avro.functions.to_avro???
-
pyspark.sql.avro.functions.to_avro高山市 数据显示:列OrName, jsonFormatSchema:字符串=''' )spark.sql.clumn ??? -
将列转换为二元a
- 参数解析
-
-
数据显示
列内或字符串 -
数据列
- jsonFormatSchema str可选
-
用户自定义输出avrosma
-
数据显示
注解
自Spark2.4以来,Avro内置数据源模块Apache Avro数据源指南部署段应用
实例
>>>发自yspark.sql导入行数>>>发自pyspark.sql.avro.functions导入to_avro>>>数据显示=[SPADES万事通>>>df=点火.创建DataFrame高山市数据显示,字符串)>>>df.选择高山市to_avro高山市df.传值).化名高山市实战).集合(b)[Row(suite=bytearray(b'\x00\x0cSPADES'))]
>>>jsonFormatSchema=+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++.符号':'################################################>>>df.选择高山市to_avro高山市df.传值,jsonFormatSchema).化名高山市实战).集合(b)[Row(suite=bytearray(b'\x02\x00'))]