package
2.15.0+incompatible
Repository: https://github.com/zia-ai/beam.git
Documentation: pkg.go.dev

# Packages

Package v1 is a generated protocol buffer package.

# Functions

DecodeCoder decodes a coder.
DecodeCoderRef extracts a usable coder from the encoded runner form.
DecodeCoderRefs extracts usable coders from the encoded runner form.
DecodeFn encodes a function.
DecodeMultiEdge converts the wire representation into the preprocessed components representing that edge.
DecodeType decodes a type.
EncodeCoder encodes a coder as a string.
EncodeCoderRef returns the encoded form understood by the runner.
EncodeCoderRefs returns the encoded forms understood by the runner.
EncodeFn encodes a function and parameter types as a string.
EncodeMultiEdge converts the preprocessed representation into the wire representation of the multiedge, capturing input and output type information.
EncodeType encodes a type as a string.
MakeGBKUnionCoder returns CoGBK<K,KV<int,[]byte>> for a given CoGBK.
MakeKVUnionCoder returns KV<K,KV<int,[]byte>> for a given CoGBK.
Marshal converts a graph to a model pipeline.
MarshalCoders marshals a list of coders into model coders.
NewCoderMarshaller returns a new CoderMarshaller.
NewCoderUnmarshaller returns a new CoderUnmarshaller.
NewScopeTree computes the ScopeTree for a set of edges.
UnmarshalCoders unmarshals coders.
WrapIterable adds an iterable (stream) coder for Dataflow side input.
WrapWindowed adds a windowed coder for Dataflow collections.

# Constants

Model constants for interfacing with a Beam runner.
Model constants for interfacing with a Beam runner.
No description provided by the author
Model constants for interfacing with a Beam runner.
Model constants for interfacing with a Beam runner.
Model constants for interfacing with a Beam runner.
Model constants for interfacing with a Beam runner.
Model constants for interfacing with a Beam runner.
No description provided by the author
Model constants for interfacing with a Beam runner.
URNJavaDoFn is the legacy constant for marking a DoFn.
URNIterableSideInput = "beam:side_input:iterable:v1".
Model constants for interfacing with a Beam runner.
Model constants for interfacing with a Beam runner.
Model constants for interfacing with a Beam runner.
Model constants for interfacing with a Beam runner.

# Structs

CoderMarshaller incrementally builds a compact model representation of a set of coders.
CoderRef defines the (structured) Coder in serializable form.
CoderUnmarshaller is an incremental unmarshaller of model coders.
NamedEdge is a named MultiEdge.
NamedScope is a named Scope.
Options for marshalling a graph into a model pipeline.
ScopeTree is a convenient representation of the Scope-structure as a tree.