Class PaneInfoCoder

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

Hierarchy

PaneInfoCoder

Implements

Coder<PaneInfo>

Index

Constructors

Properties

INSTANCE ONE_AND_ONLY_FIRING

Methods

decode encode toProto chooseEncoding decodeTiming encodeTiming

Constructors

constructor

new PaneInfoCoder(): PaneInfoCoder
Returns PaneInfoCoder

Properties

`Static` INSTANCE

INSTANCE: PaneInfoCoder = ...

`Static` ONE_AND_ONLY_FIRING

ONE_AND_ONLY_FIRING: PaneInfo = ...

Methods

decode

decode(reader: Reader, context: Context): PaneInfo
Decode an element from an incoming stream of bytes.
Parameters
- reader: Reader
  
  a reader that interfaces the coder with the input byte stream
- context: Context
  
  the context within which the element should be encoded
Returns PaneInfo
Implementation of Coder.decode
- Defined in src/apache_beam/coders/required_coders.ts:564

encode

encode(value: PaneInfo, writer: Writer, context: Context): void
Encode an element into a stream of bytes.
Parameters
- value: PaneInfo
  
  an element within a PCollection
- writer: Writer
  
  a writer that interfaces the coder with the output byte stream.
- context: Context
  
  the context within which the element should be encoded.
Returns void
Implementation of Coder.encode
- Defined in src/apache_beam/coders/required_coders.ts:614

toProto

toProto(pipelineContext: ProtoContext): Coder
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.
Parameters
- pipelineContext: ProtoContext
  
  a context that holds relevant pipeline attributes such as other coders already in the pipeline.
Returns Coder
Implementation of Coder.toProto
- Defined in src/apache_beam/coders/required_coders.ts:641

`Static` `Private` chooseEncoding

chooseEncoding(value: PaneInfo): number
Parameters
- value: PaneInfo
Returns number
- Defined in src/apache_beam/coders/required_coders.ts:548

`Static` `Private` decodeTiming

decodeTiming(timingNumber: any): Timing
Parameters
- timingNumber: any
Returns Timing
- Defined in src/apache_beam/coders/required_coders.ts:514

`Static` `Private` encodeTiming

encodeTiming(timing: Timing): number
Parameters
- timing: Timing
Returns number
- Defined in src/apache_beam/coders/required_coders.ts:533

Generated using TypeDoc