From eacf42fa006a3f2914842e67a927f49f56c65d5e Mon Sep 17 00:00:00 2001 From: Caio Camatta Date: Mon, 12 Feb 2024 16:07:01 -0500 Subject: [PATCH] Move GroupByRequestMeta to object --- .../scala/ai/chronon/online/FetcherBase.scala | 19 +++++++++++-------- 1 file changed, 11 insertions(+), 8 deletions(-) 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 + ) +}