Class StreamsBuilder
KNet extension of StreamsBuilder
public class StreamsBuilder : IGenericSerDesFactoryApplier- Inheritance
-
StreamsBuilder
- Implements
- Inherited Members
Constructors
StreamsBuilder(StreamsConfigBuilder)
public StreamsBuilder(StreamsConfigBuilder factory)Parameters
factoryStreamsConfigBuilderStreamsConfigBuilder used as reference of IGenericSerDesFactory
StreamsBuilder(TopologyConfig)
public StreamsBuilder(TopologyConfig arg0)Parameters
Properties
OverrideProperties
If set, this Func<T, TResult> will be called from PrepareProperties(StreamsConfigBuilder)
public static Func<StreamsConfigBuilder, Properties> OverrideProperties { get; set; }Property Value
Methods
AddStateStore(StoreBuilder)
public StreamsBuilder AddStateStore(StoreBuilder arg0)Parameters
arg0StoreBuilder
Returns
Build()
public Topology Build()Returns
Build(Properties)
public Topology Build(Properties arg0)Parameters
arg0Properties
Returns
GlobalTable<K, V, TJVMK, TJVMV>(string)
public GlobalKTable<K, V, TJVMK, TJVMV> GlobalTable<K, V, TJVMK, TJVMV>(string arg0)Parameters
Returns
- GlobalKTable<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
GlobalTable<K, V, TJVMK, TJVMV>(string, Consumed<K, V, TJVMK, TJVMV>)
public GlobalKTable<K, V, TJVMK, TJVMV> GlobalTable<K, V, TJVMK, TJVMV>(string arg0, Consumed<K, V, TJVMK, TJVMV> arg1)Parameters
Returns
- GlobalKTable<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
GlobalTable<K, V, TJVMK, TJVMV>(string, Consumed<K, V, TJVMK, TJVMV>, Materialized<K, V, TJVMK, TJVMV>)
public GlobalKTable<K, V, TJVMK, TJVMV> GlobalTable<K, V, TJVMK, TJVMV>(string arg0, Consumed<K, V, TJVMK, TJVMV> arg1, Materialized<K, V, TJVMK, TJVMV> arg2)Parameters
arg0stringarg1Consumed<K, V, TJVMK, TJVMV>arg2Materialized<K, V, TJVMK, TJVMV>
Returns
- GlobalKTable<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
GlobalTable<K, V, TJVMK, TJVMV>(string, Materialized<K, V, TJVMK, TJVMV>)
public GlobalKTable<K, V, TJVMK, TJVMV> GlobalTable<K, V, TJVMK, TJVMV>(string arg0, Materialized<K, V, TJVMK, TJVMV> arg1)Parameters
arg0stringarg1Materialized<K, V, TJVMK, TJVMV>
Returns
- GlobalKTable<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
PrepareProperties(StreamsConfigBuilder)
Override this method to check and modify the Properties returned to underlying KafkaStreams
protected virtual Properties PrepareProperties(StreamsConfigBuilder builder)Parameters
builderStreamsConfigBuilderStreamsConfigBuilder to use to return Properties
Returns
- Properties
Properties used from underlying KafkaStreams
Stream<K, V, TJVMK, TJVMV>(Pattern)
public KStream<K, V, TJVMK, TJVMV> Stream<K, V, TJVMK, TJVMV>(Pattern arg0)Parameters
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Stream<K, V, TJVMK, TJVMV>(Pattern, Consumed<K, V, TJVMK, TJVMV>)
public KStream<K, V, TJVMK, TJVMV> Stream<K, V, TJVMK, TJVMV>(Pattern arg0, Consumed<K, V, TJVMK, TJVMV> arg1)Parameters
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Stream<K, V, TJVMK, TJVMV>(IEnumerable<string>)
public KStream<K, V, TJVMK, TJVMV> Stream<K, V, TJVMK, TJVMV>(IEnumerable<string> arg0)Parameters
arg0IEnumerable<string>
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Stream<K, V, TJVMK, TJVMV>(IEnumerable<string>, Consumed<K, V, TJVMK, TJVMV>)
public KStream<K, V, TJVMK, TJVMV> Stream<K, V, TJVMK, TJVMV>(IEnumerable<string> arg0, Consumed<K, V, TJVMK, TJVMV> arg1)Parameters
arg0IEnumerable<string>arg1Consumed<K, V, TJVMK, TJVMV>
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Stream<K, V, TJVMK, TJVMV>(string)
public KStream<K, V, TJVMK, TJVMV> Stream<K, V, TJVMK, TJVMV>(string arg0)Parameters
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Stream<K, V, TJVMK, TJVMV>(string, Consumed<K, V, TJVMK, TJVMV>)
public KStream<K, V, TJVMK, TJVMV> Stream<K, V, TJVMK, TJVMV>(string arg0, Consumed<K, V, TJVMK, TJVMV> arg1)Parameters
Returns
- KStream<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Table<K, V, TJVMK, TJVMV>(string)
public KTable<K, V, TJVMK, TJVMV> Table<K, V, TJVMK, TJVMV>(string arg0)Parameters
Returns
- KTable<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Table<K, V, TJVMK, TJVMV>(string, Consumed<K, V, TJVMK, TJVMV>)
public KTable<K, V, TJVMK, TJVMV> Table<K, V, TJVMK, TJVMV>(string arg0, Consumed<K, V, TJVMK, TJVMV> arg1)Parameters
Returns
- KTable<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Table<K, V, TJVMK, TJVMV>(string, Consumed<K, V, TJVMK, TJVMV>, Materialized<K, V, TJVMK, TJVMV>)
public KTable<K, V, TJVMK, TJVMV> Table<K, V, TJVMK, TJVMV>(string arg0, Consumed<K, V, TJVMK, TJVMV> arg1, Materialized<K, V, TJVMK, TJVMV> arg2)Parameters
arg0stringarg1Consumed<K, V, TJVMK, TJVMV>arg2Materialized<K, V, TJVMK, TJVMV>
Returns
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
Table<K, V, TJVMK, TJVMV>(string, Materialized<K, V, TJVMK, TJVMV>)
public KTable<K, V, TJVMK, TJVMV> Table<K, V, TJVMK, TJVMV>(string arg0, Materialized<K, V, TJVMK, TJVMV> arg1)Parameters
arg0stringarg1Materialized<K, V, TJVMK, TJVMV>
Returns
- KTable<K, V, TJVMK, TJVMV>
Type Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V