transformation

package
v0.0.153 Latest Latest
Warning

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

Go to latest
Published: Oct 27, 2024 License: BSD-3-Clause Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AppSink

func AppSink[T any](name string, stream runtime.TypedStream[T], consumer runtime.ConsumerFunc[T]) runtime.TypedStreamConsumer[T]

func Delay

func Delay[T any](name string, stream runtime.TypedStream[T], f runtime.DelayFunction[T]) runtime.TypedConsumedStream[T]

func Filter

func Filter[T any](name string, stream runtime.TypedStream[T], f runtime.FilterFunction[T]) runtime.TypedConsumedStream[T]

func FlatMap

func FlatMap[T, R any](name string, stream runtime.TypedStream[T], f runtime.FlatMapFunction[T, R]) runtime.TypedTransformConsumedStream[T, R]

func FlatMapIterable

func FlatMapIterable[T, R any](name string, stream runtime.TypedStream[T]) runtime.TypedTransformConsumedStream[T, R]

func ForEach

func ForEach[T any](name string, stream runtime.TypedStream[T], f runtime.ForEachFunction[T]) runtime.TypedConsumedStream[T]

func Join

func Join[K comparable, T1, T2, R any](name string, stream runtime.TypedStream[datastruct.KeyValue[K, T1]],
	streamRight runtime.TypedStream[datastruct.KeyValue[K, T2]],
	f runtime.JoinFunction[K, T1, T2, R]) runtime.TypedJoinConsumedStream[K, T1, T2, R]

func Map

func Map[T, R any](name string, stream runtime.TypedStream[T], f runtime.MapFunction[T, R]) runtime.TypedTransformConsumedStream[T, R]

func Merge

func Merge[T any](name string, streams ...runtime.TypedStream[T]) runtime.TypedConsumedStream[T]

func MultiJoin

func MultiJoin[K comparable, T, R any](
	name string, leftStream runtime.TypedStream[datastruct.KeyValue[K, T]],
	f runtime.MultiJoinFunction[K, T, R]) runtime.TypedMultiJoinConsumedStream[K, T, R]
func MultiJoinLink[K comparable, T1, T2, R any](
	multiJoin runtime.TypedStream[R],
	stream runtime.TypedStream[datastruct.KeyValue[K, T2]])

func OutStub

func OutStub[T any](name string, stream runtime.TypedStream[T], consumer runtime.ConsumerFunc[T]) runtime.TypedStreamConsumer[T]

func OutStubBinary

func OutStubBinary[T any](name string, stream runtime.TypedStream[T], consumer runtime.BinaryConsumerFunc) runtime.TypedStreamConsumer[T]

func OutStubBinaryKV

func OutStubBinaryKV[T any](name string, stream runtime.TypedStream[T], consumer runtime.BinaryKVConsumerFunc) runtime.TypedStreamConsumer[T]

func Parallels

func Parallels[T, R any](name string, stream runtime.TypedStream[T], f runtime.ParallelsFunction[T, R]) runtime.TypedTransformConsumedStream[T, R]

func Sink

func Sink[T any](name string, stream runtime.TypedStream[T]) runtime.TypedSinkStream[T]

func Split

func Split[T any](name string, stream runtime.TypedStream[T]) runtime.TypedSplitStream[T]

Types

This section is empty.

Jump to

Keyboard shortcuts

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