可以将spark配置为将空数据集推断为空模式吗
添加schema就行了。没那么事多; 如: StructType schema = DataTypes .createStructType(Arrays.asList( DataTypes.createStructField('msisdn', DataTypes.StringType, true), DataTypes.createStructField('eid', DataTypes.IntegerType, true) )); sc.read().schema(schema).parquet('/test');
赞0
踩0