Packages

package impl

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package decoders

Type Members

  1. class NoOpSink[T] extends Sink[T]

    A simple no-op Sink v2 that discards all elements.

  2. case class PartData(partId: String, startVersion: Long, endVersion: Long) extends Product with Serializable
  3. case class PartVersionState(partId: Option[String], startVersion: Long, endVersion: Long) extends Product with Serializable
  4. case class PartitionIdsFilter(ids: Set[String], filter: VolatilePartitionsFilter) extends Product with Serializable
  5. case class PartitionVersionState(partition: Option[String], version: Long) extends Product with Serializable
  6. 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
  7. class QueryVersionPartitionsSource extends Source[QueryNotification, QueryVersionPartitionsSplit, Collection[QueryVersionPartitionsSplit]]

    FLIP-27 source for continuous versioned layer reading with notification subscription.

  8. case class QueryVersionPartitionsSplit(versionState: Option[PartitionVersionState] = None) extends SourceSplit with Serializable with Product
  9. class QueryVersionPartsSource extends Source[PartData, QueryVersionPartsSplit, Collection[QueryVersionPartsSplit]]

    FLIP-27 source for continuous versioned layer part data reading.

  10. case class QueryVersionPartsSplit(versionState: Option[PartVersionState] = None) extends SourceSplit with Serializable with Product
  11. class RowToRowDataConverterMapFunction extends RichMapFunction[Row, RowData]
  12. case class StreamLayerRowSplit(subtaskIndex: Int) extends SourceSplit with Serializable with Product

Value Members

  1. object ContinuousSourceUtils

    Shared FLIP-27 Source utilities for continuous (unbounded) polling sources that carry a timestamp as checkpoint state.

    Shared FLIP-27 Source utilities for continuous (unbounded) polling sources that carry a timestamp as checkpoint state.

    Used by QueryIndexPartitionsSource, QueryVolatilePartitionsSource, QueryVolatilePartitionsIdsSource, IndexPartsSource, ImlQuadKeysSource, ImlFeatureIdsSource.

  2. object GeometryHelper
  3. object LayerHelper
  4. object PojoConverter
  5. object SingleSplitSourceUtils

    Shared FLIP-27 Source utilities for bounded (one-shot) sources.

    Shared FLIP-27 Source utilities for bounded (one-shot) sources.

    These are used by QueryApiSource, QueryApiPartsSource, AdminApiSource and similar bounded sources that produce a finite set of elements from a single logical split.

Ungrouped