Skip to content

Instantly share code, notes, and snippets.

@yjshen

yjshen/Write batch results to Pulsar. Secret

Created July 15, 2019 07:12
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save yjshen/8ba23ebddbc4d4799d2fde85f52483ff to your computer and use it in GitHub Desktop.
Save yjshen/8ba23ebddbc4d4799d2fde85f52483ff to your computer and use it in GitHub Desktop.
Download ZIP
Raw
Write batch results to Pulsar.
df.selectExpr("CAST(__key AS STRING)", "CAST(value AS STRING)")
.write
.format("pulsar")
.option("service.url", "pulsar://localhost:6650")
.option("topic", "topic1")
.save()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment