prism

README

Prism - Stand Alone binary

This binary is the Apache Beam Go Prism Runner as a stand alone binary. See the Prism README for the current state of Prism as a runner.

Usage

Ensure you have a recent version of Go: https://go.dev/doc/install

Until Beam v2.49.0 is released:

go install "github.com/apache/beam/sdks/v2/go/cmd/prism@master"

After that release

go install "github.com/apache/beam/sdks/v2/go/cmd/prism@latest"

Then calling prism on the command line will start up a JobManagement server on port 8073, and a web UI on 8074. Submit portable Beam jobs to the runner in Loopback mode (--environment_type=LOOPBACK) so the runner can provided bundles to the SDK process.

For the Go SDK, when in your pipeline's main binary directory, this can look like:

go run *.go --runner=universal --endpoint=localhost:8073 --environment_type=LOOPBACK

Documentation

Overview

prism is a stand alone local Beam Runner. It produces a JobManagement service endpoint against which jobs can be submited, and a web UI to inspect running and completed jobs.