Class StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>
KNet extension of StreamJoined<K, V1, V2>
public class StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> : IKNetInnerReference<StreamJoined<TJVMK, TJVMV1, TJVMV2>>, IGenericSerDesFactoryApplier, IDisposableType Parameters
KV1V2TJVMKThe JVM type of
KTJVMV1The JVM type of
V1TJVMV2The JVM type of
V2
- Inheritance
-
StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>
- Implements
-
IKNetInnerReference<StreamJoined<TJVMK, TJVMV1, TJVMV2>>
Properties
InnerReference
The underlying inner reference used from KNet object instance
public StreamJoined<TJVMK, TJVMV1, TJVMV2> InnerReference { get; }Property Value
- StreamJoined<TJVMK, TJVMV1, TJVMV2>
Methods
As(string)
public static StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> As(string arg0)Parameters
Returns
- StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>
CheckDisposed()
Test if this instance was disposed
protected void CheckDisposed()Exceptions
- ObjectDisposedException
When this instance was disposed
Dispose()
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
public void Dispose()Dispose(bool)
Implements the pattern described in https://learn.microsoft.com/en-en/dotnet/standard/garbage-collection/implementing-dispose
protected virtual void Dispose(bool disposing)Parameters
disposingboolThe disposing parameter is a bool that indicates whether the method call comes from a Dispose() method (its value is true) or from a finalizer (its value is false)
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
Returns
- StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>
With(DslStoreSuppliers)
public static StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> With(DslStoreSuppliers arg0)Parameters
Returns
- 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
Returns
- StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>
WithDslStoreSuppliers(DslStoreSuppliers)
public StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> WithDslStoreSuppliers(DslStoreSuppliers arg0)Parameters
Returns
- 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
arg0ISerDes<K, TJVMK>
Returns
- 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>
WithLoggingEnabled(Map<String, String>)
public StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> WithLoggingEnabled(Map<String, String> arg0)Parameters
Returns
- StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>
WithOtherStoreSupplier(WindowBytesStoreSupplier)
public StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> WithOtherStoreSupplier(WindowBytesStoreSupplier arg0)Parameters
Returns
- 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
arg0ISerDes<V2, TJVMV2>
Returns
- StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>
WithStoreName(string)
public StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> WithStoreName(string arg0)Parameters
Returns
- StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>
WithThisStoreSupplier(WindowBytesStoreSupplier)
public StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> WithThisStoreSupplier(WindowBytesStoreSupplier arg0)Parameters
Returns
- 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
arg0ISerDes<V1, TJVMV1>
Returns
- StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>
Operators
implicit operator StreamJoined<TJVMK, TJVMV1, TJVMV2>(StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>)
Converter from StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> to StreamJoined<K, V1, V2>
public static implicit operator StreamJoined<TJVMK, TJVMV1, TJVMV2>(StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2> t)Parameters
tStreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>
Returns
- StreamJoined<TJVMK, TJVMV1, TJVMV2>