Package org.apache.beam.runners.fnexecution.graph

Utilities for a Beam runner to interact with the pipeline proto representation.

See: Description

Class Summary

Class	Description
LengthPrefixUnknownCoders	Utilities for replacing or wrapping unknown coders with LengthPrefixCoder.

Package org.apache.beam.runners.fnexecution.graph Description

Utilities for a Beam runner to interact with the pipeline proto representation.