Class KStream
public class KStream : JVMBridgeBase<KStream>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition- Inheritance
-
KStream
- Implements
- Inherited Members
Constructors
KStream()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public KStream()KStream(KStream)
public KStream(KStream inner)Parameters
KStream(params object[])
Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class
public KStream(params object[] args)Parameters
argsobject[]
Properties
BridgeClassName
Java class name to be instantiated
public override string BridgeClassName { get; }Property Value
IsBridgeAbstract
true if the BridgeClassName is an abstract class, i.e. cannot be created an instance
public override bool IsBridgeAbstract { get; }Property Value
IsBridgeCloseable
true if the BridgeClassName implements Closeable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
true if the BridgeClassName is an interface, i.e. does not have any public constructor
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
true if the BridgeClassName is a static class, i.e. does not have any public constructor
public override bool IsBridgeStatic { get; }Property Value
Methods
GroupByKey(Grouped)
public KGroupedStream GroupByKey(Grouped grouped)Parameters
Returns
Inner()
public KStream Inner()Returns
Merge(KStream)
public KStream Merge(KStream stream)Parameters
Returns
Merge(KStream, Named)
public KStream Merge(KStream stream, Named named)Parameters
Returns
Print(Printed)
public void Print(Printed printed)Parameters
Repartition(Repartitioned)
public KStream Repartition(Repartitioned repartitioned)Parameters
repartitionedRepartitioned
Returns
Split()
public BranchedKStream Split()Returns
Split(Named)
public BranchedKStream Split(Named named)Parameters
Returns
To(String, Produced)
public void To(String topic, Produced produced)Parameters
To(TopicNameExtractor, Produced)
public void To(TopicNameExtractor extractor, Produced produced)Parameters
extractorTopicNameExtractorproducedProduced
ToTable()
public KTable ToTable()Returns
ToTable(Materialized)
public KTable ToTable(Materialized materialized)Parameters
materializedMaterialized
Returns
ToTable(Named)
public KTable ToTable(Named named)Parameters
Returns
ToTable(Named, Materialized)
public KTable ToTable(Named named, Materialized materialized)Parameters
namedNamedmaterializedMaterialized