Packages

package impl

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. case class PartData(partId: String, startVersion: Long, endVersion: Long) extends Product with Serializable
  2. case class PartVersionState(partId: Option[String], startVersion: Long, endVersion: Long) extends Product with Serializable
  3. case class PartitionIdsFilter(ids: Set[String], filter: VolatilePartitionsFilter) extends Product with Serializable
  4. case class PartitionVersionState(partition: Option[String], version: Long) extends Product with Serializable
  5. case class QueryNotification(parsedQueryOpt: Option[ParsedQuery], initial: List[(Option[String], Long)], versionState: Option[PartitionVersionState], notificationOpt: Option[BatchPublicationNotification] = None, idsForSubscription: Seq[String] = Seq.empty[String], latestCompletedVersion: Option[Long] = None) extends Product with Serializable
  6. class QueryVersionPartitionsSource extends RichSourceFunction[QueryNotification] with CheckpointedFunction
  7. class QueryVersionPartsSource extends RichSourceFunction[PartData] with CheckpointedFunction
  8. class RowToRowDataConverterMapFunction extends RichMapFunction[Row, RowData]

Value Members

  1. object GeometryHelper
  2. object LayerHelper
  3. object PojoConverter

Ungrouped