Class IntervalWindowCoder

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

Hierarchy

IntervalWindowCoder

Implements

Coder<IntervalWindow>

Index

Constructors

Properties

Methods

decode encode toProto

Constructors

constructor

new IntervalWindowCoder(): IntervalWindowCoder
Returns IntervalWindowCoder

Properties

`Static` INSTANCE

INSTANCE: IntervalWindowCoder = ...

`Static` URN

URN: string = "beam:coder:interval_window:v1"

Methods

decode

decode(reader: Reader, context: Context): IntervalWindow
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 IntervalWindow
Implementation of Coder.decode
- Defined in src/apache_beam/coders/standard_coders.ts:208

encode

encode(value: IntervalWindow, writer: Writer, context: Context): void
Encode an element into a stream of bytes.
Parameters
- value: IntervalWindow
  
  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/standard_coders.ts:203

toProto

toProto(): 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.

Returns Coder
Implementation of Coder.toProto
- Defined in src/apache_beam/coders/standard_coders.ts:214

Generated using TypeDoc