package scaladsl
Type Members
-
trait
DataConverter extends Serializable
User may provide a
DataConverter
implementation 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
GroupedData
contains 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
SerializableField
describes any metadata field (versioned or index layer related).SerializableField
describes 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