package scaladsl
Type Members
- trait DataConverter extends Serializable
User may provide a
DataConverterimplementation to specify how data which has been grouped can be aggregated into a single data file (byte array). - case class GroupedData[M <: RowMetadata](rowMetadata: M, data: Array[Byte]) extends Product with Serializable
GroupedDatacontains the aggregated data for the given set of fields - trait IndexDataConverter extends DataConverter
- case class IndexRowMetadata(indexes: Array[SerializableField] = Array.empty, metadata: Option[Map[String, String]] = None, timestamp: Option[Long] = None, checksum: Option[String] = None, crc: Option[String] = None, dataSize: Option[Long] = None, compressedDataSize: Option[Long] = None) extends RowMetadata with Product with Serializable
- trait RowMetadata extends AnyRef
- case class SerializableField(fieldName: String, fieldType: String, fieldValue: String) extends Product with Serializable
SerializableFielddescribes any metadata field (versioned or index layer related).SerializableFielddescribes any metadata field (versioned or index layer related). For example, for versioned layer it could represent the partitionId and for index layer it could represent any of the user defined index attributes - trait VersionedDataConverter extends DataConverter
- case class VersionedRowMetadata(partition: Option[String], timestamp: Option[Long] = None, checksum: Option[String] = None, crc: Option[String] = None, dataSize: Option[Long] = None, compressedDataSize: Option[Long] = None, dataHandle: Option[String] = None) extends RowMetadata with Product with Serializable
- trait VolatileDataConverter extends DataConverter
- case class VolatileRowMetadata(partition: Option[String], checksum: Option[String] = None, crc: Option[String] = None, dataSize: Option[Long] = None, compressedDataSize: Option[Long] = None) extends RowMetadata with Product with Serializable