Skip to content

Latest commit

 

History

History
34 lines (27 loc) · 1.12 KB

functions-deploy-cluster.md

File metadata and controls

34 lines (27 loc) · 1.12 KB
id title sidebar_label
functions-deploy-cluster
Deploy a function in cluster mode
Deploy a function in cluster mode

Deploying a function in cluster mode uploads the function to a function worker, which means the function is scheduled by the worker.

To deploy a function in cluster mode, use the create command.

bin/pulsar-admin functions create \
  --py myfunc.py \
  --classname myfunc.SomeFunction \
  --inputs persistent://public/default/input-1 \
  --output persistent://public/default/output-1

To update a function running in cluster mode, you can use the update command.

bin/pulsar-admin functions update \
  --py myfunc.py \
  --classname myfunc.SomeFunction \
  --inputs persistent://public/default/new-input-topic \
  --output persistent://public/default/new-output-topic

More options