---------------------------------------------------------------------------
UnsupportedOperationException Traceback (most recent call last)
File <command-903026361165476>, line 43
39 dbutils.fs.mkdirs(MARKED_DIR)
41 # save label assignments
42 # save labels
---> 43 zingg.writeLabelledOutputFromPandas(candidate_pairs_pd,args)
45 # count labels accumulated
46 marked_pd_df = getPandasDfFromDs(zingg.getMarkedRecords())
File /local_disk0/.ephemeral_nfs/envs/pythonEnv-c59cd6b8-8912-4f37-be53-8d7c16396ab4/lib/python3.10/site-packages/zingg/client.py:284, in Zingg.writeLabelledOutputFromPandas(self, candidate_pairs_pd, args)
282 markedRecordsAsDS = markedRecordsAsDS.withColumn(ColName.MATCH_FLAG_COL,markedRecordsAsDS.col(ColName.MATCH_FLAG_COL).cast("int"))
283 updatedRecords = getJVM().zingg.spark.client.SparkFrame(markedRecordsAsDS)
--> 284 self.writeLabelledOutput(updatedRecords,args)
File /local_disk0/.ephemeral_nfs/envs/pythonEnv-c59cd6b8-8912-4f37-be53-8d7c16396ab4/lib/python3.10/site-packages/zingg/client.py:273, in Zingg.writeLabelledOutput(self, updatedRecords, args)
270 def writeLabelledOutput(self,updatedRecords,args):
271 """ Method to write updated records after user input
272 """
--> 273 trainingDataModel = self.client.getTrainingDataModel()
274 if updatedRecords is not None:
275 trainingDataModel.writeLabelledOutput(updatedRecords,args.getArgs())
File /databricks/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/java_gateway.py:1355, in JavaMember._call_(self, *args)
1349 command = proto.CALL_COMMAND_NAME +\
1350 self.command_header +\
1351 args_command +\
1352 proto.END_COMMAND_PART
1354 answer = self.gateway_client.send_command(command)
-> 1355 return_value = get_return_value(
1356 answer, self.gateway_client, self.target_id, self.name)
1358 for temp_arg in temp_args:
1359 if hasattr(temp_arg, "_detach"):
File /databricks/spark/python/pyspark/errors/exceptions/captured.py:194, in capture_sql_exception.<locals>.deco(*a, **kw)
190 converted = convert_exception(e.java_exception)
191 if not isinstance(converted, UnknownException):
192 # Hide where the exception came from that shows a non-Pythonic
193 # JVM exception message.
--> 194 raise converted from None
195 else:
196 raise
UnsupportedOperationException: not implement in class zingg.spark.core.executor.SparkTrainingDataFinder
