package sinks
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- trait Sink[F[_]] extends AnyRef
A common interface over the external sinks that Snowplow can write to
A common interface over the external sinks that Snowplow can write to
Implementations of this trait are provided by the sinks library (e.g. kinesis, kafka, pubsub)
- case class Sinkable(bytes: Array[Byte], partitionKey: Option[String], attributes: Map[String, String]) extends Product with Serializable
A single event that can be written to the external sink
A single event that can be written to the external sink
- bytes
the serialized content of this event
- partitionKey
optionally controls which partition the event is written to
- attributes
optionally add attributes/headers to the event, if the sink supports this feature