Packages

package config

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. case class DateTimeRange(startTime: LocalDateTime, endTime: LocalDateTime) extends Product with Serializable
  2. case class FeathrConfig(sources: Option[Map[String, DataSource]], anchors: Map[String, FeatureAnchor], derivationsArg: Option[Map[String, DerivedFeature]], multiDerivationsArg: Option[Seq[DerivedFeature]]) extends Product with Serializable

    FeathrConfig consists of anchor and derived feature definitions.

    FeathrConfig consists of anchor and derived feature definitions.

    sources

    optional map of sources, the key are the source names; the value is the source definition

    anchors

    map of feature anchors. the keys are the anchor names (currently unused, but must be unique)

    derivationsArg

    optional map of feature derivations. the keys are the feature names; the value for a given key is the derivation for that feature name

  3. class FeatureDefinitionDeserializer extends JsonDeserializer[FeatureDefinition]
  4. case class FeatureJoinConfig(groups: Map[String, Seq[KeyedFeatureList]], settings: Option[JoinConfigSettings] = None) extends Product with Serializable

    Configures the FeatureJoinJob

    Configures the FeatureJoinJob

    Annotations
    @JsonDeserialize()
  5. case class FeatureJoinConfigSettings(timeWindowJoinSetting: Option[TimeWindowJoinConfigSettingDefinition], observationTimeConfigSettingDefinition: Option[ObsTimeConfigSetting] = None) extends Product with Serializable
  6. case class KeyedFeatureList(key: Seq[String], featureList: Seq[String], startDate: Option[String] = None, endDate: Option[String] = None, dateOffset: Option[String] = None, numDays: Option[String] = None, overrideTimeDelay: Option[String] = None, featureAlias: Option[String] = None) extends Product with Serializable
  7. class SQLFeatureDefinitionDeserializer extends JsonDeserializer[SQLFeatureDefinition]
  8. case class TimeWindowFeatureDefinition(def: String, aggregationType: swj.aggregate.AggregationType.Value, window: Duration, groupBy: Option[String], limit: Option[Int], filter: Option[String], decay: Option[String], weight: Option[String], normalization: Option[String], decayAgg: Option[String], topKSetting: Option[String], embeddingSize: Option[Int], featureTypeConfig: Option[FeatureTypeConfig] = Option.empty, columnFormat: FeatureColumnFormat = FeatureColumnFormat.RAW) extends Product with Serializable
    Annotations
    @JsonDeserialize()
  9. class TimeWindowFeatureDefinitionDeserializer extends JsonDeserializer[TimeWindowFeatureDefinition]
  10. case class TimeWindowJoinConfigSettingDefinition(timestamp: String, timestamp_format: String, dateTimeRange: Option[DateTimeRange], simulate_time_delay: Map[String, Duration], useLatestFeatureData: Option[Boolean] = None, localTestJoinJob: Boolean = false) extends Product with Serializable
    Annotations
    @JsonDeserialize()
  11. class TimeWindowJoinConfigSettingDefinitionDeserializer extends JsonDeserializer[TimeWindowJoinConfigSettingDefinition]

Value Members

  1. object FeatureJoinConfig extends Serializable
  2. object KeyedFeatureList extends Serializable

Ungrouped