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

package org.apache.beam.runners.fnexecution.wire

Wire coders for communications between runner and SDK harness.

Classes

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.