Packages

package scaladsl

Type Members

  1. 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).

  2. 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

  3. trait IndexDataConverter extends DataConverter
  4. 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
  5. trait RowMetadata extends AnyRef
  6. 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

  7. trait VersionedDataConverter extends DataConverter
  8. 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
  9. trait VolatileDataConverter extends DataConverter
  10. 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

Ungrouped