diff --git a/modules/core/src/test/scala/uk/co/odinconsultants/ChangeDataFlowSpec.scala b/modules/core/src/test/scala/uk/co/odinconsultants/ChangeDataFlowSpec.scala index df7f3cf..ecb5d9a 100644 --- a/modules/core/src/test/scala/uk/co/odinconsultants/ChangeDataFlowSpec.scala +++ b/modules/core/src/test/scala/uk/co/odinconsultants/ChangeDataFlowSpec.scala @@ -5,8 +5,6 @@ import org.scalatest.GivenWhenThen import org.scalatest.matchers.should.Matchers._ import uk.co.odinconsultants.documentation_utils.{SpecPretifier, TableNameFixture} -import java.io.ByteArrayOutputStream - class ChangeDataFlowSpec extends SpecPretifier with GivenWhenThen with TableNameFixture { info( @@ -63,14 +61,6 @@ class ChangeDataFlowSpec extends SpecPretifier with GivenWhenThen with TableName ) } } - - def captureOutputOf[T](thunk: => T): String = { - val out = new ByteArrayOutputStream() - Console.withOut(out) { - thunk - } - new String(out.toByteArray) - } } object ChangeDataFlowSpec { diff --git a/modules/core/src/test/scala/uk/co/odinconsultants/MergingDataSpec.scala b/modules/core/src/test/scala/uk/co/odinconsultants/MergingDataSpec.scala index 55e7e02..0a8b3f2 100644 --- a/modules/core/src/test/scala/uk/co/odinconsultants/MergingDataSpec.scala +++ b/modules/core/src/test/scala/uk/co/odinconsultants/MergingDataSpec.scala @@ -48,20 +48,6 @@ class MergingDataSpec extends SpecPretifier with GivenWhenThen with TableNameFix } } - def histogram[K, V](kv: Map[K, V], names: Seq[String]): String = { - val width = (kv.keys.map(_.toString.length) ++ names.map(_.length)).max + 2 - Seq(columnNames(names, width), histogramValues(kv, width)).mkString("\n") - } - - def columnNames(names: Seq[String], width: Int = 20): String = { - val cols = names.map(x => s"%-${width}s".format(x)).mkString("") - val lines = names.map(x => s"%-${width}s".format("-" * x.length)).mkString("") - Seq(cols, lines).mkString("\n") - } - - def histogramValues[K, V](kv: Map[K, V], width: Int = 20): String = - kv.map { case (k, v) => s"%-${width}s%s".format(k, v) }.mkString("\n") - private def partitionKeyToCount( data: Seq[Datum] ): Map[Long, Int] = diff --git a/project/Dependencies.scala b/project/Dependencies.scala index 0c98fd5..a12334c 100644 --- a/project/Dependencies.scala +++ b/project/Dependencies.scala @@ -13,7 +13,7 @@ object Dependencies { val hadoopAws = "3.3.1" val minio = "8.5.5" val deltaLake = "3.0.0" - val documentationUtils = "0.8" + val documentationUtils = "0.11" val scalaTest = "3.2.17" }