Class KTable

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/KTable.html

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

Inheritance: object

DynamicObject

JVMBridgeBase

JVMBridgeBase<KTable>

KTable

Implements: IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBase>

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeDefinition

Inherited Members: JVMBridgeBase<KTable>.SExecute(IJavaType, string, params object[])

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

JVMBridgeBase<KTable>.SGetField(IJavaType, string)

JVMBridgeBase<KTable>.SGetField(string)

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

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

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

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

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

JVMBridgeBase<KTable>.SSetField(string, object)

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

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

JVMBridgeBase<KTable>.IsAssignableFrom(string)

JVMBridgeBase<KTable>.IsAssignableFrom(IJavaType)

JVMBridgeBase<KTable>.IsAssignableFrom<T>()

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

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

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

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

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

JVMBridgeBase<KTable>.DynBridgeClazz

JVMBridgeBase<KTable>.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

KTable()

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

[Obsolete("KTable 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 KTable()

KTable(IJVMBridgeBaseInitializer)

Internal constructor: used internally from JCOBridge

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

Parameters

initializer IJVMBridgeBaseInitializer

KTable(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("KTable 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 KTable(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/KTable.html#filter(org.apache.kafka.streams.kstream.Predicate)

public KTable Filter(Predicate arg0)

public KTable Filter(Predicate arg0, Materialized arg1)

Parameters

arg0 Predicate: Predicate
arg1 Materialized: Materialized

Returns

KTable: KTable

Filter(Predicate, Named)

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

public KTable Filter(Predicate arg0, Named arg1)

Parameters

arg0 Predicate: Predicate
arg1 Named: Named

Returns

KTable: KTable

Filter(Predicate, Named, Materialized)

public KTable Filter(Predicate arg0, Named arg1, Materialized arg2)

Parameters

arg0 Predicate: Predicate
arg1 Named: Named
arg2 Materialized: Materialized

Returns

KTable: KTable

FilterNot(Predicate)

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

public KTable FilterNot(Predicate arg0)

Parameters

arg0 Predicate: Predicate

Returns

KTable: KTable

FilterNot(Predicate, Materialized)

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

public KTable FilterNot(Predicate arg0, Materialized arg1)

Parameters

arg0 Predicate: Predicate
arg1 Materialized: Materialized

Returns

KTable: KTable

FilterNot(Predicate, Named)

public KTable FilterNot(Predicate arg0, Named arg1)

Parameters

arg0 Predicate: Predicate
arg1 Named: Named

Returns

KTable: KTable

FilterNot(Predicate, Named, Materialized)

public KTable FilterNot(Predicate arg0, Named arg1, Materialized arg2)

Parameters

arg0 Predicate: Predicate
arg1 Named: Named
arg2 Materialized: Materialized

Returns

KTable: KTable

GroupBy(KeyValueMapper)

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

public KGroupedTable GroupBy(KeyValueMapper arg0)

Parameters

arg0 KeyValueMapper: KeyValueMapper

Returns

KGroupedTable: KGroupedTable

GroupBy(KeyValueMapper, Grouped)

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

public KGroupedTable GroupBy(KeyValueMapper arg0, Grouped arg1)

Parameters

arg0 KeyValueMapper: KeyValueMapper
arg1 Grouped: Grouped

Returns

KGroupedTable: KGroupedTable

Join(KTable, BiFunction, ValueJoiner)

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

public KTable Join(KTable arg0, BiFunction arg1, ValueJoiner arg2)

Parameters

arg0 KTable: KTable
arg1 BiFunction: BiFunction
arg2 ValueJoiner: ValueJoiner

Returns

KTable: KTable

Join(KTable, BiFunction, ValueJoiner, Materialized)

public KTable Join(KTable arg0, BiFunction arg1, ValueJoiner arg2, Materialized arg3)

Parameters

arg0 KTable: KTable
arg1 BiFunction: BiFunction
arg2 ValueJoiner: ValueJoiner
arg3 Materialized: Materialized

Returns

KTable: KTable

Join(KTable, BiFunction, ValueJoiner, TableJoined)

public KTable Join(KTable arg0, BiFunction arg1, ValueJoiner arg2, TableJoined arg3)

Parameters

arg0 KTable: KTable
arg1 BiFunction: BiFunction
arg2 ValueJoiner: ValueJoiner
arg3 TableJoined: TableJoined

Returns

KTable: KTable

Join(KTable, BiFunction, ValueJoiner, TableJoined, Materialized)

public KTable Join(KTable arg0, BiFunction arg1, ValueJoiner arg2, TableJoined arg3, Materialized arg4)

Parameters

arg0 KTable: KTable
arg1 BiFunction: BiFunction
arg2 ValueJoiner: ValueJoiner
arg3 TableJoined: TableJoined
arg4 Materialized: Materialized

Returns

KTable: KTable

Join(KTable, Function, ValueJoiner)

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

public KTable Join(KTable arg0, Function arg1, ValueJoiner arg2)

Parameters

arg0 KTable: KTable
arg1 Function: Function
arg2 ValueJoiner: ValueJoiner

Returns

KTable: KTable

Join(KTable, Function, ValueJoiner, Materialized)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KTable.html#join(org.apache.kafka.streams.kstream.KTable,java.util.function.Function,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.Materialized)

public KTable Join(KTable arg0, Function arg1, ValueJoiner arg2, Materialized arg3)

Parameters

arg0 KTable: KTable
arg1 Function: Function
arg2 ValueJoiner: ValueJoiner
arg3 Materialized: Materialized

Returns

KTable: KTable

Join(KTable, Function, ValueJoiner, TableJoined)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KTable.html#join(org.apache.kafka.streams.kstream.KTable,java.util.function.Function,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.TableJoined)

public KTable Join(KTable arg0, Function arg1, ValueJoiner arg2, TableJoined arg3)

Parameters

arg0 KTable: KTable
arg1 Function: Function
arg2 ValueJoiner: ValueJoiner
arg3 TableJoined: TableJoined

Returns

KTable: KTable

Join(KTable, Function, ValueJoiner, TableJoined, Materialized)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KTable.html#join(org.apache.kafka.streams.kstream.KTable,java.util.function.Function,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.TableJoined,org.apache.kafka.streams.kstream.Materialized)

public KTable Join(KTable arg0, Function arg1, ValueJoiner arg2, TableJoined arg3, Materialized arg4)

Parameters

arg0 KTable: KTable
arg1 Function: Function
arg2 ValueJoiner: ValueJoiner
arg3 TableJoined: TableJoined
arg4 Materialized: Materialized

Returns

KTable: KTable

Join(KTable, ValueJoiner)

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

public KTable Join(KTable arg0, ValueJoiner arg1)

Parameters

arg0 KTable: KTable
arg1 ValueJoiner: ValueJoiner

Returns

KTable: KTable

Join(KTable, ValueJoiner, Materialized)

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

public KTable Join(KTable arg0, ValueJoiner arg1, Materialized arg2)

Parameters

arg0 KTable: KTable
arg1 ValueJoiner: ValueJoiner
arg2 Materialized: Materialized

Returns

KTable: KTable

Join(KTable, ValueJoiner, Named)

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

public KTable Join(KTable arg0, ValueJoiner arg1, Named arg2)

Parameters

arg0 KTable: KTable
arg1 ValueJoiner: ValueJoiner
arg2 Named: Named

Returns

KTable: KTable

Join(KTable, ValueJoiner, Named, Materialized)

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

public KTable Join(KTable arg0, ValueJoiner arg1, Named arg2, Materialized arg3)

Parameters

arg0 KTable: KTable
arg1 ValueJoiner: ValueJoiner
arg2 Named: Named
arg3 Materialized: Materialized

Returns

KTable: KTable

LeftJoin(KTable, BiFunction, ValueJoiner)

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

public KTable LeftJoin(KTable arg0, BiFunction arg1, ValueJoiner arg2)

Parameters

arg0 KTable: KTable
arg1 BiFunction: BiFunction
arg2 ValueJoiner: ValueJoiner

Returns

KTable: KTable

LeftJoin(KTable, BiFunction, ValueJoiner, Materialized)

public KTable LeftJoin(KTable arg0, BiFunction arg1, ValueJoiner arg2, Materialized arg3)

Parameters

arg0 KTable: KTable
arg1 BiFunction: BiFunction
arg2 ValueJoiner: ValueJoiner
arg3 Materialized: Materialized

Returns

KTable: KTable

LeftJoin(KTable, BiFunction, ValueJoiner, TableJoined)

public KTable LeftJoin(KTable arg0, BiFunction arg1, ValueJoiner arg2, TableJoined arg3)

Parameters

arg0 KTable: KTable
arg1 BiFunction: BiFunction
arg2 ValueJoiner: ValueJoiner
arg3 TableJoined: TableJoined

Returns

KTable: KTable

LeftJoin(KTable, BiFunction, ValueJoiner, TableJoined, Materialized)

public KTable LeftJoin(KTable arg0, BiFunction arg1, ValueJoiner arg2, TableJoined arg3, Materialized arg4)

Parameters

arg0 KTable: KTable
arg1 BiFunction: BiFunction
arg2 ValueJoiner: ValueJoiner
arg3 TableJoined: TableJoined
arg4 Materialized: Materialized

Returns

KTable: KTable

LeftJoin(KTable, Function, ValueJoiner)

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

public KTable LeftJoin(KTable arg0, Function arg1, ValueJoiner arg2)

Parameters

arg0 KTable: KTable
arg1 Function: Function
arg2 ValueJoiner: ValueJoiner

Returns

KTable: KTable

LeftJoin(KTable, Function, ValueJoiner, Materialized)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KTable.html#leftJoin(org.apache.kafka.streams.kstream.KTable,java.util.function.Function,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.Materialized)

public KTable LeftJoin(KTable arg0, Function arg1, ValueJoiner arg2, Materialized arg3)

Parameters

arg0 KTable: KTable
arg1 Function: Function
arg2 ValueJoiner: ValueJoiner
arg3 Materialized: Materialized

Returns

KTable: KTable

LeftJoin(KTable, Function, ValueJoiner, TableJoined)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KTable.html#leftJoin(org.apache.kafka.streams.kstream.KTable,java.util.function.Function,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.TableJoined)

public KTable LeftJoin(KTable arg0, Function arg1, ValueJoiner arg2, TableJoined arg3)

Parameters

arg0 KTable: KTable
arg1 Function: Function
arg2 ValueJoiner: ValueJoiner
arg3 TableJoined: TableJoined

Returns

KTable: KTable

LeftJoin(KTable, Function, ValueJoiner, TableJoined, Materialized)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KTable.html#leftJoin(org.apache.kafka.streams.kstream.KTable,java.util.function.Function,org.apache.kafka.streams.kstream.ValueJoiner,org.apache.kafka.streams.kstream.TableJoined,org.apache.kafka.streams.kstream.Materialized)

public KTable LeftJoin(KTable arg0, Function arg1, ValueJoiner arg2, TableJoined arg3, Materialized arg4)

Parameters

arg0 KTable: KTable
arg1 Function: Function
arg2 ValueJoiner: ValueJoiner
arg3 TableJoined: TableJoined
arg4 Materialized: Materialized

Returns

KTable: KTable

LeftJoin(KTable, ValueJoiner)

public KTable LeftJoin(KTable arg0, ValueJoiner arg1)

Parameters

arg0 KTable: KTable
arg1 ValueJoiner: ValueJoiner

Returns

KTable: KTable

LeftJoin(KTable, ValueJoiner, Materialized)

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

public KTable LeftJoin(KTable arg0, ValueJoiner arg1, Materialized arg2)

Parameters

arg0 KTable: KTable
arg1 ValueJoiner: ValueJoiner
arg2 Materialized: Materialized

Returns

KTable: KTable

LeftJoin(KTable, ValueJoiner, Named)

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

public KTable LeftJoin(KTable arg0, ValueJoiner arg1, Named arg2)

Parameters

arg0 KTable: KTable
arg1 ValueJoiner: ValueJoiner
arg2 Named: Named

Returns

KTable: KTable

LeftJoin(KTable, ValueJoiner, Named, Materialized)

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

public KTable LeftJoin(KTable arg0, ValueJoiner arg1, Named arg2, Materialized arg3)

Parameters

arg0 KTable: KTable
arg1 ValueJoiner: ValueJoiner
arg2 Named: Named
arg3 Materialized: Materialized

Returns

KTable: KTable

MapValues(ValueMapper)

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

public KTable MapValues(ValueMapper arg0)

Parameters

arg0 ValueMapper: ValueMapper

Returns

KTable: KTable

MapValues(ValueMapper, Materialized)

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

public KTable MapValues(ValueMapper arg0, Materialized arg1)

Parameters

arg0 ValueMapper: ValueMapper
arg1 Materialized: Materialized

Returns

KTable: KTable

MapValues(ValueMapper, Named)

public KTable MapValues(ValueMapper arg0, Named arg1)

Parameters

arg0 ValueMapper: ValueMapper
arg1 Named: Named

Returns

KTable: KTable

MapValues(ValueMapper, Named, Materialized)

public KTable MapValues(ValueMapper arg0, Named arg1, Materialized arg2)

Parameters

arg0 ValueMapper: ValueMapper
arg1 Named: Named
arg2 Materialized: Materialized

Returns

KTable: KTable

MapValues(ValueMapperWithKey)

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

public KTable MapValues(ValueMapperWithKey arg0)

Parameters

arg0 ValueMapperWithKey: ValueMapperWithKey

Returns

KTable: KTable

MapValues(ValueMapperWithKey, Materialized)

public KTable MapValues(ValueMapperWithKey arg0, Materialized arg1)

Parameters

arg0 ValueMapperWithKey: ValueMapperWithKey
arg1 Materialized: Materialized

Returns

KTable: KTable

MapValues(ValueMapperWithKey, Named)

public KTable MapValues(ValueMapperWithKey arg0, Named arg1)

Parameters

arg0 ValueMapperWithKey: ValueMapperWithKey
arg1 Named: Named

Returns

KTable: KTable

MapValues(ValueMapperWithKey, Named, Materialized)

public KTable MapValues(ValueMapperWithKey arg0, Named arg1, Materialized arg2)

Parameters

arg0 ValueMapperWithKey: ValueMapperWithKey
arg1 Named: Named
arg2 Materialized: Materialized

Returns

KTable: KTable

OuterJoin(KTable, ValueJoiner)

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

public KTable OuterJoin(KTable arg0, ValueJoiner arg1)

Parameters

arg0 KTable: KTable
arg1 ValueJoiner: ValueJoiner

Returns

KTable: KTable

OuterJoin(KTable, ValueJoiner, Materialized)

public KTable OuterJoin(KTable arg0, ValueJoiner arg1, Materialized arg2)

Parameters

arg0 KTable: KTable
arg1 ValueJoiner: ValueJoiner
arg2 Materialized: Materialized

Returns

KTable: KTable

OuterJoin(KTable, ValueJoiner, Named)

public KTable OuterJoin(KTable arg0, ValueJoiner arg1, Named arg2)

Parameters

arg0 KTable: KTable
arg1 ValueJoiner: ValueJoiner
arg2 Named: Named

Returns

KTable: KTable

OuterJoin(KTable, ValueJoiner, Named, Materialized)

public KTable OuterJoin(KTable arg0, ValueJoiner arg1, Named arg2, Materialized arg3)

Parameters

arg0 KTable: KTable
arg1 ValueJoiner: ValueJoiner
arg2 Named: Named
arg3 Materialized: Materialized

Returns

KTable: KTable

QueryableStoreName()

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

public String QueryableStoreName()

Returns

String: String

Suppress(Suppressed)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.1.0/org/apache/kafka/streams/kstream/KTable.html#suppress(org.apache.kafka.streams.kstream.Suppressed)

public KTable Suppress(Suppressed arg0)

Parameters

arg0 Suppressed: Suppressed

Returns

KTable: KTable

ToStream()

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

public KStream ToStream()

Returns

KStream: KStream

ToStream(KeyValueMapper)

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

public KStream ToStream(KeyValueMapper arg0)

Parameters

arg0 KeyValueMapper: KeyValueMapper

Returns

KStream: KStream

ToStream(KeyValueMapper, Named)

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

public KStream ToStream(KeyValueMapper arg0, Named arg1)

Parameters

arg0 KeyValueMapper: KeyValueMapper
arg1 Named: Named

Returns

KStream: KStream

ToStream(Named)

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

public KStream ToStream(Named arg0)

Parameters

arg0 Named: Named

Returns

KStream: KStream

Table of Contents

Class KTable

Constructors

KTable()

KTable(IJVMBridgeBaseInitializer)

Parameters

KTable(params object[])

Parameters

Properties

BridgeClassName

Property Value

IsBridgeAbstract

Property Value

IsBridgeCloseable

Property Value

IsBridgeInterface

Property Value

IsBridgeStatic

Property Value

Methods

Filter(Predicate)

Parameters

Returns

Filter(Predicate, Materialized)

Parameters

Returns

Filter(Predicate, Named)

Parameters

Returns

Filter(Predicate, Named, Materialized)

Parameters

Returns

FilterNot(Predicate)

Parameters

Returns

FilterNot(Predicate, Materialized)

Parameters

Returns

FilterNot(Predicate, Named)

Parameters

Returns

FilterNot(Predicate, Named, Materialized)

Parameters

Returns

GroupBy(KeyValueMapper)

Parameters

Returns

GroupBy(KeyValueMapper, Grouped)

Parameters

Returns

Join(KTable, BiFunction, ValueJoiner)

Parameters

Returns

Join(KTable, BiFunction, ValueJoiner, Materialized)

Parameters

Returns

Join(KTable, BiFunction, ValueJoiner, TableJoined)

Parameters

Returns

Join(KTable, BiFunction, ValueJoiner, TableJoined, Materialized)

Parameters

Returns

Join(KTable, Function, ValueJoiner)

Parameters

Returns

Join(KTable, Function, ValueJoiner, Materialized)

Parameters

Returns

Join(KTable, Function, ValueJoiner, TableJoined)

Parameters

Returns

Join(KTable, Function, ValueJoiner, TableJoined, Materialized)

Parameters

Returns

Join(KTable, ValueJoiner)

Parameters

Returns

Join(KTable, ValueJoiner, Materialized)

Parameters

Returns