generated

package
v2.1.0 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2023 License: Apache-2.0, BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Overview

Package generated was generated automatically. Do not edit manually.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type TransformFn1x1 

type TransformFn1x1 struct {
	Transform beam.EncodedFunc
	// contains filtered or unexported fields
}

TransformFn1x1 is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: false
HasCtx: false
HasEmit: false
HasErrOutput: false

func (*TransformFn1x1) ProcessElement 

func (fn *TransformFn1x1) ProcessElement(id beam.W, v beam.X) (beam.W, beam.Y)

ProcessElement runs the wrapped DoFn.

func (*TransformFn1x1) Setup 

func (fn *TransformFn1x1) Setup()

Setup initializes the TransformFn.

type TransformFn1x1Emit 

type TransformFn1x1Emit struct {
	Transform beam.EncodedFunc

	EmitFnType beam.EncodedType
	// contains filtered or unexported fields
}

TransformFn1x1Emit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: false
HasCtx: false
HasEmit: true
HasErrOutput: false

func (*TransformFn1x1Emit) ProcessElement 

func (fn *TransformFn1x1Emit) ProcessElement(id beam.W, v beam.X, emit func(beam.W, beam.Y))

ProcessElement runs the wrapped DoFn.

func (*TransformFn1x1Emit) Setup 

func (fn *TransformFn1x1Emit) Setup()

Setup initializes the TransformFn.

type TransformFn1x1Err 

type TransformFn1x1Err struct {
	Transform beam.EncodedFunc
	// contains filtered or unexported fields
}

TransformFn1x1Err is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: false
HasCtx: false
HasEmit: false
HasErrOutput: true

func (*TransformFn1x1Err) ProcessElement 

func (fn *TransformFn1x1Err) ProcessElement(id beam.W, v beam.X) (beam.W, beam.Y, error)

ProcessElement runs the wrapped DoFn.

func (*TransformFn1x1Err) Setup 

func (fn *TransformFn1x1Err) Setup()

Setup initializes the TransformFn.

type TransformFn1x1ErrEmit 

type TransformFn1x1ErrEmit struct {
	Transform beam.EncodedFunc

	EmitFnType beam.EncodedType
	// contains filtered or unexported fields
}

TransformFn1x1ErrEmit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: false
HasCtx: false
HasEmit: true
HasErrOutput: true

func (*TransformFn1x1ErrEmit) ProcessElement 

func (fn *TransformFn1x1ErrEmit) ProcessElement(id beam.W, v beam.X, emit func(beam.W, beam.Y)) error

ProcessElement runs the wrapped DoFn.

func (*TransformFn1x1ErrEmit) Setup 

func (fn *TransformFn1x1ErrEmit) Setup()

Setup initializes the TransformFn.

type TransformFn1x2 

type TransformFn1x2 struct {
	Transform beam.EncodedFunc

	OutputCodec *kv.Codec
	// contains filtered or unexported fields
}

TransformFn1x2 is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: true
HasCtx: false
HasEmit: false
HasErrOutput: false

func (*TransformFn1x2) ProcessElement 

func (fn *TransformFn1x2) ProcessElement(id beam.W, v beam.X) (beam.W, kv.Pair, error)

ProcessElement runs the wrapped DoFn.

func (*TransformFn1x2) Setup 

func (fn *TransformFn1x2) Setup()

Setup initializes the TransformFn.

type TransformFn1x2Emit 

type TransformFn1x2Emit struct {
	Transform beam.EncodedFunc

	OutputCodec *kv.Codec
	EmitFnType  beam.EncodedType
	// contains filtered or unexported fields
}

TransformFn1x2Emit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: true
HasCtx: false
HasEmit: true
HasErrOutput: false

func (*TransformFn1x2Emit) ProcessElement 

func (fn *TransformFn1x2Emit) ProcessElement(id beam.W, v beam.X, emit func(beam.W, kv.Pair)) error

ProcessElement runs the wrapped DoFn.

func (*TransformFn1x2Emit) Setup 

func (fn *TransformFn1x2Emit) Setup()

Setup initializes the TransformFn.

type TransformFn1x2Err 

type TransformFn1x2Err struct {
	Transform beam.EncodedFunc

	OutputCodec *kv.Codec
	// contains filtered or unexported fields
}

TransformFn1x2Err is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: true
HasCtx: false
HasEmit: false
HasErrOutput: true

func (*TransformFn1x2Err) ProcessElement 

func (fn *TransformFn1x2Err) ProcessElement(id beam.W, v beam.X) (beam.W, kv.Pair, error)

ProcessElement runs the wrapped DoFn.

func (*TransformFn1x2Err) Setup 

func (fn *TransformFn1x2Err) Setup()

Setup initializes the TransformFn.

type TransformFn1x2ErrEmit 

type TransformFn1x2ErrEmit struct {
	Transform beam.EncodedFunc

	OutputCodec *kv.Codec
	EmitFnType  beam.EncodedType
	// contains filtered or unexported fields
}

TransformFn1x2ErrEmit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: true
HasCtx: false
HasEmit: true
HasErrOutput: true

func (*TransformFn1x2ErrEmit) ProcessElement 

func (fn *TransformFn1x2ErrEmit) ProcessElement(id beam.W, v beam.X, emit func(beam.W, kv.Pair)) error

ProcessElement runs the wrapped DoFn.

func (*TransformFn1x2ErrEmit) Setup 

func (fn *TransformFn1x2ErrEmit) Setup()

Setup initializes the TransformFn.

type TransformFn2x1 

type TransformFn2x1 struct {
	Transform beam.EncodedFunc

	InputCodec *kv.Codec
	// contains filtered or unexported fields
}

TransformFn2x1 is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: false
HasCtx: false
HasEmit: false
HasErrOutput: false

func (*TransformFn2x1) ProcessElement 

func (fn *TransformFn2x1) ProcessElement(id beam.W, inputKV kv.Pair) (beam.W, beam.Y, error)

ProcessElement runs the wrapped DoFn.

func (*TransformFn2x1) Setup 

func (fn *TransformFn2x1) Setup()

Setup initializes the TransformFn.

type TransformFn2x1Emit 

type TransformFn2x1Emit struct {
	Transform beam.EncodedFunc

	InputCodec *kv.Codec
	EmitFnType beam.EncodedType
	// contains filtered or unexported fields
}

TransformFn2x1Emit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: false
HasCtx: false
HasEmit: true
HasErrOutput: false

func (*TransformFn2x1Emit) ProcessElement 

func (fn *TransformFn2x1Emit) ProcessElement(id beam.W, inputKV kv.Pair, emit func(beam.W, beam.Y)) error

ProcessElement runs the wrapped DoFn.

func (*TransformFn2x1Emit) Setup 

func (fn *TransformFn2x1Emit) Setup()

Setup initializes the TransformFn.

type TransformFn2x1Err 

type TransformFn2x1Err struct {
	Transform beam.EncodedFunc

	InputCodec *kv.Codec
	// contains filtered or unexported fields
}

TransformFn2x1Err is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: false
HasCtx: false
HasEmit: false
HasErrOutput: true

func (*TransformFn2x1Err) ProcessElement 

func (fn *TransformFn2x1Err) ProcessElement(id beam.W, inputKV kv.Pair) (beam.W, beam.Y, error)

ProcessElement runs the wrapped DoFn.

func (*TransformFn2x1Err) Setup 

func (fn *TransformFn2x1Err) Setup()

Setup initializes the TransformFn.

type TransformFn2x1ErrEmit 

type TransformFn2x1ErrEmit struct {
	Transform beam.EncodedFunc

	InputCodec *kv.Codec
	EmitFnType beam.EncodedType
	// contains filtered or unexported fields
}

TransformFn2x1ErrEmit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: false
HasCtx: false
HasEmit: true
HasErrOutput: true

func (*TransformFn2x1ErrEmit) ProcessElement 

func (fn *TransformFn2x1ErrEmit) ProcessElement(id beam.W, inputKV kv.Pair, emit func(beam.W, beam.Y)) error

ProcessElement runs the wrapped DoFn.

func (*TransformFn2x1ErrEmit) Setup 

func (fn *TransformFn2x1ErrEmit) Setup()

Setup initializes the TransformFn.

type TransformFn2x2 

type TransformFn2x2 struct {
	Transform beam.EncodedFunc

	InputCodec  *kv.Codec
	OutputCodec *kv.Codec
	// contains filtered or unexported fields
}

TransformFn2x2 is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: true
HasCtx: false
HasEmit: false
HasErrOutput: false

func (*TransformFn2x2) ProcessElement 

func (fn *TransformFn2x2) ProcessElement(id beam.W, inputKV kv.Pair) (beam.W, kv.Pair, error)

ProcessElement runs the wrapped DoFn.

func (*TransformFn2x2) Setup 

func (fn *TransformFn2x2) Setup()

Setup initializes the TransformFn.

type TransformFn2x2Emit 

type TransformFn2x2Emit struct {
	Transform beam.EncodedFunc

	InputCodec  *kv.Codec
	OutputCodec *kv.Codec
	EmitFnType  beam.EncodedType
	// contains filtered or unexported fields
}

TransformFn2x2Emit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: true
HasCtx: false
HasEmit: true
HasErrOutput: false

func (*TransformFn2x2Emit) ProcessElement 

func (fn *TransformFn2x2Emit) ProcessElement(id beam.W, inputKV kv.Pair, emit func(beam.W, kv.Pair)) error

ProcessElement runs the wrapped DoFn.

func (*TransformFn2x2Emit) Setup 

func (fn *TransformFn2x2Emit) Setup()

Setup initializes the TransformFn.

type TransformFn2x2Err 

type TransformFn2x2Err struct {
	Transform beam.EncodedFunc

	InputCodec  *kv.Codec
	OutputCodec *kv.Codec
	// contains filtered or unexported fields
}

TransformFn2x2Err is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: true
HasCtx: false
HasEmit: false
HasErrOutput: true

func (*TransformFn2x2Err) ProcessElement 

func (fn *TransformFn2x2Err) ProcessElement(id beam.W, inputKV kv.Pair) (beam.W, kv.Pair, error)

ProcessElement runs the wrapped DoFn.

func (*TransformFn2x2Err) Setup 

func (fn *TransformFn2x2Err) Setup()

Setup initializes the TransformFn.

type TransformFn2x2ErrEmit 

type TransformFn2x2ErrEmit struct {
	Transform beam.EncodedFunc

	InputCodec  *kv.Codec
	OutputCodec *kv.Codec
	EmitFnType  beam.EncodedType
	// contains filtered or unexported fields
}

TransformFn2x2ErrEmit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: true
HasCtx: false
HasEmit: true
HasErrOutput: true

func (*TransformFn2x2ErrEmit) ProcessElement 

func (fn *TransformFn2x2ErrEmit) ProcessElement(id beam.W, inputKV kv.Pair, emit func(beam.W, kv.Pair)) error

ProcessElement runs the wrapped DoFn.

func (*TransformFn2x2ErrEmit) Setup 

func (fn *TransformFn2x2ErrEmit) Setup()

Setup initializes the TransformFn.

type TransformFnCtx1x1 

type TransformFnCtx1x1 struct {
	Transform beam.EncodedFunc
	// contains filtered or unexported fields
}

TransformFnCtx1x1 is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: false
HasCtx: true
HasEmit: false
HasErrOutput: false

func (*TransformFnCtx1x1) ProcessElement 

func (fn *TransformFnCtx1x1) ProcessElement(ctx context.Context, id beam.W, v beam.X) (beam.W, beam.Y)

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx1x1) Setup 

func (fn *TransformFnCtx1x1) Setup()

Setup initializes the TransformFn.

type TransformFnCtx1x1Emit 

type TransformFnCtx1x1Emit struct {
	Transform beam.EncodedFunc

	EmitFnType beam.EncodedType
	// contains filtered or unexported fields
}

TransformFnCtx1x1Emit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: false
HasCtx: true
HasEmit: true
HasErrOutput: false

func (*TransformFnCtx1x1Emit) ProcessElement 

func (fn *TransformFnCtx1x1Emit) ProcessElement(ctx context.Context, id beam.W, v beam.X, emit func(beam.W, beam.Y))

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx1x1Emit) Setup 

func (fn *TransformFnCtx1x1Emit) Setup()

Setup initializes the TransformFn.

type TransformFnCtx1x1Err 

type TransformFnCtx1x1Err struct {
	Transform beam.EncodedFunc
	// contains filtered or unexported fields
}

TransformFnCtx1x1Err is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: false
HasCtx: true
HasEmit: false
HasErrOutput: true

func (*TransformFnCtx1x1Err) ProcessElement 

func (fn *TransformFnCtx1x1Err) ProcessElement(ctx context.Context, id beam.W, v beam.X) (beam.W, beam.Y, error)

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx1x1Err) Setup 

func (fn *TransformFnCtx1x1Err) Setup()

Setup initializes the TransformFn.

type TransformFnCtx1x1ErrEmit 

type TransformFnCtx1x1ErrEmit struct {
	Transform beam.EncodedFunc

	EmitFnType beam.EncodedType
	// contains filtered or unexported fields
}

TransformFnCtx1x1ErrEmit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: false
HasCtx: true
HasEmit: true
HasErrOutput: true

func (*TransformFnCtx1x1ErrEmit) ProcessElement 

func (fn *TransformFnCtx1x1ErrEmit) ProcessElement(ctx context.Context, id beam.W, v beam.X, emit func(beam.W, beam.Y)) error

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx1x1ErrEmit) Setup 

func (fn *TransformFnCtx1x1ErrEmit) Setup()

Setup initializes the TransformFn.

type TransformFnCtx1x2 

type TransformFnCtx1x2 struct {
	Transform beam.EncodedFunc

	OutputCodec *kv.Codec
	// contains filtered or unexported fields
}

TransformFnCtx1x2 is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: true
HasCtx: true
HasEmit: false
HasErrOutput: false

func (*TransformFnCtx1x2) ProcessElement 

func (fn *TransformFnCtx1x2) ProcessElement(ctx context.Context, id beam.W, v beam.X) (beam.W, kv.Pair, error)

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx1x2) Setup 

func (fn *TransformFnCtx1x2) Setup()

Setup initializes the TransformFn.

type TransformFnCtx1x2Emit 

type TransformFnCtx1x2Emit struct {
	Transform beam.EncodedFunc

	OutputCodec *kv.Codec
	EmitFnType  beam.EncodedType
	// contains filtered or unexported fields
}

TransformFnCtx1x2Emit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: true
HasCtx: true
HasEmit: true
HasErrOutput: false

func (*TransformFnCtx1x2Emit) ProcessElement 

func (fn *TransformFnCtx1x2Emit) ProcessElement(ctx context.Context, id beam.W, v beam.X, emit func(beam.W, kv.Pair)) error

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx1x2Emit) Setup 

func (fn *TransformFnCtx1x2Emit) Setup()

Setup initializes the TransformFn.

type TransformFnCtx1x2Err 

type TransformFnCtx1x2Err struct {
	Transform beam.EncodedFunc

	OutputCodec *kv.Codec
	// contains filtered or unexported fields
}

TransformFnCtx1x2Err is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: true
HasCtx: true
HasEmit: false
HasErrOutput: true

func (*TransformFnCtx1x2Err) ProcessElement 

func (fn *TransformFnCtx1x2Err) ProcessElement(ctx context.Context, id beam.W, v beam.X) (beam.W, kv.Pair, error)

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx1x2Err) Setup 

func (fn *TransformFnCtx1x2Err) Setup()

Setup initializes the TransformFn.

type TransformFnCtx1x2ErrEmit 

type TransformFnCtx1x2ErrEmit struct {
	Transform beam.EncodedFunc

	OutputCodec *kv.Codec
	EmitFnType  beam.EncodedType
	// contains filtered or unexported fields
}

TransformFnCtx1x2ErrEmit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: false
HasKVOutput: true
HasCtx: true
HasEmit: true
HasErrOutput: true

func (*TransformFnCtx1x2ErrEmit) ProcessElement 

func (fn *TransformFnCtx1x2ErrEmit) ProcessElement(ctx context.Context, id beam.W, v beam.X, emit func(beam.W, kv.Pair)) error

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx1x2ErrEmit) Setup 

func (fn *TransformFnCtx1x2ErrEmit) Setup()

Setup initializes the TransformFn.

type TransformFnCtx2x1 

type TransformFnCtx2x1 struct {
	Transform beam.EncodedFunc

	InputCodec *kv.Codec
	// contains filtered or unexported fields
}

TransformFnCtx2x1 is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: false
HasCtx: true
HasEmit: false
HasErrOutput: false

func (*TransformFnCtx2x1) ProcessElement 

func (fn *TransformFnCtx2x1) ProcessElement(ctx context.Context, id beam.W, inputKV kv.Pair) (beam.W, beam.Y, error)

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx2x1) Setup 

func (fn *TransformFnCtx2x1) Setup()

Setup initializes the TransformFn.

type TransformFnCtx2x1Emit 

type TransformFnCtx2x1Emit struct {
	Transform beam.EncodedFunc

	InputCodec *kv.Codec
	EmitFnType beam.EncodedType
	// contains filtered or unexported fields
}

TransformFnCtx2x1Emit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: false
HasCtx: true
HasEmit: true
HasErrOutput: false

func (*TransformFnCtx2x1Emit) ProcessElement 

func (fn *TransformFnCtx2x1Emit) ProcessElement(ctx context.Context, id beam.W, inputKV kv.Pair, emit func(beam.W, beam.Y)) error

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx2x1Emit) Setup 

func (fn *TransformFnCtx2x1Emit) Setup()

Setup initializes the TransformFn.

type TransformFnCtx2x1Err 

type TransformFnCtx2x1Err struct {
	Transform beam.EncodedFunc

	InputCodec *kv.Codec
	// contains filtered or unexported fields
}

TransformFnCtx2x1Err is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: false
HasCtx: true
HasEmit: false
HasErrOutput: true

func (*TransformFnCtx2x1Err) ProcessElement 

func (fn *TransformFnCtx2x1Err) ProcessElement(ctx context.Context, id beam.W, inputKV kv.Pair) (beam.W, beam.Y, error)

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx2x1Err) Setup 

func (fn *TransformFnCtx2x1Err) Setup()

Setup initializes the TransformFn.

type TransformFnCtx2x1ErrEmit 

type TransformFnCtx2x1ErrEmit struct {
	Transform beam.EncodedFunc

	InputCodec *kv.Codec
	EmitFnType beam.EncodedType
	// contains filtered or unexported fields
}

TransformFnCtx2x1ErrEmit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: false
HasCtx: true
HasEmit: true
HasErrOutput: true

func (*TransformFnCtx2x1ErrEmit) ProcessElement 

func (fn *TransformFnCtx2x1ErrEmit) ProcessElement(ctx context.Context, id beam.W, inputKV kv.Pair, emit func(beam.W, beam.Y)) error

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx2x1ErrEmit) Setup 

func (fn *TransformFnCtx2x1ErrEmit) Setup()

Setup initializes the TransformFn.

type TransformFnCtx2x2 

type TransformFnCtx2x2 struct {
	Transform beam.EncodedFunc

	InputCodec  *kv.Codec
	OutputCodec *kv.Codec
	// contains filtered or unexported fields
}

TransformFnCtx2x2 is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: true
HasCtx: true
HasEmit: false
HasErrOutput: false

func (*TransformFnCtx2x2) ProcessElement 

func (fn *TransformFnCtx2x2) ProcessElement(ctx context.Context, id beam.W, inputKV kv.Pair) (beam.W, kv.Pair, error)

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx2x2) Setup 

func (fn *TransformFnCtx2x2) Setup()

Setup initializes the TransformFn.

type TransformFnCtx2x2Emit 

type TransformFnCtx2x2Emit struct {
	Transform beam.EncodedFunc

	InputCodec  *kv.Codec
	OutputCodec *kv.Codec
	EmitFnType  beam.EncodedType
	// contains filtered or unexported fields
}

TransformFnCtx2x2Emit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: true
HasCtx: true
HasEmit: true
HasErrOutput: false

func (*TransformFnCtx2x2Emit) ProcessElement 

func (fn *TransformFnCtx2x2Emit) ProcessElement(ctx context.Context, id beam.W, inputKV kv.Pair, emit func(beam.W, kv.Pair)) error

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx2x2Emit) Setup 

func (fn *TransformFnCtx2x2Emit) Setup()

Setup initializes the TransformFn.

type TransformFnCtx2x2Err 

type TransformFnCtx2x2Err struct {
	Transform beam.EncodedFunc

	InputCodec  *kv.Codec
	OutputCodec *kv.Codec
	// contains filtered or unexported fields
}

TransformFnCtx2x2Err is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: true
HasCtx: true
HasEmit: false
HasErrOutput: true

func (*TransformFnCtx2x2Err) ProcessElement 

func (fn *TransformFnCtx2x2Err) ProcessElement(ctx context.Context, id beam.W, inputKV kv.Pair) (beam.W, kv.Pair, error)

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx2x2Err) Setup 

func (fn *TransformFnCtx2x2Err) Setup()

Setup initializes the TransformFn.

type TransformFnCtx2x2ErrEmit 

type TransformFnCtx2x2ErrEmit struct {
	Transform beam.EncodedFunc

	InputCodec  *kv.Codec
	OutputCodec *kv.Codec
	EmitFnType  beam.EncodedType
	// contains filtered or unexported fields
}

TransformFnCtx2x2ErrEmit is a wrapper for DoFns of the following type on a PrivatePCollection: 

HasKVInput: true
HasKVOutput: true
HasCtx: true
HasEmit: true
HasErrOutput: true

func (*TransformFnCtx2x2ErrEmit) ProcessElement 

func (fn *TransformFnCtx2x2ErrEmit) ProcessElement(ctx context.Context, id beam.W, inputKV kv.Pair, emit func(beam.W, kv.Pair)) error

ProcessElement runs the wrapped DoFn.

func (*TransformFnCtx2x2ErrEmit) Setup 

func (fn *TransformFnCtx2x2ErrEmit) Setup()

Setup initializes the TransformFn.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.