如何用scala或python将结构化数据映射到schemaRDD？

Question

我有一个要映射到schemaRDD的结构化数据。数据如下所示：

{recordType:NEW,data:{keycol:val1,col2:val2,col3:val3,col4:val4}
{recordType:update,data:{keycol:val1,col2:val5,col3:val6,col4:val7}

我希望能够在将sql映射到schemaRDD之后运行sql，如下所示：

select keycol, col1, col2 from tableT1 where col3 = val3

感谢您的帮助。你知道吗