final case class RowCountMetricConfig(id: ID, description: Option[NonEmptyString], source: NonEmptyString, metadata: Seq[SparkParam] = Seq.empty) extends RegularMetricConfig with Product with Serializable
Row count metric configuration
- id
Metric ID
- description
Metric description
- source
Source ID over which metric is being calculated
- metadata
List of metadata parameters specific to this metric
- Alphabetic
- By Inheritance
- RowCountMetricConfig
- Product
- Equals
- RegularMetricConfig
- RegularMetric
- MetricConfig
- JobConfigEntity
- Serializable
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
RowCountMetricConfig(id: ID, description: Option[NonEmptyString], source: NonEmptyString, metadata: Seq[SparkParam] = Seq.empty)
- id
Metric ID
- description
Metric description
- source
Source ID over which metric is being calculated
- metadata
List of metadata parameters specific to this metric
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
val
description: Option[NonEmptyString]
- Definition Classes
- RowCountMetricConfig → JobConfigEntity
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
val
id: ID
- Definition Classes
- RowCountMetricConfig → JobConfigEntity
-
def
initDFMetricCalculator(columns: Seq[String]): DFMetricCalculator
Inits DF metric calculator.
Inits DF metric calculator.
- columns
Sequence of columns this metric refers to.
- returns
Initial state of DF metric calculator.
- Definition Classes
- RowCountMetricConfig → RegularMetric
- Note
It is allowed to use
*in order to refer all source columns. In this case value of metricColumns will be the sequence with only one element:*. It is required to expand the star with actual list of source columns. But that information will only be available during metric processing after the source metadata is being retrieved. Thus, the expansion of*will be performed during metric processing and DF metric calculator will be initialized with actual list of source columns passed ascolumnsargument.
-
def
initRDDMetricCalculator: RDDMetricCalculator
Inits RDD metric calculator.
Inits RDD metric calculator.
- returns
Initial state of RDD metric calculator.
- Definition Classes
- RowCountMetricConfig → RegularMetric
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
val
metadata: Seq[SparkParam]
- Definition Classes
- RowCountMetricConfig → JobConfigEntity
-
val
metadataString: Option[String]
- Definition Classes
- JobConfigEntity
-
val
metricColumns: Seq[String]
- Definition Classes
- RowCountMetricConfig → RegularMetricConfig → RegularMetric
-
val
metricId: String
- Definition Classes
- MetricConfig
-
val
metricName: MetricName
- Definition Classes
- RowCountMetricConfig → RegularMetric
-
val
metricSource: String
- Definition Classes
- RegularMetricConfig → RegularMetric
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
val
paramString: Option[String]
- Definition Classes
- RowCountMetricConfig → RegularMetricConfig
-
val
source: NonEmptyString
- Definition Classes
- RowCountMetricConfig → RegularMetricConfig
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()