Versions in this module Expand all Collapse all v2 v2.1.0 Apr 17, 2023 v2.0.0 Nov 15, 2022 Changes in this version + type TransformFn1x1 struct + Transform beam.EncodedFunc + func (fn *TransformFn1x1) ProcessElement(id beam.W, v beam.X) (beam.W, beam.Y) + func (fn *TransformFn1x1) Setup() + type TransformFn1x1Emit struct + EmitFnType beam.EncodedType + Transform beam.EncodedFunc + func (fn *TransformFn1x1Emit) ProcessElement(id beam.W, v beam.X, emit func(beam.W, beam.Y)) + func (fn *TransformFn1x1Emit) Setup() + type TransformFn1x1Err struct + Transform beam.EncodedFunc + func (fn *TransformFn1x1Err) ProcessElement(id beam.W, v beam.X) (beam.W, beam.Y, error) + func (fn *TransformFn1x1Err) Setup() + type TransformFn1x1ErrEmit struct + EmitFnType beam.EncodedType + Transform beam.EncodedFunc + func (fn *TransformFn1x1ErrEmit) ProcessElement(id beam.W, v beam.X, emit func(beam.W, beam.Y)) error + func (fn *TransformFn1x1ErrEmit) Setup() + type TransformFn1x2 struct + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFn1x2) ProcessElement(id beam.W, v beam.X) (beam.W, beam.Z, error) + func (fn *TransformFn1x2) Setup() + type TransformFn1x2Emit struct + EmitFnType beam.EncodedType + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFn1x2Emit) ProcessElement(id beam.W, v beam.X, emit func(beam.W, beam.Z)) error + func (fn *TransformFn1x2Emit) Setup() + type TransformFn1x2Err struct + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFn1x2Err) ProcessElement(id beam.W, v beam.X) (beam.W, beam.Z, error) + func (fn *TransformFn1x2Err) Setup() + type TransformFn1x2ErrEmit struct + EmitFnType beam.EncodedType + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFn1x2ErrEmit) ProcessElement(id beam.W, v beam.X, emit func(beam.W, beam.Z)) error + func (fn *TransformFn1x2ErrEmit) Setup() + type TransformFn2x1 struct + InputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFn2x1) ProcessElement(id beam.W, kvp beam.Z) (beam.W, beam.Y, error) + func (fn *TransformFn2x1) Setup() + type TransformFn2x1Emit struct + EmitFnType beam.EncodedType + InputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFn2x1Emit) ProcessElement(id beam.W, kvp beam.Z, emit func(beam.W, beam.Y)) error + func (fn *TransformFn2x1Emit) Setup() + type TransformFn2x1Err struct + InputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFn2x1Err) ProcessElement(id beam.W, kvp beam.Z) (beam.W, beam.Y, error) + func (fn *TransformFn2x1Err) Setup() + type TransformFn2x1ErrEmit struct + EmitFnType beam.EncodedType + InputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFn2x1ErrEmit) ProcessElement(id beam.W, kvp beam.Z, emit func(beam.W, beam.Y)) error + func (fn *TransformFn2x1ErrEmit) Setup() + type TransformFn2x2 struct + InputCodec *kv.Codec + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFn2x2) ProcessElement(id beam.W, kvp beam.Z) (beam.W, beam.Z, error) + func (fn *TransformFn2x2) Setup() + type TransformFn2x2Emit struct + EmitFnType beam.EncodedType + InputCodec *kv.Codec + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFn2x2Emit) ProcessElement(id beam.W, kvp beam.Z, emit func(beam.W, beam.Z)) error + func (fn *TransformFn2x2Emit) Setup() + type TransformFn2x2Err struct + InputCodec *kv.Codec + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFn2x2Err) ProcessElement(id beam.W, kvp beam.Z) (beam.W, beam.Z, error) + func (fn *TransformFn2x2Err) Setup() + type TransformFn2x2ErrEmit struct + EmitFnType beam.EncodedType + InputCodec *kv.Codec + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFn2x2ErrEmit) ProcessElement(id beam.W, kvp beam.Z, emit func(beam.W, beam.Z)) error + func (fn *TransformFn2x2ErrEmit) Setup() + type TransformFnCtx1x1 struct + Transform beam.EncodedFunc + func (fn *TransformFnCtx1x1) ProcessElement(ctx context.Context, id beam.W, v beam.X) (beam.W, beam.Y) + func (fn *TransformFnCtx1x1) Setup() + type TransformFnCtx1x1Emit struct + EmitFnType beam.EncodedType + Transform beam.EncodedFunc + func (fn *TransformFnCtx1x1Emit) ProcessElement(ctx context.Context, id beam.W, v beam.X, emit func(beam.W, beam.Y)) + func (fn *TransformFnCtx1x1Emit) Setup() + type TransformFnCtx1x1Err struct + Transform beam.EncodedFunc + func (fn *TransformFnCtx1x1Err) ProcessElement(ctx context.Context, id beam.W, v beam.X) (beam.W, beam.Y, error) + func (fn *TransformFnCtx1x1Err) Setup() + type TransformFnCtx1x1ErrEmit struct + EmitFnType beam.EncodedType + Transform beam.EncodedFunc + func (fn *TransformFnCtx1x1ErrEmit) ProcessElement(ctx context.Context, id beam.W, v beam.X, emit func(beam.W, beam.Y)) error + func (fn *TransformFnCtx1x1ErrEmit) Setup() + type TransformFnCtx1x2 struct + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFnCtx1x2) ProcessElement(ctx context.Context, id beam.W, v beam.X) (beam.W, beam.Z, error) + func (fn *TransformFnCtx1x2) Setup() + type TransformFnCtx1x2Emit struct + EmitFnType beam.EncodedType + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFnCtx1x2Emit) ProcessElement(ctx context.Context, id beam.W, v beam.X, emit func(beam.W, beam.Z)) error + func (fn *TransformFnCtx1x2Emit) Setup() + type TransformFnCtx1x2Err struct + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFnCtx1x2Err) ProcessElement(ctx context.Context, id beam.W, v beam.X) (beam.W, beam.Z, error) + func (fn *TransformFnCtx1x2Err) Setup() + type TransformFnCtx1x2ErrEmit struct + EmitFnType beam.EncodedType + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFnCtx1x2ErrEmit) ProcessElement(ctx context.Context, id beam.W, v beam.X, emit func(beam.W, beam.Z)) error + func (fn *TransformFnCtx1x2ErrEmit) Setup() + type TransformFnCtx2x1 struct + InputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFnCtx2x1) ProcessElement(ctx context.Context, id beam.W, kvp beam.Z) (beam.W, beam.Y, error) + func (fn *TransformFnCtx2x1) Setup() + type TransformFnCtx2x1Emit struct + EmitFnType beam.EncodedType + InputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFnCtx2x1Emit) ProcessElement(ctx context.Context, id beam.W, kvp beam.Z, emit func(beam.W, beam.Y)) error + func (fn *TransformFnCtx2x1Emit) Setup() + type TransformFnCtx2x1Err struct + InputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFnCtx2x1Err) ProcessElement(ctx context.Context, id beam.W, kvp beam.Z) (beam.W, beam.Y, error) + func (fn *TransformFnCtx2x1Err) Setup() + type TransformFnCtx2x1ErrEmit struct + EmitFnType beam.EncodedType + InputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFnCtx2x1ErrEmit) ProcessElement(ctx context.Context, id beam.W, kvp beam.Z, emit func(beam.W, beam.Y)) error + func (fn *TransformFnCtx2x1ErrEmit) Setup() + type TransformFnCtx2x2 struct + InputCodec *kv.Codec + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFnCtx2x2) ProcessElement(ctx context.Context, id beam.W, kvp beam.Z) (beam.W, beam.Z, error) + func (fn *TransformFnCtx2x2) Setup() + type TransformFnCtx2x2Emit struct + EmitFnType beam.EncodedType + InputCodec *kv.Codec + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFnCtx2x2Emit) ProcessElement(ctx context.Context, id beam.W, kvp beam.Z, emit func(beam.W, beam.Z)) error + func (fn *TransformFnCtx2x2Emit) Setup() + type TransformFnCtx2x2Err struct + InputCodec *kv.Codec + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFnCtx2x2Err) ProcessElement(ctx context.Context, id beam.W, kvp beam.Z) (beam.W, beam.Z, error) + func (fn *TransformFnCtx2x2Err) Setup() + type TransformFnCtx2x2ErrEmit struct + EmitFnType beam.EncodedType + InputCodec *kv.Codec + OutputCodec *kv.Codec + Transform beam.EncodedFunc + func (fn *TransformFnCtx2x2ErrEmit) ProcessElement(ctx context.Context, id beam.W, kvp beam.Z, emit func(beam.W, beam.Z)) error + func (fn *TransformFnCtx2x2ErrEmit) Setup() Other modules containing this package github.com/google/differential-privacy/privacy-on-beam github.com/google/differential-privacy/privacy-on-beam/v3
Go to main page