Packages

package sink

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. abstract class BaseKafkaSinkFactory extends SinkFactory
  2. case class GenericJsonSerialization(topic: String) extends SimpleSerializationSchema[AnyRef] with Product with Serializable
  3. class KafkaSinkFactory extends BaseKafkaSinkFactory
  4. trait KafkaSinkImplFactory extends AnyRef

Value Members

  1. object GenericJsonSerialization extends Serializable

Ungrouped