我正在尝试将对象的查询结果(通过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();
}
}
}
暂无答案!
目前还没有任何答案,快来回答吧!