Table of Contents

Class ImplicitConversions

Namespace
Org.Apache.Kafka.Streams.Scala
Assembly
MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html

public class ImplicitConversions : JVMBridgeBase<ImplicitConversions>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
ImplicitConversions
Implements
Inherited Members

Constructors

ImplicitConversions()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

public ImplicitConversions()

ImplicitConversions(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 ImplicitConversions(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

true if the BridgeClassName is an abstract class, i.e. cannot be created an instance

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

true if the BridgeClassName implements Closeable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

true if the BridgeClassName is an interface, i.e. does not have any public constructor

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

true if the BridgeClassName is a static class, i.e. does not have any public constructor

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

ConsumedFromSerde<K, V>(Serde<K>, Serde<V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#consumedFromSerde(org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde)

public static Consumed<K, V> ConsumedFromSerde<K, V>(Serde<K> keySerde, Serde<V> valueSerde)

Parameters

keySerde Serde<K>

Serde

valueSerde Serde<V>

Serde

Returns

Consumed<K, V>

Consumed

Type Parameters

K
V

GroupedFromSerde<K, V>(Serde<K>, Serde<V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#groupedFromSerde(org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde)

public static Grouped<K, V> GroupedFromSerde<K, V>(Serde<K> keySerde, Serde<V> valueSerde)

Parameters

keySerde Serde<K>

Serde

valueSerde Serde<V>

Serde

Returns

Grouped<K, V>

Grouped

Type Parameters

K
V

JoinedFromKeyValueOtherSerde<K, V, VO>(Serde<K>, Serde<V>, Serde<VO>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#joinedFromKeyValueOtherSerde(org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde)

public static Joined<K, V, VO> JoinedFromKeyValueOtherSerde<K, V, VO>(Serde<K> keySerde, Serde<V> valueSerde, Serde<VO> otherValueSerde)

Parameters

keySerde Serde<K>

Serde

valueSerde Serde<V>

Serde

otherValueSerde Serde<VO>

Serde

Returns

Joined<K, V, VO>

Joined

Type Parameters

K
V
VO

MaterializedFromSerde<K, V>(Serde<K>, Serde<V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#materializedFromSerde(org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde)

public static Materialized MaterializedFromSerde<K, V>(Serde<K> keySerde, Serde<V> valueSerde)

Parameters

keySerde Serde<K>

Serde

valueSerde Serde<V>

Serde

Returns

Materialized

Materialized

Type Parameters

K
V

ProducedFromSerde<K, V>(Serde<K>, Serde<V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#producedFromSerde(org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde)

public static Produced<K, V> ProducedFromSerde<K, V>(Serde<K> keySerde, Serde<V> valueSerde)

Parameters

keySerde Serde<K>

Serde

valueSerde Serde<V>

Serde

Returns

Produced<K, V>

Produced

Type Parameters

K
V

RepartitionedFromSerde<K, V>(Serde<K>, Serde<V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#repartitionedFromSerde(org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde)

public static Repartitioned<K, V> RepartitionedFromSerde<K, V>(Serde<K> keySerde, Serde<V> valueSerde)

Parameters

keySerde Serde<K>

Serde

valueSerde Serde<V>

Serde

Returns

Repartitioned<K, V>

Repartitioned

Type Parameters

K
V

StreamJoinFromKeyValueOtherSerde<K, V, VO>(Serde<K>, Serde<V>, Serde<VO>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#streamJoinFromKeyValueOtherSerde(org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde,org.apache.kafka.common.serialization.Serde)

public static StreamJoined<K, V, VO> StreamJoinFromKeyValueOtherSerde<K, V, VO>(Serde<K> keySerde, Serde<V> valueSerde, Serde<VO> otherValueSerde)

Parameters

keySerde Serde<K>

Serde

valueSerde Serde<V>

Serde

otherValueSerde Serde<VO>

Serde

Returns

StreamJoined<K, V, VO>

StreamJoined

Type Parameters

K
V
VO

WrapCogroupedKStream<K, V>(CogroupedKStream<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#wrapCogroupedKStream(org.apache.kafka.streams.kstream.CogroupedKStream)

public static CogroupedKStream<K, V> WrapCogroupedKStream<K, V>(CogroupedKStream<K, V> inner)

Parameters

inner CogroupedKStream<K, V>

CogroupedKStream

Returns

CogroupedKStream<K, V>

CogroupedKStream

Type Parameters

K
V

WrapKGroupedStream<K, V>(KGroupedStream<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#wrapKGroupedStream(org.apache.kafka.streams.kstream.KGroupedStream)

public static KGroupedStream<K, V> WrapKGroupedStream<K, V>(KGroupedStream<K, V> inner)

Parameters

inner KGroupedStream<K, V>

KGroupedStream

Returns

KGroupedStream<K, V>

KGroupedStream

Type Parameters

K
V

WrapKGroupedTable<K, V>(KGroupedTable<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#wrapKGroupedTable(org.apache.kafka.streams.kstream.KGroupedTable)

public static KGroupedTable<K, V> WrapKGroupedTable<K, V>(KGroupedTable<K, V> inner)

Parameters

inner KGroupedTable<K, V>

KGroupedTable

Returns

KGroupedTable<K, V>

KGroupedTable

Type Parameters

K
V

WrapKStream<K, V>(KStream<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#wrapKStream(org.apache.kafka.streams.kstream.KStream)

public static KStream<K, V> WrapKStream<K, V>(KStream<K, V> inner)

Parameters

inner KStream<K, V>

KStream

Returns

KStream<K, V>

KStream

Type Parameters

K
V

WrapKTable<K, V>(KTable<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#wrapKTable(org.apache.kafka.streams.kstream.KTable)

public static KTable<K, V> WrapKTable<K, V>(KTable<K, V> inner)

Parameters

inner KTable<K, V>

KTable

Returns

KTable<K, V>

KTable

Type Parameters

K
V

WrapSessionWindowedCogroupedKStream<K, V>(SessionWindowedCogroupedKStream<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#wrapSessionWindowedCogroupedKStream(org.apache.kafka.streams.kstream.SessionWindowedCogroupedKStream)

public static SessionWindowedCogroupedKStream<K, V> WrapSessionWindowedCogroupedKStream<K, V>(SessionWindowedCogroupedKStream<K, V> inner)

Parameters

inner SessionWindowedCogroupedKStream<K, V>

SessionWindowedCogroupedKStream

Returns

SessionWindowedCogroupedKStream<K, V>

SessionWindowedCogroupedKStream

Type Parameters

K
V

WrapSessionWindowedKStream<K, V>(SessionWindowedKStream<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#wrapSessionWindowedKStream(org.apache.kafka.streams.kstream.SessionWindowedKStream)

public static SessionWindowedKStream<K, V> WrapSessionWindowedKStream<K, V>(SessionWindowedKStream<K, V> inner)

Parameters

inner SessionWindowedKStream<K, V>

SessionWindowedKStream

Returns

SessionWindowedKStream<K, V>

SessionWindowedKStream

Type Parameters

K
V

WrapTimeWindowedCogroupedKStream<K, V>(TimeWindowedCogroupedKStream<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#wrapTimeWindowedCogroupedKStream(org.apache.kafka.streams.kstream.TimeWindowedCogroupedKStream)

public static TimeWindowedCogroupedKStream<K, V> WrapTimeWindowedCogroupedKStream<K, V>(TimeWindowedCogroupedKStream<K, V> inner)

Parameters

inner TimeWindowedCogroupedKStream<K, V>

TimeWindowedCogroupedKStream

Returns

TimeWindowedCogroupedKStream<K, V>

TimeWindowedCogroupedKStream

Type Parameters

K
V

WrapTimeWindowedKStream<K, V>(TimeWindowedKStream<K, V>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/4.0.0/org/apache/kafka/streams/scala/ImplicitConversions.html#wrapTimeWindowedKStream(org.apache.kafka.streams.kstream.TimeWindowedKStream)

public static TimeWindowedKStream<K, V> WrapTimeWindowedKStream<K, V>(TimeWindowedKStream<K, V> inner)

Parameters

inner TimeWindowedKStream<K, V>

TimeWindowedKStream

Returns

TimeWindowedKStream<K, V>

TimeWindowedKStream

Type Parameters

K
V
Edit this page