Private componentsPrivate encodingPrivate encodingPrivate encodingPrivate fieldPrivate fieldPrivate hasPrivate nPrivate schemaStatic URNEncode an element into a stream of bytes.
an element within a PCollection
a writer that interfaces the coder with the output byte stream.
the context within which the element should be encoded.
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.
a context that holds relevant pipeline attributes such as other coders already in the pipeline.
Static fromJSONStatic fromStatic inferStatic inferGenerated using TypeDoc
A coder for encoding Objects as row objects with a given schema.
This is particularly useful for cross-language interoperability, and is more efficient than the general object encoding scheme as the fields (and their types) are fixed and do not have to be encoded along with each individual element.
While RowCoders can be instantiated directly from a schema object, there is also the convenience method
RowCoder.fromJSON()method that can infer a RowCoder from a prototypical example, e.g.