Class BsonObjectCoder<T>

A Coder that encodes a javascript object with BSON.

Type Parameters

T

Hierarchy

BsonObjectCoder

Implements

Coder<T>

Index

Constructors

Properties

Methods

decode encode toProto

Constructors

constructor

new BsonObjectCoder<T>(): BsonObjectCoder<T>
Type Parameters
- T
Returns BsonObjectCoder<T>

Properties

`Static` URN

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

Methods

decode

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

encode

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

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/js_coders.ts:49

Generated using TypeDoc