我正在查看pyspark的相关库，以便从kafka获取模式注册表并解码数据。有人知道什么是scala代码中从scala到pyspark的代码/库转换吗？
fgw7neuy1#
你可以用 requests 要将请求发送到的包 schema-registry restapi并获取主题的模式，如果您正在收听某些特定的主题，您可以在spark上缓存它们的模式并使用它们
requests
schema-registry
tct7dpnv2#
pyspark可以导入和使用任何jvmspark类。因此，您找到的任何scala和其他java示例都应该可以正常工作在pyspark中运行自定义java类
2条答案
按热度按时间fgw7neuy1#
你可以用
requests要将请求发送到的包schema-registryrestapi并获取主题的模式，如果您正在收听某些特定的主题，您可以在spark上缓存它们的模式并使用它们tct7dpnv2#
pyspark可以导入和使用任何jvmspark类。因此，您找到的任何scala和其他java示例都应该可以正常工作
在pyspark中运行自定义java类