object ArrowScan extends LazyLogging
- Alphabetic
- By Inheritance
- ArrowScan
- LazyLogging
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
-
trait
ArrowAggregate extends Result
Trait for aggregating arrow files
-
abstract
class
ArrowResultsToFeatures[T] extends ResultsToFeatures[T]
Converts arrow-encoded results to features
Converts arrow-encoded results to features
- T
result type
- case class ArrowScanConfig(config: Map[String, String], reduce: FeatureReducer) extends Product with Serializable
-
class
DeltaAggregate extends ArrowAggregate
Returns batches of [threading key][dictionary deltas][record batch].
Returns batches of [threading key][dictionary deltas][record batch]. Will sort each batch, but not between batches.
-
class
DeltaReducer extends FeatureReducer
Reduce function for delta batches.
Reduce function for delta batches.
First feature contains metadata for arrow file and dictionary batch, subsequent features contain record batches, final feature contains EOF indicator
Value Members
-
def
configure(sft: SimpleFeatureType, index: GeoMesaFeatureIndex[_, _], stats: GeoMesaStats, filter: Option[Filter], ecql: Option[Filter], hints: Hints): ArrowScanConfig
Configure the iterator
Configure the iterator
- sft
simple feature type
- index
feature index
- stats
stats, used for querying dictionaries
- filter
full filter from the query, if any
- ecql
secondary push down filter, if any
- hints
query hints
-
def
getBatchSize(hints: Hints): Int
Gets the batch size from query hints, or falls back to the system property
Gets the batch size from query hints, or falls back to the system property
- hints
query hints
-
def
resultFeature(): SimpleFeature
Simple feature used for returning from scans
- object Configuration
- object ReducerConfig