dofns

Documentation

Index

• type DropKeyFn
  • func NewDropKeyFn(keyType reflect.Type, valueType reflect.Type) *DropKeyFn
  • func (fn *DropKeyFn) ProcessElement(_ context.Context, _ beam.X, value beam.Y, emit func(beam.Y))
• type ExtractKeyFn
  • func NewExtractKeyFn(keyField string, elemType reflect.Type) *ExtractKeyFn
  • func (fn *ExtractKeyFn) ProcessElement(_ context.Context, elem beam.X, emit func(string, beam.X)) error

Types

type DropKeyFn

type DropKeyFn struct {
	XType beam.EncodedType
	YType beam.EncodedType
}

func NewDropKeyFn

func NewDropKeyFn(keyType reflect.Type, valueType reflect.Type) *DropKeyFn

func (*DropKeyFn) ProcessElement

func (fn *DropKeyFn) ProcessElement(_ context.Context, _ beam.X, value beam.Y, emit func(beam.Y))

type ExtractKeyFn

type ExtractKeyFn struct {
	KeyField string
	Type     beam.EncodedType
}

func NewExtractKeyFn

func NewExtractKeyFn(keyField string, elemType reflect.Type) *ExtractKeyFn

func (*ExtractKeyFn) ProcessElement

func (fn *ExtractKeyFn) ProcessElement(
	_ context.Context,
	elem beam.X,
	emit func(string, beam.X),
) error