transformation

Documentation

Index

• func AppSink[T any](name string, stream runtime.TypedStream[T], consumer runtime.ConsumerFunc[T]) runtime.TypedStreamConsumer[T]
• func Delay[T any](name string, stream runtime.TypedStream[T], f runtime.DelayFunction[T]) runtime.TypedConsumedStream[T]
• func Filter[T any](name string, stream runtime.TypedStream[T], f runtime.FilterFunction[T]) runtime.TypedConsumedStream[T]
• func FlatMap[T, R any](name string, stream runtime.TypedStream[T], f runtime.FlatMapFunction[T, R]) runtime.TypedTransformConsumedStream[T, R]
• func FlatMapIterable[T, R any](name string, stream runtime.TypedStream[T]) runtime.TypedTransformConsumedStream[T, R]
• func ForEach[T any](name string, stream runtime.TypedStream[T], f runtime.ForEachFunction[T]) runtime.TypedConsumedStream[T]
• func InStub[T any](name string, env runtime.ServiceExecutionEnvironment) runtime.TypedBinaryConsumedStream[T]
• func InStubKV[K comparable, V any](name string, env runtime.ServiceExecutionEnvironment) runtime.TypedBinaryKVConsumedStream[datastruct.KeyValue[K, V]]
• func Input[T any](name string, env runtime.ServiceExecutionEnvironment) runtime.TypedInputStream[T]
• func Join[K comparable, T1, T2, R any](name string, stream runtime.TypedStream[datastruct.KeyValue[K, T1]], ...) runtime.TypedJoinConsumedStream[K, T1, T2, R]
• func KeyBy[T any, K comparable, V any](name string, stream runtime.TypedStream[T], f runtime.KeyByFunction[T, K, V]) runtime.TypedTransformConsumedStream[T, datastruct.KeyValue[K, V]]
• func Link[T any](name string, env runtime.ServiceExecutionEnvironment) runtime.TypedLinkStream[T]
• func Map[T, R any](name string, stream runtime.TypedStream[T], f runtime.MapFunction[T, R]) runtime.TypedTransformConsumedStream[T, R]
• func Merge[T any](name string, stream runtime.TypedStream[T], streams ...runtime.TypedStream[T]) runtime.TypedConsumedStream[T]
• func MultiJoin[K comparable, T, R any](name string, leftStream runtime.TypedStream[datastruct.KeyValue[K, T]], ...) runtime.TypedMultiJoinConsumedStream[K, T, R]
• func MultiJoinLink[K comparable, T1, T2, R any](multiJoinStream runtime.TypedMultiJoinConsumedStream[K, T1, R], ...)
• func OutStub[T any](name string, stream runtime.TypedStream[T], consumer runtime.ConsumerFunc[T]) runtime.TypedStreamConsumer[T]
• func OutStubBinary[T any](name string, stream runtime.TypedStream[T], ...) runtime.TypedStreamConsumer[T]
• func OutStubBinaryKV[T any](name string, stream runtime.TypedStream[T], ...) runtime.TypedStreamConsumer[T]
• func Parallels[T, R any](name string, stream runtime.TypedStream[T], f runtime.ParallelsFunction[T, R]) runtime.TypedTransformConsumedStream[T, R]
• func Sink[T any](name string, stream runtime.TypedStream[T]) runtime.TypedSinkStream[T]
• func Split[T any](name string, stream runtime.TypedStream[T]) runtime.TypedSplitStream[T]
• func SplitInStub[T any](name string, env runtime.ServiceExecutionEnvironment) runtime.TypedBinarySplitStream[T]
• func SplitInStubKV[K comparable, V any](name string, env runtime.ServiceExecutionEnvironment) runtime.TypedBinaryKVSplitStream[datastruct.KeyValue[K, V]]

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 InStub

func InStub[T any](name string, env runtime.ServiceExecutionEnvironment) runtime.TypedBinaryConsumedStream[T]

func InStubKV

func InStubKV[K comparable, V any](name string, env runtime.ServiceExecutionEnvironment) runtime.TypedBinaryKVConsumedStream[datastruct.KeyValue[K, V]]

func Input

func Input[T any](name string, env runtime.ServiceExecutionEnvironment) runtime.TypedInputStream[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 KeyBy

func KeyBy[T any, K comparable, V any](name string, stream runtime.TypedStream[T],
	f runtime.KeyByFunction[T, K, V]) runtime.TypedTransformConsumedStream[T, datastruct.KeyValue[K, V]]

func Link

func Link[T any](name string, env runtime.ServiceExecutionEnvironment) runtime.TypedLinkStream[T]

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, stream runtime.TypedStream[T],
	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

func MultiJoinLink[K comparable, T1, T2, R any](
	multiJoinStream runtime.TypedMultiJoinConsumedStream[K, T1, R],
	rightStream 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]

func SplitInStub

func SplitInStub[T any](name string, env runtime.ServiceExecutionEnvironment) runtime.TypedBinarySplitStream[T]

func SplitInStubKV

func SplitInStubKV[K comparable, V any](name string, env runtime.ServiceExecutionEnvironment) runtime.TypedBinaryKVSplitStream[datastruct.KeyValue[K, V]]