diff --git a/online/src/main/scala/ai/chronon/online/FetcherBase.scala b/online/src/main/scala/ai/chronon/online/FetcherBase.scala index cd384188b..919e82881 100644 --- a/online/src/main/scala/ai/chronon/online/FetcherBase.scala +++ b/online/src/main/scala/ai/chronon/online/FetcherBase.scala @@ -43,14 +43,7 @@ class FetcherBase(kvStore: KVStore, timeoutMillis: Long = 10000, debug: Boolean = false) extends MetadataStore(kvStore, metaDataSet, timeoutMillis) { - - private case class GroupByRequestMeta( - groupByServingInfoParsed: GroupByServingInfoParsed, - batchRequest: GetRequest, - streamingRequestOpt: Option[GetRequest], - endTs: Option[Long], - context: Metrics.Context - ) + import FetcherBase._ // a groupBy request is split into batchRequest and optionally a streamingRequest // this method decodes bytes (of the appropriate avro schema) into chronon rows aggregates further if necessary @@ -495,3 +488,13 @@ class FetcherBase(kvStore: KVStore, } } } + +object FetcherBase { + private[online] case class GroupByRequestMeta( + groupByServingInfoParsed: GroupByServingInfoParsed, + batchRequest: GetRequest, + streamingRequestOpt: Option[GetRequest], + endTs: Option[Long], + context: Metrics.Context + ) +}