schema

package
v3.0.0-...-7ba4d6b Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 17, 2024 License: Apache-2.0, BSD-3-Clause, MIT Imports: 4 Imported by: 0

Documentation

Overview

Package schema has the cross language implementation for calling schema transforms in other language SDKs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Transform

func Transform(scope beam.Scope, config any, transformIdentifier string, opts ...Option) map[string]beam.PCollection

Transform configures a new cross language transform to call a "schema transform" in an external SDK.

Types

type Option

type Option func(*options)

Option is the base type of all the schema transform options.

func ExpansionAddr

func ExpansionAddr(addr string) Option

ExpansionAddr is the URL of the expansion service to use.

func Input

func Input(name string, in beam.PCollection) Option

Input adds a named PCollection input to the transform.

func OutputType

func OutputType(name string, tpe beam.FullType) Option

OutputType specifies an output PCollection type of the transform. It must match the external transform's output schema.

func UnnamedOutputType

func UnnamedOutputType(tpe beam.FullType) Option

UnnamedOutputType specifies an output PCollection type of the transform. It must match the external transform's output schema. This is simply syntactic sugar for OutputType(beam.UnnamedOutputTag(), tpe).

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL