SELECT * FROM encrypted_im.abcSELECT * FROM encrypted_im.abc;
错误:无法识别表源中“减号”选择“*”的输入--选择store_numstore_nm从encrypted_im.base_abc中选择store_num,store_nm从encrypted_im.base_abc中选择;错误:无法识别表源中“减号”选择“store_num”的输入
我配置了一个合流模式注册中心,该模式使用type=object的json格式。现在,我可以从注册表中检索模式,但是我需要在包含kafka记录的dataframe上使用这个模式。schemaName) // return type is io.confluent.kafka.schemaregistry.client.rest.entities.Schema
现在,我想对下面的代码使用DataFrame =df.selectExpr(“强制转换为字符串)作为数据”).select(fro
我需要使用sparksql.I在我的hive表中插入一些值。我使用以下代码。fileName.split("/") val e=LocalDateTime.now() //timestamp 首先,我尝试使用Insert Into Values,但后来我发现此功能在sparksql中不可用。"insert into mytable(&