ImplicitConversions

ImplicitConversions is a Scala object that contains the implicit conversions between the Scala wrapper objects and the underlying Java objects.

You should import ImplicitConversions to use the implicit conversions in a Scala application that uses the Kafka Streams library.

import org.apache.kafka.streams.scala.ImplicitConversions._
Table 1. Implicit Conversions
Name Description

consumedFromSerde

 
consumedFromSerde[K, V](
  implicit keySerde: Serde[K],
  valueSerde: Serde[V]): Consumed[K, V]

Creates a Consumed instance

groupedFromSerde

 
groupedFromSerde[K, V](
  implicit keySerde: Serde[K],
  valueSerde: Serde[V]): Grouped[K, V]

Creates a Grouped instance

joinedFromKeyValueOtherSerde

 
joinedFromKeyValueOtherSerde[K, V, VO](
  implicit keySerde: Serde[K],
  valueSerde: Serde[V],
  otherValueSerde: Serde[VO]): Joined[K, V, VO]

Creates a Joined instance

materializedFromSerde

 
materializedFromSerde[K, V, S <: StateStore](
  implicit keySerde: Serde[K],
  valueSerde: Serde[V]): Materialized[K, V, S]

Creates a Materialized instance

producedFromSerde

 
producedFromSerde[K, V](
  implicit keySerde: Serde[K],
  valueSerde: Serde[V]): Produced[K, V]

Creates a Produced instance

tuple2ToKeyValue

 
tuple2ToKeyValue[K, V](tuple: (K, V)): KeyValue[K, V]

Creates a KeyValue instance

wrapKGroupedStream

 
wrapKGroupedStream[K, V](inner: KGroupedStreamJ[K, V]): KGroupedStream[K, V]

Extends (wraps) a Java-based KGroupedStream with Scala API

wrapKGroupedTable

 
wrapKGroupedTable[K, V](inner: KGroupedTableJ[K, V]): KGroupedTable[K, V]

Extends (wraps) a Java-based KGroupedTable with Scala API

wrapKStream

 
wrapKStream[K, V](inner: KStreamJ[K, V]): KStream[K, V]

Extends (wraps) a Java-based KStream with Scala API

wrapKTable

 
wrapKTable[K, V](inner: KTableJ[K, V]): KTable[K, V]

Extends (wraps) a Java-based KTable with Scala API

wrapSessionWindowedKStream

 
wrapSessionWindowedKStream[K, V](
  inner: SessionWindowedKStreamJ[K, V]): SessionWindowedKStream[K, V]

Extends (wraps) a Java-based SessionWindowedKStream with Scala API

wrapTimeWindowedKStream

 
wrapTimeWindowedKStream[K, V](
  inner: TimeWindowedKStreamJ[K, V]): TimeWindowedKStream[K, V]

Extends (wraps) a Java-based TimeWindowedKStream with Scala API

results matching ""

    No results matching ""