-
Notifications
You must be signed in to change notification settings - Fork 126
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
What is the correct way to construct a ProtobufResponseRowDeserializer in PySpark? #118
Comments
Hi @RunshengSong, to use You will need to build a |
Hi @ChuyangDeng , thanks for the reply. I understand that I need to send a However, the problem I was asking is the protobufKeys attribute. When I don't send this parameter, it gives me an NPE when I display the Dataframe of prediction output. What should be correct type of protobufKeys attribute? Thanks again. |
Please fill out the form below.
System Information
Describe the problem
I have the following code in pyspark trying to to construct a
SageMakerEstimator
for a random cut forest image:When I run this code using PySpark, I got the following error:
The problem is in the
ProtobufResponseRowDeserializer
. According to the source code of this object for Scala, it should accept aSeq
.What is the correct counterpart in PySpark? Obviously it doesn't accept a list of string.
I tried to search the
sagemaker-spark-sdk
and I couldn't find any reference there.The text was updated successfully, but these errors were encountered: