Path	Lines of Code
measure/src/main/scala/org/apache/griffin/measure/Application.scala	91
measure/src/main/scala/org/apache/griffin/measure/Loggable.scala	31
measure/src/main/scala/org/apache/griffin/measure/configuration/dqdefinition/DQConfig.scala	213
measure/src/main/scala/org/apache/griffin/measure/configuration/dqdefinition/EnvConfig.scala	75
measure/src/main/scala/org/apache/griffin/measure/configuration/dqdefinition/GriffinConfig.scala	17
measure/src/main/scala/org/apache/griffin/measure/configuration/dqdefinition/Param.scala	4
measure/src/main/scala/org/apache/griffin/measure/configuration/dqdefinition/reader/ParamFileReader.scala	15
measure/src/main/scala/org/apache/griffin/measure/configuration/dqdefinition/reader/ParamHttpReader.scala	16
measure/src/main/scala/org/apache/griffin/measure/configuration/dqdefinition/reader/ParamJsonReader.scala	13
measure/src/main/scala/org/apache/griffin/measure/configuration/dqdefinition/reader/ParamReader.scala	12
measure/src/main/scala/org/apache/griffin/measure/configuration/dqdefinition/reader/ParamReaderFactory.scala	24
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/DqType.scala	13
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/DslType.scala	13
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/FlattenType.scala	16
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/GriffinEnum.scala	9
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/MeasureTypes.scala	8
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/OutputType.scala	15
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/ProcessType.scala	7
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/SinkType.scala	22
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/WriteMode.scala	12
measure/src/main/scala/org/apache/griffin/measure/context/ContextId.scala	6
measure/src/main/scala/org/apache/griffin/measure/context/DQContext.scala	65
measure/src/main/scala/org/apache/griffin/measure/context/DataFrameCache.scala	40
measure/src/main/scala/org/apache/griffin/measure/context/MetricWrapper.scala	41
measure/src/main/scala/org/apache/griffin/measure/context/TableRegister.scala	40
measure/src/main/scala/org/apache/griffin/measure/context/TimeRange.scala	28
measure/src/main/scala/org/apache/griffin/measure/context/streaming/checkpoint/lock/CheckpointLock.scala	7
measure/src/main/scala/org/apache/griffin/measure/context/streaming/checkpoint/lock/CheckpointLockInZK.scala	26
measure/src/main/scala/org/apache/griffin/measure/context/streaming/checkpoint/lock/CheckpointLockSeq.scala	10
measure/src/main/scala/org/apache/griffin/measure/context/streaming/checkpoint/offset/OffsetCheckpoint.scala	14
measure/src/main/scala/org/apache/griffin/measure/context/streaming/checkpoint/offset/OffsetCheckpointClient.scala	31
measure/src/main/scala/org/apache/griffin/measure/context/streaming/checkpoint/offset/OffsetCheckpointFactory.scala	18
measure/src/main/scala/org/apache/griffin/measure/context/streaming/checkpoint/offset/OffsetCheckpointInZK.scala	170
measure/src/main/scala/org/apache/griffin/measure/context/streaming/checkpoint/offset/OffsetOps.scala	97
measure/src/main/scala/org/apache/griffin/measure/context/streaming/metric/AccuracyMetric.scala	22
measure/src/main/scala/org/apache/griffin/measure/context/streaming/metric/CacheResults.scala	40
measure/src/main/scala/org/apache/griffin/measure/context/streaming/metric/Metric.scala	9
measure/src/main/scala/org/apache/griffin/measure/datasource/DataSource.scala	68
measure/src/main/scala/org/apache/griffin/measure/datasource/DataSourceFactory.scala	52
measure/src/main/scala/org/apache/griffin/measure/datasource/TimestampStorage.scala	15
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/DataConnector.scala	67
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/DataConnectorFactory.scala	125
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/batch/AvroBatchDataConnector.scala	39
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/batch/BatchDataConnector.scala	5
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/batch/CassandraDataConnector.scala	61
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/batch/ElasticSearchDataConnector.scala	54
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/batch/ElasticSearchGriffinDataConnector.scala	154
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/batch/FileBasedDataConnector.scala	121
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/batch/HiveBatchDataConnector.scala	42
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/batch/JDBCBasedDataConnector.scala	86
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/batch/MySqlDataConnector.scala	60
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/batch/TextDirBatchDataConnector.scala	69
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/streaming/KafkaStreamingDataConnector.scala	45
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/streaming/KafkaStreamingStringDataConnector.scala	42
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/streaming/StreamingDataConnector.scala	17
measure/src/main/scala/org/apache/griffin/measure/execution/Measure.scala	59
measure/src/main/scala/org/apache/griffin/measure/execution/MeasureExecutor.scala	154
measure/src/main/scala/org/apache/griffin/measure/execution/impl/AccuracyMeasure.scala	115
measure/src/main/scala/org/apache/griffin/measure/execution/impl/CompletenessMeasure.scala	38
measure/src/main/scala/org/apache/griffin/measure/execution/impl/DuplicationMeasure.scala	80
measure/src/main/scala/org/apache/griffin/measure/execution/impl/ProfilingMeasure.scala	127
measure/src/main/scala/org/apache/griffin/measure/execution/impl/SchemaConformanceMeasure.scala	59
measure/src/main/scala/org/apache/griffin/measure/execution/impl/SparkSQLMeasure.scala	43
measure/src/main/scala/org/apache/griffin/measure/job/DQJob.scala	16
measure/src/main/scala/org/apache/griffin/measure/job/builder/DQJobBuilder.scala	22
measure/src/main/scala/org/apache/griffin/measure/launch/DQApp.scala	33
measure/src/main/scala/org/apache/griffin/measure/launch/batch/BatchDQApp.scala	72
measure/src/main/scala/org/apache/griffin/measure/launch/streaming/StreamingDQApp.scala	165
measure/src/main/scala/org/apache/griffin/measure/sink/ConsoleSink.scala	34
measure/src/main/scala/org/apache/griffin/measure/sink/ElasticSearchSink.scala	45
measure/src/main/scala/org/apache/griffin/measure/sink/HdfsSink.scala	126
measure/src/main/scala/org/apache/griffin/measure/sink/MongoSink.scala	79
measure/src/main/scala/org/apache/griffin/measure/sink/Sink.scala	17
measure/src/main/scala/org/apache/griffin/measure/sink/SinkFactory.scala	53
measure/src/main/scala/org/apache/griffin/measure/sink/SinkTaskRunner.scala	69
measure/src/main/scala/org/apache/griffin/measure/step/DQStep.scala	15
measure/src/main/scala/org/apache/griffin/measure/step/SeqDQStep.scala	23
measure/src/main/scala/org/apache/griffin/measure/step/builder/BatchDataSourceStepBuilder.scala	9
measure/src/main/scala/org/apache/griffin/measure/step/builder/ConstantColumns.scala	13
measure/src/main/scala/org/apache/griffin/measure/step/builder/DQStepBuilder.scala	53
measure/src/main/scala/org/apache/griffin/measure/step/builder/DQStepNameGenerator.scala	12
measure/src/main/scala/org/apache/griffin/measure/step/builder/DataSourceParamStepBuilder.scala	19
measure/src/main/scala/org/apache/griffin/measure/step/builder/GriffinDslDQStepBuilder.scala	33
measure/src/main/scala/org/apache/griffin/measure/step/builder/RuleParamStepBuilder.scala	42
measure/src/main/scala/org/apache/griffin/measure/step/builder/SparkSqlDQStepBuilder.scala	17
measure/src/main/scala/org/apache/griffin/measure/step/builder/StreamingDataSourceStepBuilder.scala	9
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/expr/AliasableExpr.scala	4
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/expr/ClauseExpression.scala	209
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/expr/Expr.scala	7
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/expr/ExprTag.scala	4
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/expr/ExtraConditionExpr.scala	5
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/expr/FunctionExpr.scala	29
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/expr/LiteralExpr.scala	46
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/expr/LogicalExpr.scala	166
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/expr/MathExpr.scala	63
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/expr/SelectExpr.scala	88
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/expr/TreeNode.scala	31
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/parser/BasicParser.scala	229
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/parser/GriffinDslParser.scala	39
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/transform/AccuracyExpr2DQSteps.scala	210
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/transform/CompletenessExpr2DQSteps.scala	178
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/transform/DistinctnessExpr2DQSteps.scala	337
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/transform/Expr2DQSteps.scala	28
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/transform/ProfilingExpr2DQSteps.scala	83
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/transform/TimelinessExpr2DQSteps.scala	197
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/transform/UniquenessExpr2DQSteps.scala	186
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/transform/analyzer/AccuracyAnalyzer.scala	18
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/transform/analyzer/BasicAnalyzer.scala	34
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/transform/analyzer/CompletenessAnalyzer.scala	23
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/transform/analyzer/DistinctnessAnalyzer.scala	23
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/transform/analyzer/ProfilingAnalyzer.scala	18
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/transform/analyzer/TimelinessAnalyzer.scala	10
measure/src/main/scala/org/apache/griffin/measure/step/builder/dsl/transform/analyzer/UniquenessAnalyzer.scala	23
measure/src/main/scala/org/apache/griffin/measure/step/builder/udf/GriffinUDFs.scala	27
measure/src/main/scala/org/apache/griffin/measure/step/read/ReadStep.scala	21
measure/src/main/scala/org/apache/griffin/measure/step/read/UnionReadStep.scala	16
measure/src/main/scala/org/apache/griffin/measure/step/transform/DataFrameOps.scala	101
measure/src/main/scala/org/apache/griffin/measure/step/transform/DataFrameOpsTransformStep.scala	30
measure/src/main/scala/org/apache/griffin/measure/step/transform/SparkSqlTransformStep.scala	23
measure/src/main/scala/org/apache/griffin/measure/step/transform/TransformStep.scala	81
measure/src/main/scala/org/apache/griffin/measure/step/write/DataSourceUpdateWriteStep.scala	32
measure/src/main/scala/org/apache/griffin/measure/step/write/MetricFlushStep.scala	32
measure/src/main/scala/org/apache/griffin/measure/step/write/MetricWriteStep.scala	71
measure/src/main/scala/org/apache/griffin/measure/step/write/RecordWriteStep.scala	126
measure/src/main/scala/org/apache/griffin/measure/step/write/SparkRowFormatter.scala	38
measure/src/main/scala/org/apache/griffin/measure/step/write/WriteStep.scala	7
measure/src/main/scala/org/apache/griffin/measure/utils/CommonUtils.scala	17
measure/src/main/scala/org/apache/griffin/measure/utils/DataFrameUtil.scala	17
measure/src/main/scala/org/apache/griffin/measure/utils/FSUtil.scala	53
measure/src/main/scala/org/apache/griffin/measure/utils/HdfsUtil.scala	104
measure/src/main/scala/org/apache/griffin/measure/utils/HttpUtil.scala	44
measure/src/main/scala/org/apache/griffin/measure/utils/JsonUtil.scala	27
measure/src/main/scala/org/apache/griffin/measure/utils/ParamUtil.scala	200
measure/src/main/scala/org/apache/griffin/measure/utils/ThreadUtils.scala	120
measure/src/main/scala/org/apache/griffin/measure/utils/TimeUtil.scala	78