Skip to content

Commit

Permalink
#1437 adress comments
Browse files Browse the repository at this point in the history
  • Loading branch information
Zejnilovic committed Jul 17, 2020
1 parent aa3b968 commit a8cd22d
Showing 1 changed file with 10 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -45,28 +45,28 @@ package object conformanceRule {
outputColumn: String,
controlCheckpoint: Boolean,
inputColumns: Seq[String]) extends ConformanceRule {
override def withUpdatedOrder(newOrder: Int): ConformanceRule = copy(order = newOrder)
override def withUpdatedOrder(newOrder: Int): ConcatenationConformanceRule = copy(order = newOrder)
}

case class CastingConformanceRule(order: Int,
outputColumn: String,
controlCheckpoint: Boolean,
inputColumn: String,
outputDataType: String) extends ConformanceRule {
override def withUpdatedOrder(newOrder: Int): ConformanceRule = copy(order = newOrder)
override def withUpdatedOrder(newOrder: Int): CastingConformanceRule = copy(order = newOrder)
}

case class DropConformanceRule(order: Int,
controlCheckpoint: Boolean,
outputColumn: String) extends ConformanceRule {
override def withUpdatedOrder(newOrder: Int): ConformanceRule = copy(order = newOrder)
override def withUpdatedOrder(newOrder: Int): DropConformanceRule = copy(order = newOrder)
}

case class LiteralConformanceRule(order: Int,
outputColumn: String,
controlCheckpoint: Boolean,
value: String) extends ConformanceRule {
override def withUpdatedOrder(newOrder: Int): ConformanceRule = copy(order = newOrder)
override def withUpdatedOrder(newOrder: Int): LiteralConformanceRule = copy(order = newOrder)
}


Expand All @@ -78,14 +78,14 @@ package object conformanceRule {
targetAttribute: String,
outputColumn: String,
isNullSafe: Boolean = false) extends ConformanceRule {
override def withUpdatedOrder(newOrder: Int): ConformanceRule = copy(order = newOrder)
override def withUpdatedOrder(newOrder: Int): MappingConformanceRule = copy(order = newOrder)
}

case class NegationConformanceRule(order: Int,
outputColumn: String,
controlCheckpoint: Boolean,
inputColumn: String) extends ConformanceRule {
override def withUpdatedOrder(newOrder: Int): ConformanceRule = copy(order = newOrder)
override def withUpdatedOrder(newOrder: Int): NegationConformanceRule = copy(order = newOrder)
}

/**
Expand All @@ -98,7 +98,7 @@ package object conformanceRule {
outputColumn: String,
inputColumn: String,
inputColumnAlias: String) extends ConformanceRule {
override def withUpdatedOrder(newOrder: Int): ConformanceRule = copy(order = newOrder)
override def withUpdatedOrder(newOrder: Int): SingleColumnConformanceRule = copy(order = newOrder)
}

/**
Expand All @@ -112,22 +112,22 @@ package object conformanceRule {
outputColumn: String,
controlCheckpoint: Boolean,
sparkConfKey: String) extends ConformanceRule {
override def withUpdatedOrder(newOrder: Int): ConformanceRule = copy(order = newOrder)
override def withUpdatedOrder(newOrder: Int): SparkSessionConfConformanceRule = copy(order = newOrder)
}

case class UppercaseConformanceRule(order: Int,
outputColumn: String,
controlCheckpoint: Boolean,
inputColumn: String) extends ConformanceRule {
override def withUpdatedOrder(newOrder: Int): ConformanceRule = copy(order = newOrder)
override def withUpdatedOrder(newOrder: Int): UppercaseConformanceRule = copy(order = newOrder)
}

case class FillNullsConformanceRule(order: Int,
outputColumn: String,
controlCheckpoint: Boolean,
inputColumn: String,
value: String) extends ConformanceRule {
override def withUpdatedOrder(newOrder: Int): ConformanceRule = copy(order = newOrder)
override def withUpdatedOrder(newOrder: Int): FillNullsConformanceRule = copy(order = newOrder)
}

abstract class ExtensibleConformanceRule() extends ConformanceRule
Expand Down

0 comments on commit a8cd22d

Please sign in to comment.