ueshin commented on code in PR #43204: URL: https://github.com/apache/spark/pull/43204#discussion_r1350811414
########## sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/PythonUDF.scala: ########## @@ -241,12 +248,17 @@ case class UnresolvedPolymorphicPythonUDTF( * @param orderByExpressions if non-empty, this contains the list of ordering items that the * 'analyze' method explicitly indicated that the UDTF call should consume * the input table rows by + * @param pickledAnalyzeResult this is the pickled 'AnalyzeResult' instance from the UDTF, which + * contains all metadata returned by the Python UDTF 'analyze' method + * including the result schema of the function call as well as optional + * other information */ case class PythonUDTFAnalyzeResult( schema: StructType, withSinglePartition: Boolean, partitionByExpressions: Seq[Expression], - orderByExpressions: Seq[SortOrder]) { + orderByExpressions: Seq[SortOrder], + pickledAnalyzeResult: Option[Array[Byte]]) { Review Comment: We don't need `Option` here as it will always be set? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org