Table of Contents

Class StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

Namespace
MASES.KNet.Streams.Kstream
Assembly
MASES.KNet.dll

KNet extension of StreamJoined<K, V1, V2>

public class StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> : IGenericSerDesFactoryApplier

Type Parameters

K
V1
V2
TJVMK

The JVM type of K

TJVMV1

The JVM type of V1

TJVMV2

The JVM type of V2

Inheritance
StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>
Implements
Inherited Members

Methods

As(string)

public static StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> As(string arg0)

Parameters

arg0 string

string

Returns

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

With(ISerDes<K, TJVMK>, ISerDes<V1, TJVMV1>, ISerDes<V2, TJVMV2>)

public static StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> With(ISerDes<K, TJVMK> arg0, ISerDes<V1, TJVMV1> arg1, ISerDes<V2, TJVMV2> arg2)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

arg1 ISerDes<V1, TJVMV1>

ISerDes<T, TJVMT>

arg2 ISerDes<V2, TJVMV2>

ISerDes<T, TJVMT>

Returns

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

With(DslStoreSuppliers)

public static StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> With(DslStoreSuppliers arg0)

Parameters

arg0 DslStoreSuppliers

DslStoreSuppliers

Returns

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

With(WindowBytesStoreSupplier, WindowBytesStoreSupplier)

public static StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> With(WindowBytesStoreSupplier arg0, WindowBytesStoreSupplier arg1)

Parameters

arg0 WindowBytesStoreSupplier

WindowBytesStoreSupplier

arg1 WindowBytesStoreSupplier

WindowBytesStoreSupplier

Returns

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

WithDslStoreSuppliers(DslStoreSuppliers)

public StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> WithDslStoreSuppliers(DslStoreSuppliers arg0)

Parameters

arg0 DslStoreSuppliers

DslStoreSuppliers

Returns

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

WithKeySerde(ISerDes<K, TJVMK>)

public StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> WithKeySerde(ISerDes<K, TJVMK> arg0)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

Returns

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

WithLoggingDisabled()

public StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> WithLoggingDisabled()

Returns

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

WithLoggingEnabled(Map<String, String>)

public StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> WithLoggingEnabled(Map<String, String> arg0)

Parameters

arg0 Map<String, String>

Map

Returns

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

WithOtherStoreSupplier(WindowBytesStoreSupplier)

public StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> WithOtherStoreSupplier(WindowBytesStoreSupplier arg0)

Parameters

arg0 WindowBytesStoreSupplier

WindowBytesStoreSupplier

Returns

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

WithOtherValueSerde(ISerDes<V2, TJVMV2>)

public StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> WithOtherValueSerde(ISerDes<V2, TJVMV2> arg0)

Parameters

arg0 ISerDes<V2, TJVMV2>

ISerDes<T, TJVMT>

Returns

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

WithStoreName(string)

public StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> WithStoreName(string arg0)

Parameters

arg0 string

string

Returns

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

WithThisStoreSupplier(WindowBytesStoreSupplier)

public StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> WithThisStoreSupplier(WindowBytesStoreSupplier arg0)

Parameters

arg0 WindowBytesStoreSupplier

WindowBytesStoreSupplier

Returns

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

WithValueSerde(ISerDes<V1, TJVMV1>)

public StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> WithValueSerde(ISerDes<V1, TJVMV1> arg0)

Parameters

arg0 ISerDes<V1, TJVMV1>

ISerDes<T, TJVMT>

Returns

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

Operators

implicit operator StreamJoined<TJVMK, TJVMV1, TJVMV2>(StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>)

public static implicit operator StreamJoined<TJVMK, TJVMV1, TJVMV2>(StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> t)

Parameters

t StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>

Returns

StreamJoined<TJVMK, TJVMV1, TJVMV2>