Package org.apache.beam.runners.fnexecution.wire

Wire coders for communications between runner and SDK harness.

See: Description

Class Summary

Class	Description
ByteStringCoder	A duplicate of ByteStringCoder that uses the Apache Beam vendored protobuf.
LengthPrefixUnknownCoders	Utilities for replacing or wrapping unknown coders with LengthPrefixCoder.
WireCoders	Helpers to construct coders for gRPC port reads and writes.

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

Wire coders for communications between runner and SDK harness.