Class KStream

Namespace

Org.Apache.Kafka.Streams.Kstream

Assembly

MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html

public class KStream : JVMBridgeBase<KStream>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBase>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<KStream>

KStream

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBase>

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeDefinition

Inherited Members

JVMBridgeBase<KStream>.SExecute(IJavaType, string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignature(IJavaType, string, string, params object[])

JVMBridgeBase<KStream>.SExecute(string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignature(string, string, params object[])

JVMBridgeBase<KStream>.SExecute<TReturn>(IJavaType, string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignature<TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<KStream>.SExecute<TReturn>(string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase<KStream>.SExecute(Type, IJavaType, string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])

JVMBridgeBase<KStream>.SExecute(Type, string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignature(Type, string, string, params object[])

JVMBridgeBase<KStream>.SExecute<TNewClass, TReturn>(IJavaType, string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignature<TNewClass, TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<KStream>.SExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase<KStream>.SExecute<TReturn>(Type, IJavaType, string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignature<TReturn>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<KStream>.SExecute<TReturn>(Type, string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignature<TReturn>(Type, string, string, params object[])

JVMBridgeBase<KStream>.SExecute<TNewClass, TReturn, TConverter>(IJavaType, string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(IJavaType, string, string, params object[])

JVMBridgeBase<KStream>.SExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase<KStream>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignature<TReturn, TConverter>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<KStream>.SExecute<TReturn, TConverter>(Type, string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignature<TReturn, TConverter>(Type, string, string, params object[])

JVMBridgeBase<KStream>.SExecuteArray<TArrayType>(IJavaType, string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignatureArray<TArrayType>(IJavaType, string, string, params object[])

JVMBridgeBase<KStream>.SExecuteArray<TArrayType>(string, params object[])

JVMBridgeBase<KStream>.SExecuteWithSignatureArray<TArrayType>(string, string, params object[])

JVMBridgeBase<KStream>.SGetField(IJavaType, string)

JVMBridgeBase<KStream>.SGetField(string)

JVMBridgeBase<KStream>.SGetField<TReturn>(IJavaType, string)

JVMBridgeBase<KStream>.SGetField<TReturn>(string)

JVMBridgeBase<KStream>.SGetFieldArray<TReturn>(IJavaType, string)

JVMBridgeBase<KStream>.SGetFieldArray<TReturn>(string)

JVMBridgeBase<KStream>.SSetField(IJavaType, string, object)

JVMBridgeBase<KStream>.SSetField(string, object)

JVMBridgeBase<KStream>.SSetField<TValue>(IJavaType, string, TValue)

JVMBridgeBase<KStream>.SSetField<TValue>(string, TValue)

JVMBridgeBase<KStream>.IsAssignableFrom(string)

JVMBridgeBase<KStream>.IsAssignableFrom(IJavaType)

JVMBridgeBase<KStream>.IsAssignableFrom<T>()

JVMBridgeBase<KStream>.New(params object[])

JVMBridgeBase<KStream>.NewWithSignature(string, params object[])

JVMBridgeBase<KStream>.NewAndWrapsDirect<TNewClass>(string, params object[])

JVMBridgeBase<KStream>.NewWithSignatureAndWrapsDirect<TNewClass>(string, string, params object[])

JVMBridgeBase<KStream>.Execute<T>(params T[])

JVMBridgeBase<KStream>.DynBridgeClazz

JVMBridgeBase<KStream>.BridgeClazz

JVMBridgeBase.ReferenceEqualsJVM(JVMBridgeBase, JVMBridgeBase)

JVMBridgeBase.ClazzOf<TClass>(bool)

JVMBridgeBase.ClazzOf<TClass>(out Exception, bool)

JVMBridgeBase.ClazzOf(string, bool)

JVMBridgeBase.ClazzOf(string, out Exception, bool)

JVMBridgeBase.RuntimeClassNameOf<T>()

JVMBridgeBase.RuntimeClassNameOf(Type)

JVMBridgeBase.ClassNameOf<T>()

JVMBridgeBase.ClassOf<T>()

JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)

JVMBridgeBase.Wraps<TReturn>(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)

JVMBridgeBase.Wraps<TReturn, TConverter>(Type, IJavaObject)

JVMBridgeBase.MonitorEnter()

JVMBridgeBase.MonitorExit()

JVMBridgeBase.IsInstanceOf(string)

JVMBridgeBase.IsInstanceOf(IJavaType)

JVMBridgeBase.IsInstanceOf<T>()

JVMBridgeBase.RuntimeIsInstanceOf<T>()

JVMBridgeBase.CastTo<TNewClass>()

JVMBridgeBase.CastDirect<TNewClass>()

JVMBridgeBase.Dispose()

JVMBridgeBase.Dispose(bool)

JVMBridgeBase.ToString()

JVMBridgeBase.Equals(IJVMBridgeBase)

JVMBridgeBase.Equals(object)

JVMBridgeBase.GetHashCode()

JVMBridgeBase.Notify()

JVMBridgeBase.NotifyAll()

JVMBridgeBase.Wait()

JVMBridgeBase.Wait(long)

JVMBridgeBase.Wait(long, int)

JVMBridgeBase.IExecute(string, params object[])

JVMBridgeBase.IExecuteWithSignature(string, string, params object[])

JVMBridgeBase.IExecute<TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase.IExecuteArray<TArrayType>(string, params object[])

JVMBridgeBase.IExecuteWithSignatureArray<TArrayType>(string, string, params object[])

JVMBridgeBase.IGetField(string)

JVMBridgeBase.IGetField<TReturn>(string)

JVMBridgeBase.IGetFieldArray<TReturn>(string)

JVMBridgeBase.ISetField(string, object)

JVMBridgeBase.ISetField<TValue>(string, TValue)

JVMBridgeBase.DynBridgeInstance

JVMBridgeBase.BridgeInstance

JVMBridgeBase.IsBridgeListener

DynamicObject.TryGetMember(GetMemberBinder, out object)

DynamicObject.TrySetMember(SetMemberBinder, object)

DynamicObject.TryDeleteMember(DeleteMemberBinder)

DynamicObject.TryInvokeMember(InvokeMemberBinder, object[], out object)

DynamicObject.TryConvert(ConvertBinder, out object)

DynamicObject.TryCreateInstance(CreateInstanceBinder, object[], out object)

DynamicObject.TryInvoke(InvokeBinder, object[], out object)

DynamicObject.TryBinaryOperation(BinaryOperationBinder, object, out object)

DynamicObject.TryUnaryOperation(UnaryOperationBinder, out object)

DynamicObject.TryGetIndex(GetIndexBinder, object[], out object)

DynamicObject.TrySetIndex(SetIndexBinder, object[], object)

DynamicObject.TryDeleteIndex(DeleteIndexBinder, object[])

DynamicObject.GetDynamicMemberNames()

DynamicObject.GetMetaObject(Expression)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetType()

object.MemberwiseClone()

Constructors

KStream()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

[Obsolete("KStream class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public KStream()

KStream(IJVMBridgeBaseInitializer)

Internal constructor: used internally from JCOBridge

[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public KStream(IJVMBridgeBaseInitializer initializer)

Parameters

initializer IJVMBridgeBaseInitializer

KStream(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

[Obsolete("KStream class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public KStream(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

true if the BridgeClassName is an abstract class, i.e. cannot be created an instance

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

true if the BridgeClassName implements Closeable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

true if the BridgeClassName is an interface, i.e. does not have any public constructor

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

true if the BridgeClassName is a static class, i.e. does not have any public constructor

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

Filter(Predicate)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#filter(org.apache.kafka.streams.kstream.Predicate)

public KStream Filter(Predicate arg0)

Parameters

arg0 Predicate

Predicate

Returns

KStream

KStream

Filter(Predicate, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#filter(org.apache.kafka.streams.kstream.Predicate,org.apache.kafka.streams.kstream.Named)

public KStream Filter(Predicate arg0, Named arg1)

Parameters

arg0 Predicate

Predicate

arg1 Named

Named

Returns

KStream

KStream

FilterNot(Predicate)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#filterNot(org.apache.kafka.streams.kstream.Predicate)

public KStream FilterNot(Predicate arg0)

Parameters

arg0 Predicate

Predicate

Returns

KStream

KStream

FilterNot(Predicate, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#filterNot(org.apache.kafka.streams.kstream.Predicate,org.apache.kafka.streams.kstream.Named)

public KStream FilterNot(Predicate arg0, Named arg1)

Parameters

arg0 Predicate

Predicate

arg1 Named

Named

Returns

KStream

KStream

FlatMap(KeyValueMapper)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#flatMap(org.apache.kafka.streams.kstream.KeyValueMapper)

public KStream FlatMap(KeyValueMapper arg0)

Parameters

arg0 KeyValueMapper

KeyValueMapper

Returns

KStream

KStream

FlatMap(KeyValueMapper, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#flatMap(org.apache.kafka.streams.kstream.KeyValueMapper,org.apache.kafka.streams.kstream.Named)

public KStream FlatMap(KeyValueMapper arg0, Named arg1)

Parameters

arg0 KeyValueMapper

KeyValueMapper

arg1 Named

Named

Returns

KStream

KStream

FlatMapValues(ValueMapper)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#flatMapValues(org.apache.kafka.streams.kstream.ValueMapper)

public KStream FlatMapValues(ValueMapper arg0)

Parameters

arg0 ValueMapper

ValueMapper

Returns

KStream

KStream

FlatMapValues(ValueMapper, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#flatMapValues(org.apache.kafka.streams.kstream.ValueMapper,org.apache.kafka.streams.kstream.Named)

public KStream FlatMapValues(ValueMapper arg0, Named arg1)

Parameters

arg0 ValueMapper

ValueMapper

arg1 Named

Named

Returns

KStream

KStream

FlatMapValues(ValueMapperWithKey)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#flatMapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey)

public KStream FlatMapValues(ValueMapperWithKey arg0)

Parameters

arg0 ValueMapperWithKey

ValueMapperWithKey

Returns

KStream

KStream

FlatMapValues(ValueMapperWithKey, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#flatMapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey,org.apache.kafka.streams.kstream.Named)

public KStream FlatMapValues(ValueMapperWithKey arg0, Named arg1)

Parameters

arg0 ValueMapperWithKey

ValueMapperWithKey

arg1 Named

Named

Returns

KStream

KStream

Foreach(ForeachAction)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#foreach(org.apache.kafka.streams.kstream.ForeachAction)

public void Foreach(ForeachAction arg0)

Parameters

arg0 ForeachAction

ForeachAction

Foreach(ForeachAction, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#foreach(org.apache.kafka.streams.kstream.ForeachAction,org.apache.kafka.streams.kstream.Named)

public void Foreach(ForeachAction arg0, Named arg1)

Parameters

arg0 ForeachAction

ForeachAction

arg1 Named

Named

GroupBy(KeyValueMapper)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#groupBy(org.apache.kafka.streams.kstream.KeyValueMapper)

public KGroupedStream GroupBy(KeyValueMapper arg0)

Parameters

arg0 KeyValueMapper

KeyValueMapper

Returns

KGroupedStream

KGroupedStream

GroupBy(KeyValueMapper, Grouped)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#groupBy(org.apache.kafka.streams.kstream.KeyValueMapper,org.apache.kafka.streams.kstream.Grouped)

public KGroupedStream GroupBy(KeyValueMapper arg0, Grouped arg1)

Parameters

arg0 KeyValueMapper

KeyValueMapper

arg1 Grouped

Grouped

Returns

KGroupedStream

KGroupedStream

GroupByKey()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#groupByKey()

public KGroupedStream GroupByKey()

Returns

KGroupedStream

KGroupedStream

GroupByKey(Grouped)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#groupByKey(org.apache.kafka.streams.kstream.Grouped)

public KGroupedStream GroupByKey(Grouped arg0)

Parameters

arg0 Grouped

Grouped

Returns

KGroupedStream

KGroupedStream

Join(GlobalKTable, KeyValueMapper, ValueJoiner)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.GlobalKTable,org.apache.kafka.streams.kstream.KeyValueMapper,org.apache.kafka.streams.kstream.ValueJoiner)

public KStream Join(GlobalKTable arg0, KeyValueMapper arg1, ValueJoiner arg2)

Parameters

arg0 GlobalKTable

GlobalKTable

arg1 KeyValueMapper

KeyValueMapper

arg2 ValueJoiner

ValueJoiner

Returns

KStream

KStream

Join(GlobalKTable, KeyValueMapper, ValueJoiner, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.GlobalKTable,org.apache.kafka.streams.kstream.KeyValueMapper,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.Named)

public KStream Join(GlobalKTable arg0, KeyValueMapper arg1, ValueJoiner arg2, Named arg3)

Parameters

arg0 GlobalKTable

GlobalKTable

arg1 KeyValueMapper

KeyValueMapper

arg2 ValueJoiner

ValueJoiner

arg3 Named

Named

Returns

KStream

KStream

Join(GlobalKTable, KeyValueMapper, ValueJoinerWithKey)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.GlobalKTable,org.apache.kafka.streams.kstream.KeyValueMapper,org.apache.kafka.streams.kstream.ValueJoinerWithKey)

public KStream Join(GlobalKTable arg0, KeyValueMapper arg1, ValueJoinerWithKey arg2)

Parameters

arg0 GlobalKTable

GlobalKTable

arg1 KeyValueMapper

KeyValueMapper

arg2 ValueJoinerWithKey

ValueJoinerWithKey

Returns

KStream

KStream

Join(GlobalKTable, KeyValueMapper, ValueJoinerWithKey, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.GlobalKTable,org.apache.kafka.streams.kstream.KeyValueMapper,org.apache.kafka.streams.kstream.ValueJoinerWithKey,org.apache.kafka.streams.kstream.Named)

public KStream Join(GlobalKTable arg0, KeyValueMapper arg1, ValueJoinerWithKey arg2, Named arg3)

Parameters

arg0 GlobalKTable

GlobalKTable

arg1 KeyValueMapper

KeyValueMapper

arg2 ValueJoinerWithKey

ValueJoinerWithKey

arg3 Named

Named

Returns

KStream

KStream

Join(KStream, ValueJoiner, JoinWindows)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.KStream,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.JoinWindows)

public KStream Join(KStream arg0, ValueJoiner arg1, JoinWindows arg2)

Parameters

arg0 KStream

KStream

arg1 ValueJoiner

ValueJoiner

arg2 JoinWindows

JoinWindows

Returns

KStream

KStream

Join(KStream, ValueJoiner, JoinWindows, StreamJoined)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.KStream,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.JoinWindows,org.apache.kafka.streams.kstream.StreamJoined)

public KStream Join(KStream arg0, ValueJoiner arg1, JoinWindows arg2, StreamJoined arg3)

Parameters

arg0 KStream

KStream

arg1 ValueJoiner

ValueJoiner

arg2 JoinWindows

JoinWindows

arg3 StreamJoined

StreamJoined

Returns

KStream

KStream

Join(KStream, ValueJoinerWithKey, JoinWindows)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.KStream,org.apache.kafka.streams.kstream.ValueJoinerWithKey,org.apache.kafka.streams.kstream.JoinWindows)

public KStream Join(KStream arg0, ValueJoinerWithKey arg1, JoinWindows arg2)

Parameters

arg0 KStream

KStream

arg1 ValueJoinerWithKey

ValueJoinerWithKey

arg2 JoinWindows

JoinWindows

Returns

KStream

KStream

Join(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.KStream,org.apache.kafka.streams.kstream.ValueJoinerWithKey,org.apache.kafka.streams.kstream.JoinWindows,org.apache.kafka.streams.kstream.StreamJoined)

public KStream Join(KStream arg0, ValueJoinerWithKey arg1, JoinWindows arg2, StreamJoined arg3)

Parameters

arg0 KStream

KStream

arg1 ValueJoinerWithKey

ValueJoinerWithKey

arg2 JoinWindows

JoinWindows

arg3 StreamJoined

StreamJoined

Returns

KStream

KStream

Join(KTable, ValueJoiner)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.KTable,org.apache.kafka.streams.kstream.ValueJoiner)

public KStream Join(KTable arg0, ValueJoiner arg1)

Parameters

arg0 KTable

KTable

arg1 ValueJoiner

ValueJoiner

Returns

KStream

KStream

Join(KTable, ValueJoiner, Joined)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.KTable,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.Joined)

public KStream Join(KTable arg0, ValueJoiner arg1, Joined arg2)

Parameters

arg0 KTable

KTable

arg1 ValueJoiner

ValueJoiner

arg2 Joined

Joined

Returns

KStream

KStream

Join(KTable, ValueJoinerWithKey)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.KTable,org.apache.kafka.streams.kstream.ValueJoinerWithKey)

public KStream Join(KTable arg0, ValueJoinerWithKey arg1)

Parameters

arg0 KTable

KTable

arg1 ValueJoinerWithKey

ValueJoinerWithKey

Returns

KStream

KStream

Join(KTable, ValueJoinerWithKey, Joined)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#join(org.apache.kafka.streams.kstream.KTable,org.apache.kafka.streams.kstream.ValueJoinerWithKey,org.apache.kafka.streams.kstream.Joined)

public KStream Join(KTable arg0, ValueJoinerWithKey arg1, Joined arg2)

Parameters

arg0 KTable

KTable

arg1 ValueJoinerWithKey

ValueJoinerWithKey

arg2 Joined

Joined

Returns

KStream

KStream

LeftJoin(GlobalKTable, KeyValueMapper, ValueJoiner)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#leftJoin(org.apache.kafka.streams.kstream.GlobalKTable,org.apache.kafka.streams.kstream.KeyValueMapper,org.apache.kafka.streams.kstream.ValueJoiner)

public KStream LeftJoin(GlobalKTable arg0, KeyValueMapper arg1, ValueJoiner arg2)

Parameters

arg0 GlobalKTable

GlobalKTable

arg1 KeyValueMapper

KeyValueMapper

arg2 ValueJoiner

ValueJoiner

Returns

KStream

KStream

LeftJoin(GlobalKTable, KeyValueMapper, ValueJoiner, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#leftJoin(org.apache.kafka.streams.kstream.GlobalKTable,org.apache.kafka.streams.kstream.KeyValueMapper,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.Named)

public KStream LeftJoin(GlobalKTable arg0, KeyValueMapper arg1, ValueJoiner arg2, Named arg3)

Parameters

arg0 GlobalKTable

GlobalKTable

arg1 KeyValueMapper

KeyValueMapper

arg2 ValueJoiner

ValueJoiner

arg3 Named

Named

Returns

KStream

KStream

LeftJoin(GlobalKTable, KeyValueMapper, ValueJoinerWithKey)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#leftJoin(org.apache.kafka.streams.kstream.GlobalKTable,org.apache.kafka.streams.kstream.KeyValueMapper,org.apache.kafka.streams.kstream.ValueJoinerWithKey)

public KStream LeftJoin(GlobalKTable arg0, KeyValueMapper arg1, ValueJoinerWithKey arg2)

Parameters

arg0 GlobalKTable

GlobalKTable

arg1 KeyValueMapper

KeyValueMapper

arg2 ValueJoinerWithKey

ValueJoinerWithKey

Returns

KStream

KStream

LeftJoin(GlobalKTable, KeyValueMapper, ValueJoinerWithKey, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#leftJoin(org.apache.kafka.streams.kstream.GlobalKTable,org.apache.kafka.streams.kstream.KeyValueMapper,org.apache.kafka.streams.kstream.ValueJoinerWithKey,org.apache.kafka.streams.kstream.Named)

public KStream LeftJoin(GlobalKTable arg0, KeyValueMapper arg1, ValueJoinerWithKey arg2, Named arg3)

Parameters

arg0 GlobalKTable

GlobalKTable

arg1 KeyValueMapper

KeyValueMapper

arg2 ValueJoinerWithKey

ValueJoinerWithKey

arg3 Named

Named

Returns

KStream

KStream

LeftJoin(KStream, ValueJoiner, JoinWindows)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#leftJoin(org.apache.kafka.streams.kstream.KStream,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.JoinWindows)

public KStream LeftJoin(KStream arg0, ValueJoiner arg1, JoinWindows arg2)

Parameters

arg0 KStream

KStream

arg1 ValueJoiner

ValueJoiner

arg2 JoinWindows

JoinWindows

Returns

KStream

KStream

LeftJoin(KStream, ValueJoiner, JoinWindows, StreamJoined)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#leftJoin(org.apache.kafka.streams.kstream.KStream,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.JoinWindows,org.apache.kafka.streams.kstream.StreamJoined)

public KStream LeftJoin(KStream arg0, ValueJoiner arg1, JoinWindows arg2, StreamJoined arg3)

Parameters

arg0 KStream

KStream

arg1 ValueJoiner

ValueJoiner

arg2 JoinWindows

JoinWindows

arg3 StreamJoined

StreamJoined

Returns

KStream

KStream

LeftJoin(KStream, ValueJoinerWithKey, JoinWindows)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#leftJoin(org.apache.kafka.streams.kstream.KStream,org.apache.kafka.streams.kstream.ValueJoinerWithKey,org.apache.kafka.streams.kstream.JoinWindows)

public KStream LeftJoin(KStream arg0, ValueJoinerWithKey arg1, JoinWindows arg2)

Parameters

arg0 KStream

KStream

arg1 ValueJoinerWithKey

ValueJoinerWithKey

arg2 JoinWindows

JoinWindows

Returns

KStream

KStream

LeftJoin(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#leftJoin(org.apache.kafka.streams.kstream.KStream,org.apache.kafka.streams.kstream.ValueJoinerWithKey,org.apache.kafka.streams.kstream.JoinWindows,org.apache.kafka.streams.kstream.StreamJoined)

public KStream LeftJoin(KStream arg0, ValueJoinerWithKey arg1, JoinWindows arg2, StreamJoined arg3)

Parameters

arg0 KStream

KStream

arg1 ValueJoinerWithKey

ValueJoinerWithKey

arg2 JoinWindows

JoinWindows

arg3 StreamJoined

StreamJoined

Returns

KStream

KStream

LeftJoin(KTable, ValueJoiner)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#leftJoin(org.apache.kafka.streams.kstream.KTable,org.apache.kafka.streams.kstream.ValueJoiner)

public KStream LeftJoin(KTable arg0, ValueJoiner arg1)

Parameters

arg0 KTable

KTable

arg1 ValueJoiner

ValueJoiner

Returns

KStream

KStream

LeftJoin(KTable, ValueJoiner, Joined)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#leftJoin(org.apache.kafka.streams.kstream.KTable,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.Joined)

public KStream LeftJoin(KTable arg0, ValueJoiner arg1, Joined arg2)

Parameters

arg0 KTable

KTable

arg1 ValueJoiner

ValueJoiner

arg2 Joined

Joined

Returns

KStream

KStream

LeftJoin(KTable, ValueJoinerWithKey)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#leftJoin(org.apache.kafka.streams.kstream.KTable,org.apache.kafka.streams.kstream.ValueJoinerWithKey)

public KStream LeftJoin(KTable arg0, ValueJoinerWithKey arg1)

Parameters

arg0 KTable

KTable

arg1 ValueJoinerWithKey

ValueJoinerWithKey

Returns

KStream

KStream

LeftJoin(KTable, ValueJoinerWithKey, Joined)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#leftJoin(org.apache.kafka.streams.kstream.KTable,org.apache.kafka.streams.kstream.ValueJoinerWithKey,org.apache.kafka.streams.kstream.Joined)

public KStream LeftJoin(KTable arg0, ValueJoinerWithKey arg1, Joined arg2)

Parameters

arg0 KTable

KTable

arg1 ValueJoinerWithKey

ValueJoinerWithKey

arg2 Joined

Joined

Returns

KStream

KStream

Map(KeyValueMapper)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#map(org.apache.kafka.streams.kstream.KeyValueMapper)

public KStream Map(KeyValueMapper arg0)

Parameters

arg0 KeyValueMapper

KeyValueMapper

Returns

KStream

KStream

Map(KeyValueMapper, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#map(org.apache.kafka.streams.kstream.KeyValueMapper,org.apache.kafka.streams.kstream.Named)

public KStream Map(KeyValueMapper arg0, Named arg1)

Parameters

arg0 KeyValueMapper

KeyValueMapper

arg1 Named

Named

Returns

KStream

KStream

MapValues(ValueMapper)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#mapValues(org.apache.kafka.streams.kstream.ValueMapper)

public KStream MapValues(ValueMapper arg0)

Parameters

arg0 ValueMapper

ValueMapper

Returns

KStream

KStream

MapValues(ValueMapper, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#mapValues(org.apache.kafka.streams.kstream.ValueMapper,org.apache.kafka.streams.kstream.Named)

public KStream MapValues(ValueMapper arg0, Named arg1)

Parameters

arg0 ValueMapper

ValueMapper

arg1 Named

Named

Returns

KStream

KStream

MapValues(ValueMapperWithKey)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey)

public KStream MapValues(ValueMapperWithKey arg0)

Parameters

arg0 ValueMapperWithKey

ValueMapperWithKey

Returns

KStream

KStream

MapValues(ValueMapperWithKey, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey,org.apache.kafka.streams.kstream.Named)

public KStream MapValues(ValueMapperWithKey arg0, Named arg1)

Parameters

arg0 ValueMapperWithKey

ValueMapperWithKey

arg1 Named

Named

Returns

KStream

KStream

Merge(KStream)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#merge(org.apache.kafka.streams.kstream.KStream)

public KStream Merge(KStream arg0)

Parameters

arg0 KStream

KStream

Returns

KStream

KStream

Merge(KStream, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#merge(org.apache.kafka.streams.kstream.KStream,org.apache.kafka.streams.kstream.Named)

public KStream Merge(KStream arg0, Named arg1)

Parameters

arg0 KStream

KStream

arg1 Named

Named

Returns

KStream

KStream

OuterJoin(KStream, ValueJoiner, JoinWindows)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#outerJoin(org.apache.kafka.streams.kstream.KStream,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.JoinWindows)

public KStream OuterJoin(KStream arg0, ValueJoiner arg1, JoinWindows arg2)

Parameters

arg0 KStream

KStream

arg1 ValueJoiner

ValueJoiner

arg2 JoinWindows

JoinWindows

Returns

KStream

KStream

OuterJoin(KStream, ValueJoiner, JoinWindows, StreamJoined)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#outerJoin(org.apache.kafka.streams.kstream.KStream,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.JoinWindows,org.apache.kafka.streams.kstream.StreamJoined)

public KStream OuterJoin(KStream arg0, ValueJoiner arg1, JoinWindows arg2, StreamJoined arg3)

Parameters

arg0 KStream

KStream

arg1 ValueJoiner

ValueJoiner

arg2 JoinWindows

JoinWindows

arg3 StreamJoined

StreamJoined

Returns

KStream

KStream

OuterJoin(KStream, ValueJoinerWithKey, JoinWindows)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#outerJoin(org.apache.kafka.streams.kstream.KStream,org.apache.kafka.streams.kstream.ValueJoinerWithKey,org.apache.kafka.streams.kstream.JoinWindows)

public KStream OuterJoin(KStream arg0, ValueJoinerWithKey arg1, JoinWindows arg2)

Parameters

arg0 KStream

KStream

arg1 ValueJoinerWithKey

ValueJoinerWithKey

arg2 JoinWindows

JoinWindows

Returns

KStream

KStream

OuterJoin(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#outerJoin(org.apache.kafka.streams.kstream.KStream,org.apache.kafka.streams.kstream.ValueJoinerWithKey,org.apache.kafka.streams.kstream.JoinWindows,org.apache.kafka.streams.kstream.StreamJoined)

public KStream OuterJoin(KStream arg0, ValueJoinerWithKey arg1, JoinWindows arg2, StreamJoined arg3)

Parameters

arg0 KStream

KStream

arg1 ValueJoinerWithKey

ValueJoinerWithKey

arg2 JoinWindows

JoinWindows

arg3 StreamJoined

StreamJoined

Returns

KStream

KStream

Peek(ForeachAction)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#peek(org.apache.kafka.streams.kstream.ForeachAction)

public KStream Peek(ForeachAction arg0)

Parameters

arg0 ForeachAction

ForeachAction

Returns

KStream

KStream

Peek(ForeachAction, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#peek(org.apache.kafka.streams.kstream.ForeachAction,org.apache.kafka.streams.kstream.Named)

public KStream Peek(ForeachAction arg0, Named arg1)

Parameters

arg0 ForeachAction

ForeachAction

arg1 Named

Named

Returns

KStream

KStream

Print(Printed)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#print(org.apache.kafka.streams.kstream.Printed)

public void Print(Printed arg0)

Parameters

arg0 Printed

Printed

Process(ProcessorSupplier, params String[])

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#process(org.apache.kafka.streams.processor.api.ProcessorSupplier,java.lang.String...)

public KStream Process(ProcessorSupplier arg0, params String[] arg1)

Parameters

arg0 ProcessorSupplier

ProcessorSupplier

arg1 String[]

String

Returns

KStream

KStream

Process(ProcessorSupplier, Named, params String[])

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#process(org.apache.kafka.streams.processor.api.ProcessorSupplier,org.apache.kafka.streams.kstream.Named,java.lang.String...)

public KStream Process(ProcessorSupplier arg0, Named arg1, params String[] arg2)

Parameters

arg0 ProcessorSupplier

ProcessorSupplier

arg1 Named

Named

arg2 String[]

String

Returns

KStream

KStream

ProcessValues(FixedKeyProcessorSupplier, params String[])

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#processValues(org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier,java.lang.String...)

public KStream ProcessValues(FixedKeyProcessorSupplier arg0, params String[] arg1)

Parameters

arg0 FixedKeyProcessorSupplier

FixedKeyProcessorSupplier

arg1 String[]

String

Returns

KStream

KStream

ProcessValues(FixedKeyProcessorSupplier, Named, params String[])

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#processValues(org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier,org.apache.kafka.streams.kstream.Named,java.lang.String...)

public KStream ProcessValues(FixedKeyProcessorSupplier arg0, Named arg1, params String[] arg2)

Parameters

arg0 FixedKeyProcessorSupplier

FixedKeyProcessorSupplier

arg1 Named

Named

arg2 String[]

String

Returns

KStream

KStream

Repartition()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#repartition()

public KStream Repartition()

Returns

KStream

KStream

Repartition(Repartitioned)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#repartition(org.apache.kafka.streams.kstream.Repartitioned)

public KStream Repartition(Repartitioned arg0)

Parameters

arg0 Repartitioned

Repartitioned

Returns

KStream

KStream

SelectKey(KeyValueMapper)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#selectKey(org.apache.kafka.streams.kstream.KeyValueMapper)

public KStream SelectKey(KeyValueMapper arg0)

Parameters

arg0 KeyValueMapper

KeyValueMapper

Returns

KStream

KStream

SelectKey(KeyValueMapper, Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#selectKey(org.apache.kafka.streams.kstream.KeyValueMapper,org.apache.kafka.streams.kstream.Named)

public KStream SelectKey(KeyValueMapper arg0, Named arg1)

Parameters

arg0 KeyValueMapper

KeyValueMapper

arg1 Named

Named

Returns

KStream

KStream

Split()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#split()

public BranchedKStream Split()

Returns

BranchedKStream

BranchedKStream

Split(Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#split(org.apache.kafka.streams.kstream.Named)

public BranchedKStream Split(Named arg0)

Parameters

arg0 Named

Named

Returns

BranchedKStream

BranchedKStream

To(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#to(java.lang.String)

public void To(String arg0)

Parameters

arg0 String

String

To(String, Produced)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#to(java.lang.String,org.apache.kafka.streams.kstream.Produced)

public void To(String arg0, Produced arg1)

Parameters

arg0 String

String

arg1 Produced

Produced

To(TopicNameExtractor)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#to(org.apache.kafka.streams.processor.TopicNameExtractor)

public void To(TopicNameExtractor arg0)

Parameters

arg0 TopicNameExtractor

TopicNameExtractor

To(TopicNameExtractor, Produced)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#to(org.apache.kafka.streams.processor.TopicNameExtractor,org.apache.kafka.streams.kstream.Produced)

public void To(TopicNameExtractor arg0, Produced arg1)

Parameters

arg0 TopicNameExtractor

TopicNameExtractor

arg1 Produced

Produced

ToTable()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#toTable()

public KTable ToTable()

Returns

KTable

KTable

ToTable(Materialized)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#toTable(org.apache.kafka.streams.kstream.Materialized)

public KTable ToTable(Materialized arg0)

Parameters

arg0 Materialized

Materialized

Returns

KTable

KTable

ToTable(Named)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#toTable(org.apache.kafka.streams.kstream.Named)

public KTable ToTable(Named arg0)

Parameters

arg0 Named

Named

Returns

KTable

KTable

ToTable(Named, Materialized)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KStream.html#toTable(org.apache.kafka.streams.kstream.Named,org.apache.kafka.streams.kstream.Materialized)

public KTable ToTable(Named arg0, Materialized arg1)

Parameters

arg0 Named

Named

arg1 Materialized

Materialized

Returns

KTable

KTable