Table of Contents

Class Repartitioned<K, V, TJVMK, TJVMV>

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

KNet extension of Produced<K, V>

public class Repartitioned<K, V, TJVMK, TJVMV> : IGenericSerDesFactoryApplier

Type Parameters

K
V
TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance
Repartitioned<K, V, TJVMK, TJVMV>
Implements
Inherited Members

Methods

As(string)

public static Repartitioned<K, V, TJVMK, TJVMV> As(string arg0)

Parameters

arg0 string

string

Returns

Repartitioned<K, V, TJVMK, TJVMV>

Repartitioned<K, V, TJVMK, TJVMV>

NumberOfPartitions(int)

public static Repartitioned<K, V, TJVMK, TJVMV> NumberOfPartitions(int arg0)

Parameters

arg0 int

int

Returns

Repartitioned<K, V, TJVMK, TJVMV>

Repartitioned<K, V, TJVMK, TJVMV>

StreamPartitioner(StreamPartitioner<K, V, TJVMK, TJVMV>)

public static Repartitioned<K, V, TJVMK, TJVMV> StreamPartitioner(StreamPartitioner<K, V, TJVMK, TJVMV> arg0)

Parameters

arg0 StreamPartitioner<K, V, TJVMK, TJVMV>

StreamPartitioner<K, V, TJVMK, TJVMV>

Returns

Repartitioned<K, V, TJVMK, TJVMV>

Repartitioned<K, V, TJVMK, TJVMV>

With(ISerDes<K, TJVMK>, ISerDes<V, TJVMV>)

public static Repartitioned<K, V, TJVMK, TJVMV> With(ISerDes<K, TJVMK> arg0, ISerDes<V, TJVMV> arg1)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

arg1 ISerDes<V, TJVMV>

ISerDes<T, TJVMT>

Returns

Repartitioned<K, V, TJVMK, TJVMV>

Repartitioned<K, V, TJVMK, TJVMV>

WithKeySerde(ISerDes<K, TJVMK>)

public Repartitioned<K, V, TJVMK, TJVMV> WithKeySerde(ISerDes<K, TJVMK> arg0)

Parameters

arg0 ISerDes<K, TJVMK>

ISerDes<T, TJVMT>

Returns

Repartitioned<K, V, TJVMK, TJVMV>

Repartitioned<K, V, TJVMK, TJVMV>

WithNumberOfPartitions(int)

public Repartitioned<K, V, TJVMK, TJVMV> WithNumberOfPartitions(int arg0)

Parameters

arg0 int

int

Returns

Repartitioned<K, V, TJVMK, TJVMV>

Repartitioned<K, V, TJVMK, TJVMV>

WithStreamPartitioner(StreamPartitioner<K, V, TJVMK, TJVMV>)

public Repartitioned<K, V, TJVMK, TJVMV> WithStreamPartitioner(StreamPartitioner<K, V, TJVMK, TJVMV> arg0)

Parameters

arg0 StreamPartitioner<K, V, TJVMK, TJVMV>

StreamPartitioner<K, V, TJVMK, TJVMV>

Returns

Repartitioned<K, V, TJVMK, TJVMV>

Repartitioned<K, V, TJVMK, TJVMV>

WithValueSerde(ISerDes<V, TJVMV>)

public Repartitioned<K, V, TJVMK, TJVMV> WithValueSerde(ISerDes<V, TJVMV> arg0)

Parameters

arg0 ISerDes<V, TJVMV>

ISerDes<T, TJVMT>

Returns

Repartitioned<K, V, TJVMK, TJVMV>

Repartitioned<K, V, TJVMK, TJVMV>

Operators

implicit operator Repartitioned<TJVMK, TJVMV>(Repartitioned<K, V, TJVMK, TJVMV>)

public static implicit operator Repartitioned<TJVMK, TJVMV>(Repartitioned<K, V, TJVMK, TJVMV> t)

Parameters

t Repartitioned<K, V, TJVMK, TJVMV>

Returns

Repartitioned<TJVMK, TJVMV>