Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  def addExtensionFieldsToSchema(schema: StructType, extensions: Array[StacExtension]): StructType

   Adds STAC extension fields to the properties field in the schema

   Adds STAC extension fields to the properties field in the schema

   schema

   The base STAC schema to enhance

   extensions

   Array of STAC extension definitions

   returns

   Enhanced schema with extension fields added to the properties struct

5.  def addFiltersToUrl(baseUrl: String, spatialFilter: Option[GeoParquetSpatialFilter], temporalFilter: Option[TemporalFilter]): String

   Adds the spatial and temporal filters to the base URL.

6.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... ) @native()

8.  final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

9.  def equals(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

10.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

11.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

12.  def getFilterBBox(filter: GeoParquetSpatialFilter): String

    Returns the temporal filter string based on the temporal filter.

13.  def getFilterTemporal(filter: TemporalFilter): String

    Returns the temporal filter string based on the temporal filter.

14.  def getFullCollectionUrl(opts: Map[String, String]): String
15.  def getNumPartitions(itemCount: Int, numPartitions: Int, maxPartitionItemFiles: Int, defaultParallelism: Int): Int

    Returns the number of partitions to use for reading the data.

    Returns the number of partitions to use for reading the data.

    The number of partitions is determined based on the number of items, the number of partitions requested, the maximum number of item files per partition, and the default parallelism.

    itemCount

    The number of items in the collection.

    numPartitions

    The number of partitions requested.

    maxPartitionItemFiles

    The maximum number of item files per partition.

    defaultParallelism

    The default parallelism.

    returns

    The number of partitions to use for reading the data.

16.  def getStacCollectionBasePath(collectionUrl: String): String
17.  def getStacCollectionBasePath(opts: Map[String, String]): String
18.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

19.  def inferStacSchema(opts: Map[String, String]): StructType

    Infer the schema of the STAC data source table.

    Infer the schema of the STAC data source table.

    This method checks if a cached schema exists for the given data source options. If not, it processes the STAC collection and saves it as a GeoJson file. The schema is then inferred from this GeoJson file.

    opts

    Mapping of data source options, which should include either 'url' or 'service'.

    returns

    The inferred schema of the STAC data source table.

    Exceptions thrown

    IllegalArgumentException If neither 'url' nor 'service' are provided.

20.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

21.  def loadStacCollectionToJson(url: String, maxRetries: Int = 3): String
22.  def loadStacCollectionToJson(opts: Map[String, String]): String
23.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

24.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

25.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

26.  def promotePropertiesToTop(row: InternalRow, schema: StructType): InternalRow

    Promote the properties field to the top level of the row.

27.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

28.  def toString(): String

    Definition Classes

    AnyRef → Any

29.  def updatePropertiesPromotedSchema(schema: StructType): StructType
30.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

31.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

32.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... ) @native()