Skip to content

Commit dc8fdf3

Browse files
tchow-zlaithomaschow
tchow-zlai
and
thomaschow
committed
relocate
Co-authored-by: Thomas Chow <[email protected]>
1 parent 3f8b633 commit dc8fdf3

File tree

3 files changed

+20
-40
lines changed

3 files changed

+20
-40
lines changed

‎spark/src/main/scala/ai/chronon/spark/scripts/DataServer.scala renamed to ‎spark/src/main/scala/ai/chronon/spark/stats/DataServer.scala

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,9 @@
1-
package ai.chronon.spark.scripts
1+
package ai.chronon.spark.stats
22

33
import ai.chronon.api.SerdeUtils
44
import ai.chronon.api.thrift.TBase
5-
import ai.chronon.observability.TileDriftSeries
6-
import ai.chronon.observability.TileSeriesKey
7-
import ai.chronon.observability.TileSummarySeries
8-
import ai.chronon.online.stats.DriftStore
9-
import com.fasterxml.jackson.databind.ObjectMapper
10-
import com.fasterxml.jackson.databind.SerializationFeature
5+
import ai.chronon.observability.{TileDriftSeries, TileSeriesKey, TileSummarySeries}
6+
import com.fasterxml.jackson.databind.{ObjectMapper, SerializationFeature}
117
import com.fasterxml.jackson.module.scala.DefaultScalaModule
128
import io.netty.bootstrap.ServerBootstrap
139
import io.netty.buffer.Unpooled

‎spark/src/main/scala/ai/chronon/spark/scripts/ObservabilityDemo.scala renamed to ‎spark/src/main/scala/ai/chronon/spark/stats/ObservabilityDemo.scala

Lines changed: 10 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -1,34 +1,24 @@
1-
package ai.chronon.spark.scripts
1+
package ai.chronon.spark.stats
22

33
import ai.chronon
44
import ai.chronon.api.ColorPrinter.ColorString
5-
import ai.chronon.api.Constants
6-
import ai.chronon.api.Extensions.MetadataOps
7-
import ai.chronon.api.Extensions.WindowOps
8-
import ai.chronon.api.PartitionSpec
5+
import ai.chronon.api.Extensions.{MetadataOps, WindowOps}
96
import ai.chronon.api.ScalaJavaConversions._
10-
import ai.chronon.api.Window
11-
import ai.chronon.observability.DriftMetric
12-
import ai.chronon.observability.TileDriftSeries
13-
import ai.chronon.observability.TileSummarySeries
7+
import ai.chronon.api.{Constants, PartitionSpec, Window}
8+
import ai.chronon.observability.{DriftMetric, TileDriftSeries, TileSummarySeries}
149
import ai.chronon.online.KVStore
1510
import ai.chronon.online.stats.DriftStore
16-
import ai.chronon.spark.SparkSessionBuilder
17-
import ai.chronon.spark.TableUtils
18-
import ai.chronon.spark.stats.drift.Summarizer
19-
import ai.chronon.spark.stats.drift.SummaryUploader
11+
import ai.chronon.spark.{SparkSessionBuilder, TableUtils}
12+
import ai.chronon.spark.stats.drift.{Summarizer, SummaryUploader}
2013
import ai.chronon.spark.stats.drift.scripts.PrepareData
21-
import ai.chronon.spark.utils.InMemoryKvStore
22-
import ai.chronon.spark.utils.MockApi
23-
import org.rogach.scallop.ScallopConf
24-
import org.rogach.scallop.ScallopOption
25-
import org.slf4j.Logger
26-
import org.slf4j.LoggerFactory
14+
import ai.chronon.spark.utils.{InMemoryKvStore, MockApi}
15+
import org.rogach.scallop.{ScallopConf, ScallopOption}
16+
import org.slf4j.{Logger, LoggerFactory}
2717

2818
import java.util.concurrent.TimeUnit
19+
import scala.collection.Seq
2920
import scala.concurrent.Await
3021
import scala.concurrent.duration.Duration
31-
import scala.collection.Seq
3222

3323
object ObservabilityDemo {
3424
@transient lazy val logger: Logger = LoggerFactory.getLogger(getClass)

‎spark/src/main/scala/ai/chronon/spark/scripts/ObservabilityDemoDataLoader.scala renamed to ‎spark/src/main/scala/ai/chronon/spark/stats/ObservabilityDemoDataLoader.scala

Lines changed: 7 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -1,21 +1,15 @@
1-
package ai.chronon.spark.scripts
1+
package ai.chronon.spark.stats
22

33
import ai.chronon.api.ColorPrinter.ColorString
44
import ai.chronon.api.Constants
55
import ai.chronon.api.Extensions.MetadataOps
6-
import ai.chronon.online.HTTPKVStore
7-
import ai.chronon.online.KVStore
8-
import ai.chronon.spark.SparkSessionBuilder
9-
import ai.chronon.spark.TableUtils
10-
import ai.chronon.spark.stats.drift.Summarizer
11-
import ai.chronon.spark.stats.drift.SummaryUploader
6+
import ai.chronon.online.{HTTPKVStore, KVStore}
7+
import ai.chronon.spark.{SparkSessionBuilder, TableUtils}
8+
import ai.chronon.spark.stats.drift.{Summarizer, SummaryUploader}
129
import ai.chronon.spark.stats.drift.scripts.PrepareData
13-
import ai.chronon.spark.utils.InMemoryKvStore
14-
import ai.chronon.spark.utils.MockApi
15-
import org.rogach.scallop.ScallopConf
16-
import org.rogach.scallop.ScallopOption
17-
import org.slf4j.Logger
18-
import org.slf4j.LoggerFactory
10+
import ai.chronon.spark.utils.{InMemoryKvStore, MockApi}
11+
import org.rogach.scallop.{ScallopConf, ScallopOption}
12+
import org.slf4j.{Logger, LoggerFactory}
1913

2014
object ObservabilityDemoDataLoader {
2115
@transient lazy val logger: Logger = LoggerFactory.getLogger(getClass)

0 commit comments

Comments
 (0)