Class KStream
public class KStream : JVMBridgeBase<KStream>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition- Inheritance
-
JVMBridgeBaseJVMBridgeBase<KStream>KStream
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Inherited Members
-
JVMBridgeBase<KStream>.IsAssignableFrom(IJavaType)JVMBridgeBase<KStream>.IsAssignableFrom<T>()JVMBridgeBase<KStream>.Execute<T>(params T[])JVMBridgeBase<KStream>.DynBridgeClazzJVMBridgeBase<KStream>.BridgeClazzJVMBridgeBase.RuntimeClassNameOf<T>()JVMBridgeBase.ClassNameOf<T>()JVMBridgeBase.ClassOf<T>()JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)JVMBridgeBase.Wraps<TNewClass>(IJavaObject)JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)JVMBridgeBase.MonitorEnter()JVMBridgeBase.MonitorExit()JVMBridgeBase.IsInstanceOf(IJavaType)JVMBridgeBase.IsInstanceOf<T>()JVMBridgeBase.RuntimeIsInstanceOf<T>()JVMBridgeBase.CastTo<TNewClass>()JVMBridgeBase.CastDirect<TNewClass>()JVMBridgeBase.Dispose()JVMBridgeBase.ToString()JVMBridgeBase.GetHashCode()JVMBridgeBase.Notify()JVMBridgeBase.NotifyAll()JVMBridgeBase.Wait()JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeListener
Constructors
KStream()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
[Obsolete("KStream class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public KStream()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
[Obsolete("KStream class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public KStream(params object[] args)Parameters
argsobject[]
Properties
BridgeClassName
https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm
public override string BridgeClassName { get; }Property Value
IsBridgeAbstract
public override bool IsBridgeAbstract { get; }Property Value
IsBridgeCloseable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
public override bool IsBridgeStatic { get; }Property Value
Methods
Filter(Predicate)
public KStream Filter(Predicate arg0)Parameters
Returns
Filter(Predicate, Named)
public KStream Filter(Predicate arg0, Named arg1)Parameters
Returns
FilterNot(Predicate)
public KStream FilterNot(Predicate arg0)Parameters
Returns
FilterNot(Predicate, Named)
public KStream FilterNot(Predicate arg0, Named arg1)Parameters
Returns
FlatMap(KeyValueMapper)
public KStream FlatMap(KeyValueMapper arg0)Parameters
Returns
FlatMap(KeyValueMapper, Named)
public KStream FlatMap(KeyValueMapper arg0, Named arg1)Parameters
arg0KeyValueMapperarg1Named
Returns
FlatMapValues(ValueMapper)
public KStream FlatMapValues(ValueMapper arg0)Parameters
arg0ValueMapper
Returns
FlatMapValues(ValueMapper, Named)
public KStream FlatMapValues(ValueMapper arg0, Named arg1)Parameters
arg0ValueMapperarg1Named
Returns
FlatMapValues(ValueMapperWithKey)
public KStream FlatMapValues(ValueMapperWithKey arg0)Parameters
Returns
FlatMapValues(ValueMapperWithKey, Named)
public KStream FlatMapValues(ValueMapperWithKey arg0, Named arg1)Parameters
arg0ValueMapperWithKeyarg1Named
Returns
Foreach(ForeachAction)
public void Foreach(ForeachAction arg0)Parameters
Foreach(ForeachAction, Named)
public void Foreach(ForeachAction arg0, Named arg1)Parameters
arg0ForeachActionarg1Named
GroupBy(KeyValueMapper)
public KGroupedStream GroupBy(KeyValueMapper arg0)Parameters
Returns
GroupBy(KeyValueMapper, Grouped)
public KGroupedStream GroupBy(KeyValueMapper arg0, Grouped arg1)Parameters
arg0KeyValueMapperarg1Grouped
Returns
GroupByKey()
public KGroupedStream GroupByKey()Returns
GroupByKey(Grouped)
public KGroupedStream GroupByKey(Grouped arg0)Parameters
Returns
Join(GlobalKTable, KeyValueMapper, ValueJoiner)
public KStream Join(GlobalKTable arg0, KeyValueMapper arg1, ValueJoiner arg2)Parameters
arg0GlobalKTablearg1KeyValueMapperarg2ValueJoiner
Returns
Join(GlobalKTable, KeyValueMapper, ValueJoiner, Named)
public KStream Join(GlobalKTable arg0, KeyValueMapper arg1, ValueJoiner arg2, Named arg3)Parameters
arg0GlobalKTablearg1KeyValueMapperarg2ValueJoinerarg3Named
Returns
Join(GlobalKTable, KeyValueMapper, ValueJoinerWithKey)
public KStream Join(GlobalKTable arg0, KeyValueMapper arg1, ValueJoinerWithKey arg2)Parameters
arg0GlobalKTablearg1KeyValueMapperarg2ValueJoinerWithKey
Returns
Join(GlobalKTable, KeyValueMapper, ValueJoinerWithKey, Named)
public KStream Join(GlobalKTable arg0, KeyValueMapper arg1, ValueJoinerWithKey arg2, Named arg3)Parameters
arg0GlobalKTablearg1KeyValueMapperarg2ValueJoinerWithKeyarg3Named
Returns
Join(KStream, ValueJoiner, JoinWindows)
public KStream Join(KStream arg0, ValueJoiner arg1, JoinWindows arg2)Parameters
arg0KStreamarg1ValueJoinerarg2JoinWindows
Returns
Join(KStream, ValueJoiner, JoinWindows, StreamJoined)
public KStream Join(KStream arg0, ValueJoiner arg1, JoinWindows arg2, StreamJoined arg3)Parameters
arg0KStreamarg1ValueJoinerarg2JoinWindowsarg3StreamJoined
Returns
Join(KStream, ValueJoinerWithKey, JoinWindows)
public KStream Join(KStream arg0, ValueJoinerWithKey arg1, JoinWindows arg2)Parameters
arg0KStreamarg1ValueJoinerWithKeyarg2JoinWindows
Returns
Join(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined)
public KStream Join(KStream arg0, ValueJoinerWithKey arg1, JoinWindows arg2, StreamJoined arg3)Parameters
arg0KStreamarg1ValueJoinerWithKeyarg2JoinWindowsarg3StreamJoined
Returns
Join(KTable, ValueJoiner)
public KStream Join(KTable arg0, ValueJoiner arg1)Parameters
arg0KTablearg1ValueJoiner
Returns
Join(KTable, ValueJoiner, Joined)
public KStream Join(KTable arg0, ValueJoiner arg1, Joined arg2)Parameters
arg0KTablearg1ValueJoinerarg2Joined
Returns
Join(KTable, ValueJoinerWithKey)
public KStream Join(KTable arg0, ValueJoinerWithKey arg1)Parameters
arg0KTablearg1ValueJoinerWithKey
Returns
Join(KTable, ValueJoinerWithKey, Joined)
public KStream Join(KTable arg0, ValueJoinerWithKey arg1, Joined arg2)Parameters
arg0KTablearg1ValueJoinerWithKeyarg2Joined
Returns
LeftJoin(GlobalKTable, KeyValueMapper, ValueJoiner)
public KStream LeftJoin(GlobalKTable arg0, KeyValueMapper arg1, ValueJoiner arg2)Parameters
arg0GlobalKTablearg1KeyValueMapperarg2ValueJoiner
Returns
LeftJoin(GlobalKTable, KeyValueMapper, ValueJoiner, Named)
public KStream LeftJoin(GlobalKTable arg0, KeyValueMapper arg1, ValueJoiner arg2, Named arg3)Parameters
arg0GlobalKTablearg1KeyValueMapperarg2ValueJoinerarg3Named
Returns
LeftJoin(GlobalKTable, KeyValueMapper, ValueJoinerWithKey)
public KStream LeftJoin(GlobalKTable arg0, KeyValueMapper arg1, ValueJoinerWithKey arg2)Parameters
arg0GlobalKTablearg1KeyValueMapperarg2ValueJoinerWithKey
Returns
LeftJoin(GlobalKTable, KeyValueMapper, ValueJoinerWithKey, Named)
public KStream LeftJoin(GlobalKTable arg0, KeyValueMapper arg1, ValueJoinerWithKey arg2, Named arg3)Parameters
arg0GlobalKTablearg1KeyValueMapperarg2ValueJoinerWithKeyarg3Named
Returns
LeftJoin(KStream, ValueJoiner, JoinWindows)
public KStream LeftJoin(KStream arg0, ValueJoiner arg1, JoinWindows arg2)Parameters
arg0KStreamarg1ValueJoinerarg2JoinWindows
Returns
LeftJoin(KStream, ValueJoiner, JoinWindows, StreamJoined)
public KStream LeftJoin(KStream arg0, ValueJoiner arg1, JoinWindows arg2, StreamJoined arg3)Parameters
arg0KStreamarg1ValueJoinerarg2JoinWindowsarg3StreamJoined
Returns
LeftJoin(KStream, ValueJoinerWithKey, JoinWindows)
public KStream LeftJoin(KStream arg0, ValueJoinerWithKey arg1, JoinWindows arg2)Parameters
arg0KStreamarg1ValueJoinerWithKeyarg2JoinWindows
Returns
LeftJoin(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined)
public KStream LeftJoin(KStream arg0, ValueJoinerWithKey arg1, JoinWindows arg2, StreamJoined arg3)Parameters
arg0KStreamarg1ValueJoinerWithKeyarg2JoinWindowsarg3StreamJoined
Returns
LeftJoin(KTable, ValueJoiner)
public KStream LeftJoin(KTable arg0, ValueJoiner arg1)Parameters
arg0KTablearg1ValueJoiner
Returns
LeftJoin(KTable, ValueJoiner, Joined)
public KStream LeftJoin(KTable arg0, ValueJoiner arg1, Joined arg2)Parameters
arg0KTablearg1ValueJoinerarg2Joined
Returns
LeftJoin(KTable, ValueJoinerWithKey)
public KStream LeftJoin(KTable arg0, ValueJoinerWithKey arg1)Parameters
arg0KTablearg1ValueJoinerWithKey
Returns
LeftJoin(KTable, ValueJoinerWithKey, Joined)
public KStream LeftJoin(KTable arg0, ValueJoinerWithKey arg1, Joined arg2)Parameters
arg0KTablearg1ValueJoinerWithKeyarg2Joined
Returns
Map(KeyValueMapper)
public KStream Map(KeyValueMapper arg0)Parameters
Returns
Map(KeyValueMapper, Named)
public KStream Map(KeyValueMapper arg0, Named arg1)Parameters
arg0KeyValueMapperarg1Named
Returns
MapValues(ValueMapper)
public KStream MapValues(ValueMapper arg0)Parameters
arg0ValueMapper
Returns
MapValues(ValueMapper, Named)
public KStream MapValues(ValueMapper arg0, Named arg1)Parameters
arg0ValueMapperarg1Named
Returns
MapValues(ValueMapperWithKey)
public KStream MapValues(ValueMapperWithKey arg0)Parameters
Returns
MapValues(ValueMapperWithKey, Named)
public KStream MapValues(ValueMapperWithKey arg0, Named arg1)Parameters
arg0ValueMapperWithKeyarg1Named
Returns
Merge(KStream)
public KStream Merge(KStream arg0)Parameters
Returns
Merge(KStream, Named)
public KStream Merge(KStream arg0, Named arg1)Parameters
Returns
OuterJoin(KStream, ValueJoiner, JoinWindows)
public KStream OuterJoin(KStream arg0, ValueJoiner arg1, JoinWindows arg2)Parameters
arg0KStreamarg1ValueJoinerarg2JoinWindows
Returns
OuterJoin(KStream, ValueJoiner, JoinWindows, StreamJoined)
public KStream OuterJoin(KStream arg0, ValueJoiner arg1, JoinWindows arg2, StreamJoined arg3)Parameters
arg0KStreamarg1ValueJoinerarg2JoinWindowsarg3StreamJoined
Returns
OuterJoin(KStream, ValueJoinerWithKey, JoinWindows)
public KStream OuterJoin(KStream arg0, ValueJoinerWithKey arg1, JoinWindows arg2)Parameters
arg0KStreamarg1ValueJoinerWithKeyarg2JoinWindows
Returns
OuterJoin(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined)
public KStream OuterJoin(KStream arg0, ValueJoinerWithKey arg1, JoinWindows arg2, StreamJoined arg3)Parameters
arg0KStreamarg1ValueJoinerWithKeyarg2JoinWindowsarg3StreamJoined
Returns
Peek(ForeachAction)
public KStream Peek(ForeachAction arg0)Parameters
Returns
Peek(ForeachAction, Named)
public KStream Peek(ForeachAction arg0, Named arg1)Parameters
arg0ForeachActionarg1Named
Returns
Print(Printed)
public void Print(Printed arg0)Parameters
Repartition()
public KStream Repartition()Returns
Repartition(Repartitioned)
public KStream Repartition(Repartitioned arg0)Parameters
Returns
SelectKey(KeyValueMapper)
public KStream SelectKey(KeyValueMapper arg0)Parameters
Returns
SelectKey(KeyValueMapper, Named)
public KStream SelectKey(KeyValueMapper arg0, Named arg1)Parameters
arg0KeyValueMapperarg1Named
Returns
Split()
public BranchedKStream Split()Returns
Split(Named)
public BranchedKStream Split(Named arg0)Parameters
Returns
To(String)
public void To(String arg0)Parameters
To(String, Produced)
public void To(String arg0, Produced arg1)Parameters
To(TopicNameExtractor)
public void To(TopicNameExtractor arg0)Parameters
To(TopicNameExtractor, Produced)
public void To(TopicNameExtractor arg0, Produced arg1)Parameters
arg0TopicNameExtractorarg1Produced
ToTable()
public KTable ToTable()Returns
ToTable(Materialized)
public KTable ToTable(Materialized arg0)Parameters
arg0Materialized
Returns
ToTable(Named)
public KTable ToTable(Named arg0)Parameters
Returns
ToTable(Named, Materialized)
public KTable ToTable(Named arg0, Materialized arg1)Parameters
arg0Namedarg1Materialized