Packages

class TimePartition extends TablePartition

Partition by time period. Partitions consist of 0-padded 5-digit strings

Linear Supertypes
TablePartition, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TimePartition
  2. TablePartition
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new TimePartition(metadata: GeoMesaMetadata[String], typeName: String, dtg: String, dtgIndex: Int, period: TimePeriod)

    metadata

    used for registering outside tables for query

    typeName

    simple feature type name

    dtg

    date attribute

    dtgIndex

    date attribute index

    period

    time period

Value Members

  1. def partition(feature: SimpleFeature): String

    Get the partition for a given feature

    Get the partition for a given feature

    feature

    simple feature

    Definition Classes
    TimePartition → TablePartition
  2. def partitions(filter: Filter): Option[Seq[String]]

    Gets the partitions that intersect a given filter.

    Gets the partitions that intersect a given filter. If partitions can't be determined, (e.g. if the filter doesn't have a predicate on the partition), then an empty option is returned

    filter

    filter

    returns

    partitions, or an empty option representing all partitions

    Definition Classes
    TimePartition → TablePartition
  3. def recover(partition: String): AnyRef

    Convert from a partition back to a partition-able value

    Convert from a partition back to a partition-able value

    partition

    partition

    Definition Classes
    TimePartition → TablePartition
  4. def register(partition: String, start: ZonedDateTime, end: ZonedDateTime): Unit

    Register a new partition

    Register a new partition

    partition

    partition name

    start

    start time for the partition

    end

    end time for the partition