我收到錯誤：
Exception: ERROR: 'int' object has no attribute 'value'
AttributeError: 'str' object has no attribute '_jvm'
ehConf['eventhubs.connectionString'] = self.connectionProperties.sc._jvm.org.apache.spark.eventhubs.EventHubsUtils.encrypt(connectionString)
當我嘗試呼叫以下函式時：
def EventHubConnectionProperties(self,processId,startOffset,endTime):
ehConf = {}
ehConf['eventhubs.connectionString'] = self.connectionProperties.sc._jvm.org.apache.spark.eventhubs.EventHubsUtils.encrypt(connectionString)
有人有想法嗎？
uj5u.com熱心網友回復：
它應該如下使用 -
ehConf['eventhubs.connectionString'] = sc._jvm.org.apache.spark.eventhubs.EventHubsUtils.encrypt(connectionString)
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/447327.html