This is the base interface for coders, which are responsible in Apache Beam to encode and decode elements of a PCollection.

Hierarchy

  • VarIntCoder

Implements

Constructors

Properties

Methods

Constructors

Properties

type: string = "varintcoder"
INSTANCE: VarIntCoder = ...
URN: string = "beam:coder:varint:v1"

Methods

  • Encode an element into a stream of bytes.

    Parameters

    • element: number

      an element within a PCollection

    • writer: Writer

      a writer that interfaces the coder with the output byte stream.

    Returns void

  • Convert this coder into its protocol buffer representation for the Runner API. A coder in protobuf format can be shared with other components such as Beam runners, SDK workers; and reconstructed into its runtime representation if necessary.

    Returns Coder

Generated using TypeDoc