Class

ai.chronon.online

MetadataStore

Related Doc: package online

Permalink

class MetadataStore extends AnyRef

Linear Supertypes
AnyRef, Any
Known Subclasses
Fetcher, FetcherBase
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MetadataStore
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new MetadataStore(kvStore: KVStore, dataset: String = ChrononMetadataKey, timeoutMillis: Long, executionContextOverride: ExecutionContext = null)

    Permalink

Value Members

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

    Permalink
    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any

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

    Permalink
    Definition Classes
    AnyRef → Any

  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any

  5. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @throws( ... )

  6. val dataset: String

    Permalink

  7. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  8. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  9. implicit val executionContext: ExecutionContext

    Permalink

  10. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate()

  11. def getConf[T <: TBase[_, _]](confPathOrName: String)(implicit arg0: Manifest[T]): Try[T]

    Permalink

  12. def getEntityListByTeam[T <: TBase[_, _]](team: String)(implicit arg0: Manifest[T]): Try[Seq[String]]

    Permalink

  13. lazy val getGroupByListByTeam: TTLCache[String, Try[Seq[String]]]

    Permalink

  14. lazy val getGroupByServingInfo: TTLCache[String, Try[GroupByServingInfoParsed]]

    Permalink

  15. lazy val getJoinConf: TTLCache[String, Try[JoinOps]]

    Permalink

  16. lazy val getJoinListByTeam: TTLCache[String, Try[Seq[String]]]

    Permalink

  17. def getSchemaFromKVStore(dataset: String, key: String): AvroCodec

    Permalink

  18. lazy val getStatsSchemaFromKVStore: TTLCache[(String, String), AvroCodec]

    Permalink

  19. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate()

  20. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any

  21. implicit lazy val logger: Logger

    Permalink

  22. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  23. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate()

  24. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate()

  25. def put(kVPairs: Map[String, Seq[String]], datasetName: String = ChrononMetadataKey, batchSize: Int = CONF_BATCH_SIZE): Future[Seq[Boolean]]

    Permalink

  26. def putJoinConf(join: Join): Unit

    Permalink

  27. def setPartitionMeta(format: String): Unit

    Permalink

  28. def setPartitionMeta(format: String, spanMillis: Long): Unit

    Permalink

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

    Permalink
    Definition Classes
    AnyRef

  30. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any

  31. def validateGroupByExist(team: String, name: String): Boolean

    Permalink

  32. def validateJoinExist(team: String, name: String): Boolean

    Permalink

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

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  34. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  35. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @Deprecated @deprecated @throws( classOf[java.lang.Throwable] )
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

Inherited from AnyRef

Inherited from Any

Ungrouped