磚

我們流數據從卡夫卡源與json但在一些列我們。(點)在列名。json數據流:df1 = df。selectExpr(鑄(值作為字符串)){“pNum”:“阿”,“從”:“電信”、“有效載荷”:{“目標”:“1”,“國家”:“印度”…