Table of Contents

Class Topology

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

KNet implementation of Topology

public class Topology : IGenericSerDesFactoryApplier
Inheritance
Topology
Implements
Inherited Members

Constructors

Topology(IGenericSerDesFactory)

public Topology(IGenericSerDesFactory factory)

Parameters

factory IGenericSerDesFactory

Topology(TopologyConfig)

public Topology(TopologyConfig arg0)

Parameters

arg0 TopologyConfig

TopologyConfig

Methods

AddSink(string, string, params string[])

public Topology AddSink(string arg0, string arg1, params string[] arg2)

Parameters

arg0 string

string

arg1 string

string

arg2 string[]

string

Returns

Topology

Topology

AddSink<K, V>(string, TopicNameExtractor<K, V>, ISerializer<K, byte[]>, ISerializer<V, byte[]>, params string[])

public Topology AddSink<K, V>(string arg0, TopicNameExtractor<K, V> arg1, ISerializer<K, byte[]> arg2, ISerializer<V, byte[]> arg3, params string[] arg4)

Parameters

arg0 string

string

arg1 TopicNameExtractor<K, V>

TopicNameExtractor<K, V>

arg2 ISerializer<K, byte[]>

ISerializer<T, TJVMT>

arg3 ISerializer<V, byte[]>

ISerializer<T, TJVMT>

arg4 string[]

string

Returns

Topology

Topology

Type Parameters

K
V

AddSink<K, V>(string, TopicNameExtractor<K, V>, params string[])

public Topology AddSink<K, V>(string arg0, TopicNameExtractor<K, V> arg1, params string[] arg2)

Parameters

arg0 string

string

arg1 TopicNameExtractor<K, V>

TopicNameExtractor<K, V>

arg2 string[]

string

Returns

Topology

Topology

Type Parameters

K
V

AddSink<K, V>(string, string, ISerializer<K, byte[]>, ISerializer<V, byte[]>, params string[])

public Topology AddSink<K, V>(string arg0, string arg1, ISerializer<K, byte[]> arg2, ISerializer<V, byte[]> arg3, params string[] arg4)

Parameters

arg0 string

string

arg1 string

string

arg2 ISerializer<K, byte[]>

ISerializer<T, TJVMT>

arg3 ISerializer<V, byte[]>

ISerializer<T, TJVMT>

arg4 string[]

string

Returns

Topology

Topology

Type Parameters

K
V

AddSink<K, V, Arg4objectSuperK, Arg4objectSuperV>(string, TopicNameExtractor<K, V>, ISerializer<K, byte[]>, ISerializer<V, byte[]>, StreamPartitioner<Arg4objectSuperK, Arg4objectSuperV>, params string[])

public Topology AddSink<K, V, Arg4objectSuperK, Arg4objectSuperV>(string arg0, TopicNameExtractor<K, V> arg1, ISerializer<K, byte[]> arg2, ISerializer<V, byte[]> arg3, StreamPartitioner<Arg4objectSuperK, Arg4objectSuperV> arg4, params string[] arg5) where Arg4objectSuperK : K where Arg4objectSuperV : V

Parameters

arg0 string

string

arg1 TopicNameExtractor<K, V>

TopicNameExtractor<K, V>

arg2 ISerializer<K, byte[]>

ISerializer<T, TJVMT>

arg3 ISerializer<V, byte[]>

ISerializer<T, TJVMT>

arg4 StreamPartitioner<Arg4objectSuperK, Arg4objectSuperV>

StreamPartitioner<K, V>

arg5 string[]

string

Returns

Topology

Topology

Type Parameters

K
V
Arg4objectSuperK

K

Arg4objectSuperV

V

AddSink<K, V, Arg2objectSuperK, Arg2objectSuperV>(string, TopicNameExtractor<K, V>, StreamPartitioner<Arg2objectSuperK, Arg2objectSuperV>, params string[])

public Topology AddSink<K, V, Arg2objectSuperK, Arg2objectSuperV>(string arg0, TopicNameExtractor<K, V> arg1, StreamPartitioner<Arg2objectSuperK, Arg2objectSuperV> arg2, params string[] arg3) where Arg2objectSuperK : K where Arg2objectSuperV : V

Parameters

arg0 string

string

arg1 TopicNameExtractor<K, V>

TopicNameExtractor<K, V>

arg2 StreamPartitioner<Arg2objectSuperK, Arg2objectSuperV>

StreamPartitioner<K, V>

arg3 string[]

string

Returns

Topology

Topology

Type Parameters

K
V
Arg2objectSuperK

K

Arg2objectSuperV

V

AddSink<K, V, Arg4objectSuperK, Arg4objectSuperV>(string, string, ISerializer<K, byte[]>, ISerializer<V, byte[]>, StreamPartitioner<Arg4objectSuperK, Arg4objectSuperV>, params string[])

public Topology AddSink<K, V, Arg4objectSuperK, Arg4objectSuperV>(string arg0, string arg1, ISerializer<K, byte[]> arg2, ISerializer<V, byte[]> arg3, StreamPartitioner<Arg4objectSuperK, Arg4objectSuperV> arg4, params string[] arg5) where Arg4objectSuperK : K where Arg4objectSuperV : V

Parameters

arg0 string

string

arg1 string

string

arg2 ISerializer<K, byte[]>

ISerializer<T, TJVMT>

arg3 ISerializer<V, byte[]>

ISerializer<T, TJVMT>

arg4 StreamPartitioner<Arg4objectSuperK, Arg4objectSuperV>

StreamPartitioner<K, V>

arg5 string[]

string

Returns

Topology

Topology

Type Parameters

K
V
Arg4objectSuperK

K

Arg4objectSuperV

V

AddSink<Arg2objectSuperK, K, Arg2objectSuperV, V>(string, string, StreamPartitioner<Arg2objectSuperK, Arg2objectSuperV>, params string[])

public Topology AddSink<Arg2objectSuperK, K, Arg2objectSuperV, V>(string arg0, string arg1, StreamPartitioner<Arg2objectSuperK, Arg2objectSuperV> arg2, params string[] arg3) where Arg2objectSuperK : K where Arg2objectSuperV : V

Parameters

arg0 string

string

arg1 string

string

arg2 StreamPartitioner<Arg2objectSuperK, Arg2objectSuperV>

StreamPartitioner<K, V>

arg3 string[]

string

Returns

Topology

Topology

Type Parameters

Arg2objectSuperK

K

K
Arg2objectSuperV

V

V

AddSource(TimestampExtractor, string, Pattern)

public Topology AddSource(TimestampExtractor arg0, string arg1, Pattern arg2)

Parameters

arg0 TimestampExtractor

TimestampExtractor

arg1 string

string

arg2 Pattern

Pattern

Returns

Topology

Topology

AddSource(TimestampExtractor, string, params string[])

public Topology AddSource(TimestampExtractor arg0, string arg1, params string[] arg2)

Parameters

arg0 TimestampExtractor

TimestampExtractor

arg1 string

string

arg2 string[]

string

Returns

Topology

Topology

AddSource(AutoOffsetReset, TimestampExtractor, string, Pattern)

public Topology AddSource(Topology.AutoOffsetReset arg0, TimestampExtractor arg1, string arg2, Pattern arg3)

Parameters

arg0 Topology.AutoOffsetReset

Topology.AutoOffsetReset

arg1 TimestampExtractor

TimestampExtractor

arg2 string

string

arg3 Pattern

Pattern

Returns

Topology

Topology

AddSource(AutoOffsetReset, TimestampExtractor, string, params string[])

public Topology AddSource(Topology.AutoOffsetReset arg0, TimestampExtractor arg1, string arg2, params string[] arg3)

Parameters

arg0 Topology.AutoOffsetReset

Topology.AutoOffsetReset

arg1 TimestampExtractor

TimestampExtractor

arg2 string

string

arg3 string[]

string

Returns

Topology

Topology

AddSource(AutoOffsetReset, string, Pattern)

public Topology AddSource(Topology.AutoOffsetReset arg0, string arg1, Pattern arg2)

Parameters

arg0 Topology.AutoOffsetReset

Topology.AutoOffsetReset

arg1 string

string

arg2 Pattern

Pattern

Returns

Topology

Topology

AddSource(AutoOffsetReset, string, IDeserializer<object, byte[]>, IDeserializer<object, byte[]>, Pattern)

public Topology AddSource(Topology.AutoOffsetReset arg0, string arg1, IDeserializer<object, byte[]> arg2, IDeserializer<object, byte[]> arg3, Pattern arg4)

Parameters

arg0 Topology.AutoOffsetReset

Topology.AutoOffsetReset

arg1 string

string

arg2 IDeserializer<object, byte[]>

IDeserializer<T, TJVMT>

arg3 IDeserializer<object, byte[]>

IDeserializer<T, TJVMT>

arg4 Pattern

Pattern

Returns

Topology

Topology

AddSource(AutoOffsetReset, string, IDeserializer<object, byte[]>, IDeserializer<object, byte[]>, params string[])

public Topology AddSource(Topology.AutoOffsetReset arg0, string arg1, IDeserializer<object, byte[]> arg2, IDeserializer<object, byte[]> arg3, params string[] arg4)

Parameters

arg0 Topology.AutoOffsetReset

Topology.AutoOffsetReset

arg1 string

string

arg2 IDeserializer<object, byte[]>

IDeserializer<T, TJVMT>

arg3 IDeserializer<object, byte[]>

IDeserializer<T, TJVMT>

arg4 string[]

string

Returns

Topology

Topology

AddSource(AutoOffsetReset, string, TimestampExtractor, IDeserializer<object, byte[]>, IDeserializer<object, byte[]>, Pattern)

public Topology AddSource(Topology.AutoOffsetReset arg0, string arg1, TimestampExtractor arg2, IDeserializer<object, byte[]> arg3, IDeserializer<object, byte[]> arg4, Pattern arg5)

Parameters

arg0 Topology.AutoOffsetReset

Topology.AutoOffsetReset

arg1 string

string

arg2 TimestampExtractor

TimestampExtractor

arg3 IDeserializer<object, byte[]>

IDeserializer<T, TJVMT>

arg4 IDeserializer<object, byte[]>

IDeserializer<T, TJVMT>

arg5 Pattern

Pattern

Returns

Topology

Topology

AddSource(AutoOffsetReset, string, TimestampExtractor, IDeserializer<object, byte[]>, IDeserializer<object, byte[]>, params string[])

public Topology AddSource(Topology.AutoOffsetReset arg0, string arg1, TimestampExtractor arg2, IDeserializer<object, byte[]> arg3, IDeserializer<object, byte[]> arg4, params string[] arg5)

Parameters

arg0 Topology.AutoOffsetReset

Topology.AutoOffsetReset

arg1 string

string

arg2 TimestampExtractor

TimestampExtractor

arg3 IDeserializer<object, byte[]>

IDeserializer<T, TJVMT>

arg4 IDeserializer<object, byte[]>

IDeserializer<T, TJVMT>

arg5 string[]

string

Returns

Topology

Topology

AddSource(AutoOffsetReset, string, params string[])

public Topology AddSource(Topology.AutoOffsetReset arg0, string arg1, params string[] arg2)

Parameters

arg0 Topology.AutoOffsetReset

Topology.AutoOffsetReset

arg1 string

string

arg2 string[]

string

Returns

Topology

Topology

AddSource(string, Pattern)

public Topology AddSource(string arg0, Pattern arg1)

Parameters

arg0 string

string

arg1 Pattern

Pattern

Returns

Topology

Topology

AddSource(string, IDeserializer<object, byte[]>, IDeserializer<object, byte[]>, Pattern)

public Topology AddSource(string arg0, IDeserializer<object, byte[]> arg1, IDeserializer<object, byte[]> arg2, Pattern arg3)

Parameters

arg0 string

string

arg1 IDeserializer<object, byte[]>

IDeserializer<T, TJVMT>

arg2 IDeserializer<object, byte[]>

IDeserializer<T, TJVMT>

arg3 Pattern

Pattern

Returns

Topology

Topology

AddSource(string, IDeserializer<object, byte[]>, IDeserializer<object, byte[]>, params string[])

public Topology AddSource(string arg0, IDeserializer<object, byte[]> arg1, IDeserializer<object, byte[]> arg2, params string[] arg3)

Parameters

arg0 string

string

arg1 IDeserializer<object, byte[]>

IDeserializer<T, TJVMT>

arg2 IDeserializer<object, byte[]>

IDeserializer<T, TJVMT>

arg3 string[]

string

Returns

Topology

Topology

AddSource(string, params string[])

public Topology AddSource(string arg0, params string[] arg1)

Parameters

arg0 string

string

arg1 string[]

string

Returns

Topology

Topology

Operators

implicit operator Topology(Topology)

Converter from Topology to Topology

public static implicit operator Topology(Topology t)

Parameters

t Topology

Returns

Topology