path # lines of code
ui/angular/src/index.html 16
ui/angular/src/app/loader/loader.component.ts 26
ui/angular/src/app/loader/loader.component.html 3
ui/angular/src/app/loader/loader.component.css 6
ui/angular/src/app/loader/loader.service.ts 16
ui/angular/src/app/loader/loader.state.ts 3
ui/angular/src/app/job/create-job/batch/batch.component.ts 305
ui/angular/src/app/job/create-job/batch/batch.component.html 174
ui/angular/src/app/job/create-job/batch/batch.component.css 65
ui/angular/src/app/job/create-job/streaming/streaming.component.ts 196
ui/angular/src/app/job/create-job/streaming/streaming.component.html 106
ui/angular/src/app/job/create-job/streaming/streaming.component.css 65
ui/angular/src/app/job/job.component.ts 191
ui/angular/src/app/job/job.component.html 173
ui/angular/src/app/job/job.component.css 40
ui/angular/src/app/job/job-detail/job-detail.component.css 1
ui/angular/src/app/job/job-detail/job-detail.component.html 83
ui/angular/src/app/job/job-detail/job-detail.component.ts 68
ui/angular/src/app/app.module.ts 181
ui/angular/src/app/app.component.html 72
ui/angular/src/app/measure/measure.component.ts 98
ui/angular/src/app/measure/create-measure/ac/ac.component.html 568
ui/angular/src/app/measure/create-measure/ac/ac.component.ts 652
ui/angular/src/app/measure/create-measure/ac/ac.component.css 96
ui/angular/src/app/measure/create-measure/create-measure.component.ts 35
ui/angular/src/app/measure/create-measure/raw/raw.component.html 84
ui/angular/src/app/measure/create-measure/raw/raw.component.css 181
ui/angular/src/app/measure/create-measure/raw/raw.component.ts 116
ui/angular/src/app/measure/create-measure/pub/pub.component.html 204
ui/angular/src/app/measure/create-measure/pub/pub.component.css 373
ui/angular/src/app/measure/create-measure/pub/pub.component.ts 181
ui/angular/src/app/measure/create-measure/create-measure.component.html 203
ui/angular/src/app/measure/create-measure/pr/step1/step1.component.html 63
ui/angular/src/app/measure/create-measure/pr/step1/step1.component.css 105
ui/angular/src/app/measure/create-measure/pr/step1/step1.component.ts 236
ui/angular/src/app/measure/create-measure/pr/step3/step3.component.ts 35
ui/angular/src/app/measure/create-measure/pr/step3/step3.component.css 15
ui/angular/src/app/measure/create-measure/pr/step3/step3.component.html 28
ui/angular/src/app/measure/create-measure/pr/pr.component.ts 372
ui/angular/src/app/measure/create-measure/pr/step2/step2.component.html 65
ui/angular/src/app/measure/create-measure/pr/step2/step2.component.ts 50
ui/angular/src/app/measure/create-measure/pr/step2/step2.component.css 29
ui/angular/src/app/measure/create-measure/pr/confirmModal/confirmModal.component.ts 23
ui/angular/src/app/measure/create-measure/pr/confirmModal/confirmModal.component.html 110
ui/angular/src/app/measure/create-measure/pr/confirmModal/confirmModal.component.css 5
ui/angular/src/app/measure/create-measure/pr/step4/step4.component.html 86
ui/angular/src/app/measure/create-measure/pr/step4/step4.component.ts 35
ui/angular/src/app/measure/create-measure/pr/step4/step4.component.css 18
ui/angular/src/app/measure/create-measure/pr/pr.component.html 59
ui/angular/src/app/measure/create-measure/pr/rule/rule.component.ts 14
ui/angular/src/app/measure/create-measure/pr/rule/rule.component.css 25
ui/angular/src/app/measure/create-measure/pr/rule/rule.component.html 1066
ui/angular/src/app/measure/create-measure/pr/pr.component.css 17
ui/angular/src/app/measure/create-measure/create-measure.component.css 95
ui/angular/src/app/measure/create-measure/configuration/configuration.component.css 3
ui/angular/src/app/measure/create-measure/configuration/configuration.component.html 55
ui/angular/src/app/measure/create-measure/configuration/configuration.component.ts 98
ui/angular/src/app/measure/measure-detail/measure-detail.component.css 14
ui/angular/src/app/measure/measure-detail/measure-detail.component.html 194
ui/angular/src/app/measure/measure-detail/measure-detail.component.ts 103
ui/angular/src/app/measure/measure.component.html 117
ui/angular/src/app/measure/measure.component.css 301
ui/angular/src/app/app.component.css 105
ui/angular/src/app/dataasset/dataasset.component.css 25
ui/angular/src/app/dataasset/dataasset.component.html 71
ui/angular/src/app/dataasset/dataasset.component.ts 42
ui/angular/src/app/service/service.service.ts 59
ui/angular/src/app/service/http.service.ts 26
ui/angular/src/app/service/measure-format.service.ts 39
ui/angular/src/app/service/chart.service.ts 243
ui/angular/src/app/service/user.service.ts 21
ui/angular/src/app/health/health.component.css 3
ui/angular/src/app/health/health.component.ts 212
ui/angular/src/app/health/health.component.html 6
ui/angular/src/app/app.module.js 49
ui/angular/src/app/mydashboard/mydashboard.component.html 1
ui/angular/src/app/mydashboard/mydashboard.component.css 1
ui/angular/src/app/mydashboard/mydashboard.component.ts 13
ui/angular/src/app/app.component.js 25
ui/angular/src/app/app.component.ts 58
ui/angular/src/app/sidebar/sidebar.component.html 55
ui/angular/src/app/sidebar/sidebar.component.css 130
ui/angular/src/app/sidebar/truncate.pipe.ts 10
ui/angular/src/app/sidebar/sidebar.component.ts 118
ui/angular/src/app/login/login.component.html 66
ui/angular/src/app/login/login.component.ts 84
ui/angular/src/app/login/login.component.css 55
ui/angular/src/app/shared/shared.module.ts 11
ui/angular/src/app/shared/time-utils.ts 3
ui/angular/src/app/metric/metric.component.css 37
ui/angular/src/app/metric/metric.component.html 25
ui/angular/src/app/metric/metric.component.ts 122
ui/angular/src/app/metric/detail-metric/detail-metric.component.css 70
ui/angular/src/app/metric/detail-metric/detail-metric.component.ts 79
ui/angular/src/app/metric/detail-metric/detail-metric.component.html 91
ui/angular/src/vendor.ts 10
ui/angular/src/styles.css 959
ui/angular/src/polyfills.ts 3
ui/angular/src/main.ts 12
ui/angular/src/environments/environment.prod.ts 4
ui/angular/src/environments/environment.ts 4
scalastyle-config.xml 116
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/utils/FSUtil.scala 53
measure/src/main/scala/org/apache/griffin/measure/utils/HttpUtil.scala 44
measure/src/main/scala/org/apache/griffin/measure/utils/DataFrameUtil.scala 17
measure/src/main/scala/org/apache/griffin/measure/utils/CommonUtils.scala 17
measure/src/main/scala/org/apache/griffin/measure/utils/ThreadUtils.scala 120
measure/src/main/scala/org/apache/griffin/measure/utils/TimeUtil.scala 78
measure/src/main/scala/org/apache/griffin/measure/utils/ParamUtil.scala 200
measure/src/main/scala/org/apache/griffin/measure/utils/HdfsUtil.scala 104
measure/src/main/scala/org/apache/griffin/measure/utils/JsonUtil.scala 27
measure/src/main/scala/org/apache/griffin/measure/context/ContextId.scala 6
measure/src/main/scala/org/apache/griffin/measure/context/DataFrameCache.scala 40
measure/src/main/scala/org/apache/griffin/measure/context/TimeRange.scala 28
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/Metric.scala 9
measure/src/main/scala/org/apache/griffin/measure/context/streaming/metric/CacheResults.scala 40
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/OffsetCheckpointFactory.scala 18
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/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/checkpoint/lock/CheckpointLockSeq.scala 10
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/CheckpointLock.scala 7
measure/src/main/scala/org/apache/griffin/measure/context/TableRegister.scala 40
measure/src/main/scala/org/apache/griffin/measure/context/MetricWrapper.scala 41
measure/src/main/scala/org/apache/griffin/measure/context/DQContext.scala 65
measure/src/main/scala/org/apache/griffin/measure/step/DQStep.scala 15
measure/src/main/scala/org/apache/griffin/measure/step/write/MetricWriteStep.scala 71
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/step/write/MetricFlushStep.scala 32
measure/src/main/scala/org/apache/griffin/measure/step/write/RecordWriteStep.scala 126
measure/src/main/scala/org/apache/griffin/measure/step/write/DataSourceUpdateWriteStep.scala 32
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/transform/DataFrameOps.scala 101
measure/src/main/scala/org/apache/griffin/measure/step/builder/SparkSqlDQStepBuilder.scala 17
measure/src/main/scala/org/apache/griffin/measure/step/builder/DQStepBuilder.scala 53
measure/src/main/scala/org/apache/griffin/measure/step/builder/StreamingDataSourceStepBuilder.scala 9
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/udf/GriffinUDFs.scala 27
measure/src/main/scala/org/apache/griffin/measure/step/builder/ConstantColumns.scala 13
measure/src/main/scala/org/apache/griffin/measure/step/builder/BatchDataSourceStepBuilder.scala 9
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/dsl/transform/AccuracyExpr2DQSteps.scala 210
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/CompletenessAnalyzer.scala 23
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/dsl/transform/analyzer/TimelinessAnalyzer.scala 10
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/AccuracyAnalyzer.scala 18
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/DistinctnessExpr2DQSteps.scala 337
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/CompletenessExpr2DQSteps.scala 178
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/Expr2DQSteps.scala 28
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/expr/LiteralExpr.scala 46
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/ExtraConditionExpr.scala 5
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/TreeNode.scala 31
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/MathExpr.scala 63
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/FunctionExpr.scala 29
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/LogicalExpr.scala 166
measure/src/main/scala/org/apache/griffin/measure/step/SeqDQStep.scala 23
measure/src/main/scala/org/apache/griffin/measure/step/read/UnionReadStep.scala 16
measure/src/main/scala/org/apache/griffin/measure/step/read/ReadStep.scala 21
measure/src/main/scala/org/apache/griffin/measure/sink/ConsoleSink.scala 34
measure/src/main/scala/org/apache/griffin/measure/sink/HdfsSink.scala 126
measure/src/main/scala/org/apache/griffin/measure/sink/SinkFactory.scala 53
measure/src/main/scala/org/apache/griffin/measure/sink/Sink.scala 17
measure/src/main/scala/org/apache/griffin/measure/sink/MongoSink.scala 79
measure/src/main/scala/org/apache/griffin/measure/sink/ElasticSearchSink.scala 45
measure/src/main/scala/org/apache/griffin/measure/sink/SinkTaskRunner.scala 69
measure/src/main/scala/org/apache/griffin/measure/Loggable.scala 31
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/execution/MeasureExecutor.scala 154
measure/src/main/scala/org/apache/griffin/measure/execution/Measure.scala 59
measure/src/main/scala/org/apache/griffin/measure/execution/impl/CompletenessMeasure.scala 38
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/AccuracyMeasure.scala 115
measure/src/main/scala/org/apache/griffin/measure/execution/impl/SparkSQLMeasure.scala 43
measure/src/main/scala/org/apache/griffin/measure/execution/impl/DuplicationMeasure.scala 80
measure/src/main/scala/org/apache/griffin/measure/Application.scala 91
measure/src/main/scala/org/apache/griffin/measure/datasource/TimestampStorage.scala 15
measure/src/main/scala/org/apache/griffin/measure/datasource/DataSourceFactory.scala 52
measure/src/main/scala/org/apache/griffin/measure/datasource/DataSource.scala 68
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/TextDirBatchDataConnector.scala 69
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/FileBasedDataConnector.scala 121
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/HiveBatchDataConnector.scala 42
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/CassandraDataConnector.scala 61
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/ElasticSearchDataConnector.scala 54
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/streaming/KafkaStreamingStringDataConnector.scala 42
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/StreamingDataConnector.scala 17
measure/src/main/scala/org/apache/griffin/measure/configuration/dqdefinition/EnvConfig.scala 75
measure/src/main/scala/org/apache/griffin/measure/configuration/dqdefinition/Param.scala 4
measure/src/main/scala/org/apache/griffin/measure/configuration/dqdefinition/DQConfig.scala 213
measure/src/main/scala/org/apache/griffin/measure/configuration/dqdefinition/GriffinConfig.scala 17
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/ParamReaderFactory.scala 24
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/ParamReader.scala 12
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/WriteMode.scala 12
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/DslType.scala 13
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/OutputType.scala 15
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/DqType.scala 13
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/SinkType.scala 22
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/FlattenType.scala 16
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/ProcessType.scala 7
service/hibernate_mysql_pom.xml 181
service/src/main/java/org/apache/griffin/core/info/GriffinInfoController.java 12
service/src/main/java/org/apache/griffin/core/job/FileExistPredicator.java 46
service/src/main/java/org/apache/griffin/core/job/StreamingJobOperatorImpl.java 218
service/src/main/java/org/apache/griffin/core/job/SparkSubmitJob.java 208
service/src/main/java/org/apache/griffin/core/job/JobOperator.java 17
service/src/main/java/org/apache/griffin/core/job/Predicator.java 5
service/src/main/java/org/apache/griffin/core/job/entity/JobInstanceBean.java 171
service/src/main/java/org/apache/griffin/core/job/entity/SegmentRange.java 29
service/src/main/java/org/apache/griffin/core/job/entity/JobHealth.java 23
service/src/main/java/org/apache/griffin/core/job/entity/AbstractJob.java 206
service/src/main/java/org/apache/griffin/core/job/entity/JobType.java 13
service/src/main/java/org/apache/griffin/core/job/entity/LivyConf.java 90
service/src/main/java/org/apache/griffin/core/job/entity/JobState.java 41
service/src/main/java/org/apache/griffin/core/job/entity/StreamingJob.java 19
service/src/main/java/org/apache/griffin/core/job/entity/SegmentPredicate.java 65
service/src/main/java/org/apache/griffin/core/job/entity/JobDataSegment.java 63
service/src/main/java/org/apache/griffin/core/job/entity/LivySessionStates.java 126
service/src/main/java/org/apache/griffin/core/job/entity/BatchJob.java 31
service/src/main/java/org/apache/griffin/core/job/entity/VirtualJob.java 18
service/src/main/java/org/apache/griffin/core/job/JobInstance.java 312
service/src/main/java/org/apache/griffin/core/job/BatchJobOperatorImpl.java 333
service/src/main/java/org/apache/griffin/core/job/LivyTaskSubmitHelper.java 250
service/src/main/java/org/apache/griffin/core/job/JobController.java 99
service/src/main/java/org/apache/griffin/core/job/JobService.java 20
service/src/main/java/org/apache/griffin/core/job/factory/AutowiringSpringBeanJobFactory.java 29
service/src/main/java/org/apache/griffin/core/job/factory/PredicatorFactory.java 51
service/src/main/java/org/apache/griffin/core/job/JobServiceImpl.java 571
service/src/main/java/org/apache/griffin/core/job/repo/VirtualJobRepo.java 4
service/src/main/java/org/apache/griffin/core/job/repo/BaseJpaRepository.java 9
service/src/main/java/org/apache/griffin/core/job/repo/JobDataSegmentRepo.java 5
service/src/main/java/org/apache/griffin/core/job/repo/BatchJobRepo.java 4
service/src/main/java/org/apache/griffin/core/job/repo/StreamingJobRepo.java 4
service/src/main/java/org/apache/griffin/core/job/repo/JobInstanceRepo.java 26
service/src/main/java/org/apache/griffin/core/job/repo/JobRepo.java 13
service/src/main/java/org/apache/griffin/core/common/SimpleCORSFilter.java 31
service/src/main/java/org/apache/griffin/core/config/EnvConfig.java 81
service/src/main/java/org/apache/griffin/core/config/EclipseLinkJpaConfig.java 36
service/src/main/java/org/apache/griffin/core/config/CacheConfig.java 21
service/src/main/java/org/apache/griffin/core/config/LoginConfig.java 38
service/src/main/java/org/apache/griffin/core/config/PropertiesConfig.java 81
service/src/main/java/org/apache/griffin/core/config/SchedulerConfig.java 36
service/src/main/java/org/apache/griffin/core/measure/GriffinMeasureOperatorImpl.java 37
service/src/main/java/org/apache/griffin/core/measure/MeasureOrgController.java 26
service/src/main/java/org/apache/griffin/core/measure/MeasureOperator.java 8
service/src/main/java/org/apache/griffin/core/measure/MeasureService.java 13
service/src/main/java/org/apache/griffin/core/measure/MeasureOrgServiceImpl.java 69
service/src/main/java/org/apache/griffin/core/measure/entity/EvaluateRule.java 29
service/src/main/java/org/apache/griffin/core/measure/entity/DqType.java 9
service/src/main/java/org/apache/griffin/core/measure/entity/GriffinMeasure.java 146
service/src/main/java/org/apache/griffin/core/measure/entity/DataSource.java 88
service/src/main/java/org/apache/griffin/core/measure/entity/AbstractAuditableEntity.java 62
service/src/main/java/org/apache/griffin/core/measure/entity/Rule.java 161
service/src/main/java/org/apache/griffin/core/measure/entity/ExternalMeasure.java 42
service/src/main/java/org/apache/griffin/core/measure/entity/Measure.java 124
service/src/main/java/org/apache/griffin/core/measure/entity/DataConnector.java 189
service/src/main/java/org/apache/griffin/core/measure/entity/StreamingPreProcess.java 85
service/src/main/java/org/apache/griffin/core/measure/MeasureController.java 56
service/src/main/java/org/apache/griffin/core/measure/MeasureServiceImpl.java 116
service/src/main/java/org/apache/griffin/core/measure/repo/MeasureRepo.java 17
service/src/main/java/org/apache/griffin/core/measure/repo/EvaluateRuleRepo.java 5
service/src/main/java/org/apache/griffin/core/measure/repo/DataConnectorRepo.java 9
service/src/main/java/org/apache/griffin/core/measure/repo/ExternalMeasureRepo.java 4
service/src/main/java/org/apache/griffin/core/measure/repo/GriffinMeasureRepo.java 4
service/src/main/java/org/apache/griffin/core/measure/MeasureOrgService.java 10
service/src/main/java/org/apache/griffin/core/measure/ExternalMeasureOperatorImpl.java 53
service/src/main/java/org/apache/griffin/core/metastore/kafka/KafkaSchemaController.java 42
service/src/main/java/org/apache/griffin/core/metastore/kafka/KafkaSchemaService.java 12
service/src/main/java/org/apache/griffin/core/metastore/kafka/KafkaSchemaServiceImpl.java 84
service/src/main/java/org/apache/griffin/core/metastore/hive/HiveMetaStoreServiceJdbcImpl.java 232
service/src/main/java/org/apache/griffin/core/metastore/hive/HiveMetaStoreService.java 13
service/src/main/java/org/apache/griffin/core/metastore/hive/HiveMetaStoreProxy.java 44
service/src/main/java/org/apache/griffin/core/metastore/hive/HiveMetaStoreController.java 42
service/src/main/java/org/apache/griffin/core/metastore/hive/HiveMetaStoreServiceImpl.java 163
service/src/main/java/org/apache/griffin/core/util/JsonUtil.java 71
service/src/main/java/org/apache/griffin/core/util/MeasureUtil.java 72
service/src/main/java/org/apache/griffin/core/util/FSUtil.java 179
service/src/main/java/org/apache/griffin/core/util/PropertiesUtil.java 45
service/src/main/java/org/apache/griffin/core/util/YarnNetUtil.java 61
service/src/main/java/org/apache/griffin/core/util/TimeUtil.java 125
service/src/main/java/org/apache/griffin/core/util/FileUtil.java 35
service/src/main/java/org/apache/griffin/core/GriffinWebApplication.java 22
service/src/main/java/org/apache/griffin/core/exception/GriffinException.java 40
service/src/main/java/org/apache/griffin/core/exception/GriffinExceptionHandler.java 37
service/src/main/java/org/apache/griffin/core/exception/GriffinExceptionMessage.java 67
service/src/main/java/org/apache/griffin/core/exception/GriffinExceptionResponse.java 51
service/src/main/java/org/apache/griffin/core/event/EventSourceType.java 5
service/src/main/java/org/apache/griffin/core/event/JobEvent.java 34
service/src/main/java/org/apache/griffin/core/event/EventPointcutType.java 6
service/src/main/java/org/apache/griffin/core/event/GriffinAbstractEvent.java 32
service/src/main/java/org/apache/griffin/core/event/GriffinEvent.java 7
service/src/main/java/org/apache/griffin/core/event/EventType.java 6
service/src/main/java/org/apache/griffin/core/event/JobEventHook.java 9
service/src/main/java/org/apache/griffin/core/event/GriffinEventManager.java 33
service/src/main/java/org/apache/griffin/core/event/GriffinHook.java 5
service/src/main/java/org/apache/griffin/core/login/ldap/SelfSignedSocketFactory.java 57
service/src/main/java/org/apache/griffin/core/login/LoginServiceLdapImpl.java 150
service/src/main/java/org/apache/griffin/core/login/LoginService.java 6
service/src/main/java/org/apache/griffin/core/login/LoginController.java 19
service/src/main/java/org/apache/griffin/core/login/LoginServiceDefaultImpl.java 20
service/src/main/java/org/apache/griffin/core/metric/MetricStoreImpl.java 189
service/src/main/java/org/apache/griffin/core/metric/model/MetricValue.java 68
service/src/main/java/org/apache/griffin/core/metric/model/Metric.java 42
service/src/main/java/org/apache/griffin/core/metric/MetricService.java 14
service/src/main/java/org/apache/griffin/core/metric/MetricController.java 52
service/src/main/java/org/apache/griffin/core/metric/MetricStore.java 13
service/src/main/java/org/apache/griffin/core/metric/MetricServiceImpl.java 139
service/src/main/resources/Init_quartz_h2.sql 212
service/src/main/resources/hiveserver2-site.xml 4
service/src/main/resources/log4j2-spring.xml 44
service/src/main/resources/hive-site.xml 4
service/src/main/resources/Init_quartz_mysql_innodb.sql 156
service/src/main/resources/init_quartz_mysql.sql 145
service/src/main/resources/Init_quartz_derby.sql 122
service/src/main/resources/hivemetastore-site.xml 4
service/src/main/resources/Init_quartz_postgres.sql 165
merge_pr.py 395