Fetcher

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

val batchIrCacheName: String

def buildJoinCodec(joinConf: Join, refreshOnFail: Boolean): (JoinCodec, Boolean)

val caffeineMetricsContext: Context

def clone(): AnyRef

val dataset: String

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

implicit val executionContext: ExecutionContext

val externalSourceRegistry: ExternalSourceRegistry

def fetchBaseJoin(requests: Seq[Request], joinConf: Option[Join]): Future[Seq[ResponseWithContext]]

def fetchColumns(columnSpecs: Seq[ColumnSpec]): Future[Map[ColumnSpec, Response]]

Fetch method to simulate a random access interface for Chronon by distributing requests to relevant GroupBys.

def fetchConsistencyMetricsTimeseries(joinRequest: StatsRequest): Future[SeriesStatsResponse]

Main endpoint for fetching OOC metrics stats or drifts.

def fetchExternal(joinRequests: Seq[Request], joinConf: Option[Join] = None): Future[Seq[Response]]

def fetchGroupBys(requests: Seq[Request]): Future[Seq[Response]]

def fetchJoin(requests: Seq[Request], joinConf: Option[Join] = None): Future[Seq[Response]]

def fetchJoinChunked(requests: Seq[Request], chunkSizeOverride: Int, joinConf: Option[Join] = None): Seq[Future[Seq[Response]]]

def fetchLogStatsTimeseries(joinRequest: StatsRequest): Future[SeriesStatsResponse]

Main endpoint for fetching logging stats or drifts.

def fetchModelTransforms(derivedValuesFuture: Future[Seq[ResponseWithContext]]): Future[Seq[ResponseWithContext]]

def fetchStatsTimeseries(joinRequest: StatsRequest): Future[SeriesStatsResponse]

Main endpoint for fetching backfill tables stats or drifts.

def getCachedRequests(groupByRequestToKvRequest: Seq[(Request, Try[GroupByRequestMeta])]): Map[GetRequest, CachedBatchResponse]

Given a list of GetRequests, return a map of GetRequests to cached FinalBatchIrs.

final def getClass(): Class[_]

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

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

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

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

lazy val getJoinCodecs: TTLCache[String, Try[(JoinCodec, Boolean)]]

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

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

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

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

def hashCode(): Int

def instrumentAndLog(modelTransformsF: Future[Seq[ResponseWithContext]]): Future[Seq[Response]]

def isCacheSizeConfigured: Boolean

def isCachingEnabled(groupBy: GroupBy): Boolean

def isEntityValidityCheckEnabled: Boolean

final def isInstanceOf[T0]: Boolean

val kvStore: KVStore

implicit lazy val logger: Logger

val maybeBatchIrCache: Option[BatchIrCache]

val modelBackend: ModelBackend

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def parseGroupByResponse(prefix: String, groupByRequest: Request, responseMap: Map[Request, Try[Map[String, AnyRef]]]): Map[String, AnyRef]

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

def putJoinConf(join: Join): Unit

def reportKvResponse(ctx: Context, response: Seq[TimedValue], queryTsMillis: Long, latencyMillis: Long, totalResponseBytes: Int): Unit

def setPartitionMeta(format: String): Unit

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

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

def toBatchIr(bytes: Array[Byte], gbInfo: GroupByServingInfoParsed): FinalBatchIr

Convert an array of bytes to a FinalBatchIr.

def toString(): String

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

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

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

final def wait(arg0: Long): Unit

final def wait(): Unit

def finalize(): Unit