scala—如何将SalesforceSOAPAPI返回的查询结果转换为sparkDataframe

wfauudbj  于 2021-05-16  发布在  Spark
关注(0)|答案(0)|浏览(250)

我正在尝试将对象的查询结果(通过salesforcesoapapi检索)转换为spark dataframe。
下面是salesforce站点的示例代码,它是用java编写的,我期望的是将“记录”(com.sforce.soap.enterprise.sobject.sobject)转换为dataframe,所以我可以在sparkshell中作为脚本运行它以进行测试
谢谢,

private void querySample() {
        String soqlQuery = "SELECT FirstName, LastName FROM Contact";
        QueryResult qr = connection.query(soqlQuery);
        if (qr.getSize() > 0) {
            SObject[] records = qr.getRecords();
            for (int i = 0; i < records.length; ++i) {
                Contact con = (Contact) records[i];
                String fName = con.getFirstName();
                String lName = con.getLastName();
            }
        }
   }

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题