Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
alextheimer committed Apr 9, 2022
1 parent 7f4393f commit 6604f5d
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 4 deletions.
2 changes: 0 additions & 2 deletions core/src/test/scala/filodb.core/TestData.scala
Original file line number Diff line number Diff line change
Expand Up @@ -548,10 +548,8 @@ object MetricsTestData {
}
}

// Routes input records to the dataset schema correctly
def records(ds: Dataset, readerSeq: Seq[RowReader]): SomeData = {
val builder = new RecordBuilder(MemFactory.onHeapFactory)
//val routing = ds.schema.ingestRouting(columnNames)
readerSeq.foreach { row => builder.addFromReader(row, ds.schema) }
builder.allContainers.zipWithIndex.map { case (container, i) => SomeData(container, i) }.head
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -384,8 +384,7 @@ class DownsamplerMainSpec extends AnyFunSpec with Matchers with BeforeAndAfterAl
it("should simulate bulk part key records being written into raw for migration") {
val partBuilder = new RecordBuilder(offheapMem.nativeMemoryManager)
val schemaSeq = Seq(Schemas.promHistogram, Schemas.gauge, Schemas.promCounter)
// TODO(a_theimer): remove this?
val dummySchemas = Schemas(Schemas.untyped)
val dummySchemas = Schemas(Schemas.untyped) // doesn't matter for the sake of this test
case class PkToWrite(pkr: PartKeyRecord, shard: Int, updateHour: Long)
val pks = for { i <- 0 to 10000 } yield {
val schema = schemaSeq(i % schemaSeq.size)
Expand Down

0 comments on commit 6604f5d

Please sign in to comment.