This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/maven/service/hive.version-3.1.2
in repository https://gitbox.apache.org/repos/asf/griffin.git.
discard e06e03f Bump hive.version from 2.2.0 to 3.1.2 in /service
add 2f3c146 [GRIFFIN-299] Add oracle jdk8 support in travis build phase
add 350663f [GRIFFIN-298] add CompletenessExpr2DQSteps test case
add 48f304d [GRIFFIN-297] Allow support for additional file based data
sources
add 6d9e9a7 Bug fix for reflecting a custom sink object
add cef0a0e [GRIFFIN-304] Eliminate older contexts
add 8ef73f1 [GRIFFIN-301] Update custom data connector to have the same
parameters as build-in data connector
add a12729b [GRIFFIN-310] Unified scala code style and enable scala code
style checking by default
add ed47c2b Enum based configs
add 7f718d3 [GRIFFIN-312] Code Style Standardization
add ee82cbd [GRIFFIN-315] Adding JDBC based data connector
add fa11527 [GRIFFIN-319] Deprecate old Data Connectors
add 15304da [GRIFFIN-318] Replace all YYYY with yyyy in all user guides
and examples
add 6784dc0 [GRIFFIN-317] Define guidelines for Griffin Project
Improvement Proposals (GPIP)
add 727e961 [GRIFFIN-322] Add SQL mode for ES connector
add 23950ec [GRIFFIN-323] Refactor configuration Data Source Connector
add 24c270e optimize get metric maps in 'MetricWriteStep'
add 3b77ccc [GRIFFIN-316] Fix job exception handling
add 491a168 Upgrade UI packages for jquery
add 35a1714 [GRIFFIN-326] New Data Connector for Elasticsearch
add 7123269 Fix Unit Test Issue In Measure Test Case
add 1aa8995 [GRIFFIN-305] Standardize sink hierarchy
add dd887db [GRIFFIN-339] Import griffin tool for debug and run user jobs
add 921e1d0 [GRIFFIN-SERVICE] use service tar.gz deploy and griffin.sh
start
add ef6466d compaliancy fix
add 0a87ef0 update angular cli version for release issue
add 469d47d Change connectors to connector for datasource
add 53521d5 [maven-release-plugin] prepare release griffin-0.6.0
add d43398b [maven-release-plugin] prepare for next development iteration
add 3994727 Fix doc format glitches
add 6977d1d Support http remote conf
add 076c8d0 [GRIFFIN-345] Support cross-version compilation for Scala and
Spark dependencies
add c7d7431 Bump hive.version from 2.2.0 to 3.1.2 in /service
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (e06e03f)
\
N -- N -- N
refs/heads/dependabot/maven/service/hive.version-3.1.2 (c7d7431)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.gitignore | 6 +-
.scalafmt.conf | 27 +
.travis.yml | 4 +-
griffin-doc/deploy/deploy-guide.md | 16 +-
griffin-doc/deploy/measure-build-guide.md | 74 +
griffin-doc/dev/code-style.md | 65 +-
griffin-doc/dev/griffin-pip.md | 103 +
griffin-doc/img/devguide/scala-intellij-idea/1.png | Bin 0 -> 102866 bytes
griffin-doc/img/devguide/scala-intellij-idea/2.png | Bin 0 -> 65081 bytes
griffin-doc/img/devguide/scala-intellij-idea/3.png | Bin 0 -> 52692 bytes
griffin-doc/img/devguide/scala-intellij-idea/4.png | Bin 0 -> 59986 bytes
griffin-doc/img/devguide/scala-intellij-idea/5.png | Bin 0 -> 79997 bytes
griffin-doc/img/devguide/scala-intellij-idea/6.png | Bin 0 -> 57525 bytes
griffin-doc/measure/griffin-tool.md | 144 ++
griffin-doc/measure/measure-batch-sample.md | 75 +-
griffin-doc/measure/measure-configuration-guide.md | 511 ++++-
griffin-doc/measure/measure-streaming-sample.md | 216 +--
griffin-doc/measure/predicates.md | 16 +-
griffin-doc/service/api-guide.md | 479 ++---
griffin-doc/ui/user-guide.md | 4 +-
measure/pom.xml | 562 ++++--
measure/sbin/griffin-tool.sh | 58 +
.../src/main/resources/config-batch-advanced.json | 41 +-
measure/src/main/resources/config-batch-es.json | 52 +
measure/src/main/resources/config-batch-path.json | 39 +-
measure/src/main/resources/config-batch.json | 39 +-
measure/src/main/resources/config-streaming.json | 76 +-
measure/src/main/resources/env-batch.json | 5 +-
measure/src/main/resources/env-streaming.json | 5 +-
.../org/apache/griffin/measure/Application.scala | 70 +-
.../org/apache/griffin/measure/Loggable.scala | 37 +-
.../configuration/dqdefinition/DQConfig.scala | 292 +--
.../configuration/dqdefinition/EnvConfig.scala | 142 +-
.../configuration/dqdefinition/GriffinConfig.scala | 54 +-
.../measure/configuration/dqdefinition/Param.scala | 37 +-
.../dqdefinition/reader/ParamFileReader.scala | 47 +-
.../dqdefinition/reader/ParamHttpReader.scala | 42 +
.../dqdefinition/reader/ParamJsonReader.scala | 40 +-
.../dqdefinition/reader/ParamReader.scala | 54 +-
.../dqdefinition/reader/ParamReaderFactory.scala | 52 +-
.../measure/configuration/enums/DqType.scala | 163 +-
.../measure/configuration/enums/DslType.scala | 98 +-
.../measure/configuration/enums/FlattenType.scala | 143 +-
.../measure/configuration/enums/GriffinEnum.scala | 35 +
.../measure/configuration/enums/OutputType.scala | 112 +-
.../measure/configuration/enums/ProcessType.scala | 78 +-
.../measure/configuration/enums/SinkType.scala | 133 +-
.../measure/configuration/enums/WriteMode.scala | 53 +-
.../apache/griffin/measure/context/ContextId.scala | 39 +-
.../apache/griffin/measure/context/DQContext.scala | 105 +-
.../griffin/measure/context/DataFrameCache.scala | 43 +-
.../griffin/measure/context/MetricWrapper.scala | 50 +-
.../griffin/measure/context/TableRegister.scala | 54 +-
.../apache/griffin/measure/context/TimeRange.scala | 38 +-
.../streaming/checkpoint/lock/CheckpointLock.scala | 35 +-
.../checkpoint/lock/CheckpointLockInZK.scala | 35 +-
.../checkpoint/lock/CheckpointLockSeq.scala | 35 +-
.../checkpoint/offset/OffsetCheckpoint.scala | 33 +-
.../checkpoint/offset/OffsetCheckpointClient.scala | 48 +-
.../offset/OffsetCheckpointFactory.scala | 41 +-
.../checkpoint/offset/OffsetCheckpointInZK.scala | 105 +-
.../streaming/checkpoint/offset/OffsetOps.scala | 85 +-
.../context/streaming/metric/AccuracyMetric.scala | 43 +-
.../context/streaming/metric/CacheResults.scala | 52 +-
.../measure/context/streaming/metric/Metric.scala | 35 +-
.../griffin/measure/datasource/DataSource.scala | 75 +-
.../measure/datasource/DataSourceFactory.scala | 77 +-
.../measure/datasource/TimestampStorage.scala | 56 +-
.../datasource/cache/StreamingCacheClient.scala | 219 ++-
.../cache/StreamingCacheClientFactory.scala | 76 +-
.../cache/StreamingCacheJsonClient.scala | 47 +-
.../datasource/cache/StreamingCacheOrcClient.scala | 47 +-
.../cache/StreamingCacheParquetClient.scala | 56 +-
.../cache/StreamingOffsetCacheable.scala | 59 +-
.../measure/datasource/cache/WithFanIn.scala | 49 +-
.../datasource/connector/DataConnector.scala | 49 +-
.../connector/DataConnectorFactory.scala | 167 +-
.../connector/batch/AvroBatchDataConnector.scala | 48 +-
.../connector/batch/BatchDataConnector.scala | 31 +-
.../batch/BatchDataConnectorContext.scala | 28 -
.../connector/batch/CassandraDataConnector.scala | 94 +-
.../batch/ElasticSearchDataConnector.scala | 105 +
.../batch/ElasticSearchGriffinDataConnector.scala | 178 +-
.../connector/batch/FileBasedDataConnector.scala | 227 +++
.../connector/batch/HiveBatchDataConnector.scala | 72 +-
.../connector/batch/JDBCBasedDataConnector.scala | 136 ++
.../connector/batch/MySqlDataConnector.scala | 77 +-
.../batch/TextDirBatchDataConnector.scala | 79 +-
.../streaming/KafkaStreamingDataConnector.scala | 82 +-
.../KafkaStreamingStringDataConnector.scala | 57 +-
.../streaming/StreamingDataConnector.scala | 34 +-
.../streaming/StreamingDataConnectorContext.scala | 32 -
.../org/apache/griffin/measure/job/DQJob.scala | 49 +-
.../griffin/measure/job/builder/DQJobBuilder.scala | 55 +-
.../org/apache/griffin/measure/launch/DQApp.scala | 77 +-
.../griffin/measure/launch/batch/BatchDQApp.scala | 99 +-
.../measure/launch/streaming/StreamingDQApp.scala | 150 +-
.../apache/griffin/measure/sink/ConsoleSink.scala | 106 +-
.../griffin/measure/sink/ElasticSearchSink.scala | 74 +-
.../org/apache/griffin/measure/sink/HdfsSink.scala | 153 +-
.../apache/griffin/measure/sink/MongoSink.scala | 93 +-
.../apache/griffin/measure/sink/MultiSinks.scala | 90 -
.../org/apache/griffin/measure/sink/Sink.scala | 80 +-
.../apache/griffin/measure/sink/SinkContext.scala | 21 -
.../apache/griffin/measure/sink/SinkFactory.scala | 137 +-
.../griffin/measure/sink/SinkTaskRunner.scala | 59 +-
.../org/apache/griffin/measure/step/DQStep.scala | 53 +-
.../apache/griffin/measure/step/SeqDQStep.scala | 58 +-
.../step/builder/BatchDataSourceStepBuilder.scala | 32 +-
.../measure/step/builder/ConstantColumns.scala | 40 +-
.../measure/step/builder/DQStepBuilder.scala | 66 +-
.../measure/step/builder/DQStepNameGenerator.scala | 33 +-
.../step/builder/DataFrameOpsDQStepBuilder.scala | 38 +-
.../step/builder/DataSourceParamStepBuilder.scala | 48 +-
.../step/builder/GriffinDslDQStepBuilder.scala | 47 +-
.../step/builder/RuleParamStepBuilder.scala | 72 +-
.../step/builder/SparkSqlDQStepBuilder.scala | 37 +-
.../builder/StreamingDataSourceStepBuilder.scala | 31 +-
.../step/builder/dsl/expr/AliasableExpr.scala | 31 +-
.../step/builder/dsl/expr/ClauseExpression.scala | 143 +-
.../measure/step/builder/dsl/expr/Expr.scala | 37 +-
.../measure/step/builder/dsl/expr/ExprTag.scala | 31 +-
.../step/builder/dsl/expr/ExtraConditionExpr.scala | 31 +-
.../step/builder/dsl/expr/FunctionExpr.scala | 57 +-
.../step/builder/dsl/expr/LiteralExpr.scala | 39 +-
.../step/builder/dsl/expr/LogicalExpr.scala | 94 +-
.../measure/step/builder/dsl/expr/MathExpr.scala | 61 +-
.../measure/step/builder/dsl/expr/SelectExpr.scala | 68 +-
.../measure/step/builder/dsl/expr/TreeNode.scala | 59 +-
.../step/builder/dsl/parser/BasicParser.scala | 491 ++---
.../step/builder/dsl/parser/GriffinDslParser.scala | 129 +-
.../dsl/transform/AccuracyExpr2DQSteps.scala | 215 ++-
.../dsl/transform/CompletenessExpr2DQSteps.scala | 177 +-
.../dsl/transform/DistinctnessExpr2DQSteps.scala | 270 +--
.../step/builder/dsl/transform/Expr2DQSteps.scala | 64 +-
.../dsl/transform/ProfilingExpr2DQSteps.scala | 65 +-
.../dsl/transform/TimelinessExpr2DQSteps.scala | 142 +-
.../dsl/transform/UniquenessExpr2DQSteps.scala | 150 +-
.../dsl/transform/analyzer/AccuracyAnalyzer.scala | 42 +-
.../dsl/transform/analyzer/BasicAnalyzer.scala | 80 +-
.../transform/analyzer/CompletenessAnalyzer.scala | 43 +-
.../transform/analyzer/DistinctnessAnalyzer.scala | 43 +-
.../dsl/transform/analyzer/ProfilingAnalyzer.scala | 40 +-
.../transform/analyzer/TimelinessAnalyzer.scala | 33 +-
.../transform/analyzer/UniquenessAnalyzer.scala | 43 +-
.../step/builder/preproc/PreProcParamMaker.scala | 66 +-
.../measure/step/builder/udf/GriffinUDFs.scala | 62 +-
.../griffin/measure/step/read/ReadStep.scala | 40 +-
.../griffin/measure/step/read/UnionReadStep.scala | 37 +-
.../measure/step/transform/DataFrameOps.scala | 112 +-
.../step/transform/DataFrameOpsTransformStep.scala | 76 +-
.../step/transform/SparkSqlTransformStep.scala | 68 +-
.../measure/step/transform/TransformStep.scala | 93 +-
.../step/write/DataSourceUpdateWriteStep.scala | 54 +-
.../measure/step/write/MetricFlushStep.scala | 62 +-
.../measure/step/write/MetricWriteStep.scala | 92 +-
.../measure/step/write/RecordWriteStep.scala | 113 +-
.../measure/step/write/SparkRowFormatter.scala | 43 +-
.../griffin/measure/step/write/WriteStep.scala | 33 +-
.../apache/griffin/measure/utils/CommonUtils.scala | 44 +
.../griffin/measure/utils/DataFrameUtil.scala | 38 +-
.../org/apache/griffin/measure/utils/FSUtil.scala | 61 +-
.../apache/griffin/measure/utils/HdfsUtil.scala | 93 +-
.../apache/griffin/measure/utils/HttpUtil.scala | 119 +-
.../apache/griffin/measure/utils/JsonUtil.scala | 36 +-
.../apache/griffin/measure/utils/ParamUtil.scala | 44 +-
.../apache/griffin/measure/utils/ThreadUtils.scala | 75 +-
.../apache/griffin/measure/utils/TimeUtil.scala | 58 +-
.../test/resources/_accuracy-batch-griffindsl.json | 39 +-
.../resources/_accuracy-streaming-griffindsl.json | 144 +-
.../resources/_completeness-batch-griffindsl.json | 25 +-
.../_completeness-streaming-griffindsl.json | 74 +-
.../_completeness_errorconf-batch-griffindsl.json | 35 +-
.../resources/_distinctness-batch-griffindsl.json | 38 +-
.../_distinctness-streaming-griffindsl.json | 79 +-
.../_profiling-batch-griffindsl-hive.json | 30 +-
.../resources/_profiling-batch-griffindsl.json | 43 +-
.../_profiling-batch-griffindsl_malformed.json | 43 +
.../test/resources/_profiling-batch-sparksql.json | 24 +-
.../resources/_profiling-streaming-griffindsl.json | 76 +-
.../resources/_timeliness-batch-griffindsl.json | 28 +-
.../_timeliness-streaming-griffindsl.json | 80 +-
.../resources/_uniqueness-batch-griffindsl.json | 38 +-
.../_uniqueness-streaming-griffindsl.json | 137 +-
.../test/resources/elasticsearch/test_data_1.json | 2000 ++++++++++++++++++++
.../elasticsearch/test_data_1_template.json | 88 +
.../test/resources/elasticsearch/test_data_2.json | 4 +
.../elasticsearch/test_data_2_template.json | 17 +
measure/src/test/resources/env-batch.json | 3 +-
.../src/test/resources/env-streaming-mongo.json | 3 +-
measure/src/test/resources/env-streaming.json | 2 +-
.../resources/files/person_table.csv/._SUCCESS.crc | Bin 0 -> 8 bytes
...d01e73-1818-4a16-9e72-2da15374961e-c000.csv.crc | Bin 0 -> 12 bytes
.../test/resources/files/person_table.csv/_SUCCESS | 0
...-34d01e73-1818-4a16-9e72-2da15374961e-c000.csv} | 1 +
.../resources/files/person_table.orc/._SUCCESS.crc | Bin 0 -> 8 bytes
...67a0-44c9-8cae-0487f2992d66-c000.snappy.orc.crc | Bin 0 -> 12 bytes
.../test/resources/files/person_table.orc/_SUCCESS | 0
...937-67a0-44c9-8cae-0487f2992d66-c000.snappy.orc | Bin 0 -> 331 bytes
.../files/person_table.parquet/._SUCCESS.crc | Bin 0 -> 8 bytes
...-4b92-a3bb-0ffb59b4d45e-c000.snappy.parquet.crc | Bin 0 -> 16 bytes
.../resources/files/person_table.parquet/_SUCCESS | 0
...6ad2-4b92-a3bb-0ffb59b4d45e-c000.snappy.parquet | Bin 0 -> 558 bytes
.../resources/files/person_table.tsv/._SUCCESS.crc | Bin 0 -> 8 bytes
...fdfa41-386d-4c4c-8a52-c690885f1569-c000.csv.crc | Bin 0 -> 12 bytes
.../test/resources/files/person_table.tsv/_SUCCESS | 0
...0-c3fdfa41-386d-4c4c-8a52-c690885f1569-c000.csv | 3 +
.../invalidtype_completeness_batch_griffindal.json | 2 +-
.../apache/griffin/measure/SparkSuiteBase.scala | 40 +-
.../reader/DataConnectorFactorySpec.scala | 129 --
.../dqdefinition/reader/ParamEnumReaderSpec.scala | 196 ++
.../dqdefinition/reader/ParamFileReaderSpec.scala | 72 +-
.../dqdefinition/reader/ParamJsonReaderSpec.scala | 59 +-
.../measure/context/DataFrameCacheTest.scala | 59 +-
.../measure/context/MetricWrapperTest.scala | 58 +-
.../griffin/measure/context/TimeRangeTest.scala | 42 +-
.../measure/datasource/TimestampStorageTest.scala | 52 +-
.../connector/DataConnectorFactorySpec.scala | 151 ++
.../batch/ElasticSearchDataConnectorTest.scala | 173 ++
.../batch/FileBasedDataConnectorTest.scala | 183 ++
.../batch/JDBCBasedDataConnectorTest.scala | 152 ++
.../griffin/measure/job/BatchDQAppTest.scala | 86 +-
.../org/apache/griffin/measure/job/DQAppTest.scala | 57 +-
.../apache/griffin/measure/sink/CustomSink.scala | 74 +-
.../griffin/measure/sink/CustomSinkTest.scala | 112 +-
.../apache/griffin/measure/sink/SinkTestBase.scala | 66 +-
.../griffin/measure/step/TransformStepTest.scala | 103 +-
.../transform/CompletenessExpr2DQStepsTest.scala | 49 +
.../AccuracyTransformationsIntegrationTest.scala | 111 +-
.../griffin/measure/utils/ParamUtilTest.scala | 116 +-
pom.xml | 51 +-
service/pom.xml | 32 +-
.../griffin/core/job/BatchJobOperatorImpl.java | 2 +-
.../org/apache/griffin/core/job/JobInstance.java | 15 +-
.../griffin/core/measure/entity/DataSource.java | 36 +-
.../metastore/hive/HiveMetaStoreServiceImpl.java | 2 +-
.../org/apache/griffin/core/util/MeasureUtil.java | 23 +-
service/src/main/resources/assembly/assembly.xml | 84 +
service/src/main/resources/env/env_batch.json | 5 +-
service/src/main/resources/log4j2-spring.xml | 16 +
service/src/main/resources/shell/griffin.sh | 146 ++
service/src/main/resources/shell/setenv.sh | 40 +
.../src/main/resources/shell/start.sh | 16 +-
.../src/main/resources/shell/stop.sh | 16 +-
.../griffin/core/measure/repo/MeasureRepoTest.java | 2 +-
.../griffin/core/util/EntityMocksHelper.java | 4 +-
ui/angular/package.json | 8 +-
.../app/job/create-job/batch/batch.component.ts | 32 +-
.../create-job/streaming/streaming.component.ts | 32 +-
.../src/app/job/job-detail/job-detail.component.ts | 2 +-
.../app/measure/create-measure/ac/ac.component.ts | 16 +-
.../configuration/configuration.component.html | 4 +-
.../app/measure/create-measure/pr/pr.component.ts | 7 +-
.../measure-detail.component.spec.ts | 6 +-
.../measure-detail/measure-detail.component.ts | 2 +-
ui/angular/src/app/measure/measure.component.ts | 4 +-
ui/pom.xml | 2 +-
257 files changed, 12083 insertions(+), 7145 deletions(-)
create mode 100644 .scalafmt.conf
create mode 100644 griffin-doc/deploy/measure-build-guide.md
create mode 100644 griffin-doc/dev/griffin-pip.md
create mode 100644 griffin-doc/img/devguide/scala-intellij-idea/1.png
create mode 100644 griffin-doc/img/devguide/scala-intellij-idea/2.png
create mode 100644 griffin-doc/img/devguide/scala-intellij-idea/3.png
create mode 100644 griffin-doc/img/devguide/scala-intellij-idea/4.png
create mode 100644 griffin-doc/img/devguide/scala-intellij-idea/5.png
create mode 100644 griffin-doc/img/devguide/scala-intellij-idea/6.png
create mode 100644 griffin-doc/measure/griffin-tool.md
create mode 100644 measure/sbin/griffin-tool.sh
create mode 100644 measure/src/main/resources/config-batch-es.json
create mode 100644
measure/src/main/scala/org/apache/griffin/measure/configuration/dqdefinition/reader/ParamHttpReader.scala
create mode 100644
measure/src/main/scala/org/apache/griffin/measure/configuration/enums/GriffinEnum.scala
delete mode 100644
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/batch/BatchDataConnectorContext.scala
create mode 100644
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/batch/ElasticSearchDataConnector.scala
create mode 100644
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/batch/FileBasedDataConnector.scala
create mode 100644
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/batch/JDBCBasedDataConnector.scala
delete mode 100644
measure/src/main/scala/org/apache/griffin/measure/datasource/connector/streaming/StreamingDataConnectorContext.scala
delete mode 100644
measure/src/main/scala/org/apache/griffin/measure/sink/MultiSinks.scala
delete mode 100644
measure/src/main/scala/org/apache/griffin/measure/sink/SinkContext.scala
create mode 100644
measure/src/main/scala/org/apache/griffin/measure/utils/CommonUtils.scala
create mode 100644
measure/src/test/resources/_profiling-batch-griffindsl_malformed.json
create mode 100644 measure/src/test/resources/elasticsearch/test_data_1.json
create mode 100644
measure/src/test/resources/elasticsearch/test_data_1_template.json
create mode 100644 measure/src/test/resources/elasticsearch/test_data_2.json
create mode 100644
measure/src/test/resources/elasticsearch/test_data_2_template.json
create mode 100644
measure/src/test/resources/files/person_table.csv/._SUCCESS.crc
create mode 100644
measure/src/test/resources/files/person_table.csv/.part-00000-34d01e73-1818-4a16-9e72-2da15374961e-c000.csv.crc
copy ui/angular/src/assets/.gitkeep =>
measure/src/test/resources/files/person_table.csv/_SUCCESS (100%)
copy measure/src/test/resources/{hive/person_table.csv =>
files/person_table.csv/part-00000-34d01e73-1818-4a16-9e72-2da15374961e-c000.csv}
(64%)
create mode 100644
measure/src/test/resources/files/person_table.orc/._SUCCESS.crc
create mode 100644
measure/src/test/resources/files/person_table.orc/.part-00000-d7c5a937-67a0-44c9-8cae-0487f2992d66-c000.snappy.orc.crc
copy ui/angular/src/assets/.gitkeep =>
measure/src/test/resources/files/person_table.orc/_SUCCESS (100%)
create mode 100644
measure/src/test/resources/files/person_table.orc/part-00000-d7c5a937-67a0-44c9-8cae-0487f2992d66-c000.snappy.orc
create mode 100644
measure/src/test/resources/files/person_table.parquet/._SUCCESS.crc
create mode 100644
measure/src/test/resources/files/person_table.parquet/.part-00000-1a3fe17e-6ad2-4b92-a3bb-0ffb59b4d45e-c000.snappy.parquet.crc
copy ui/angular/src/assets/.gitkeep =>
measure/src/test/resources/files/person_table.parquet/_SUCCESS (100%)
create mode 100644
measure/src/test/resources/files/person_table.parquet/part-00000-1a3fe17e-6ad2-4b92-a3bb-0ffb59b4d45e-c000.snappy.parquet
create mode 100644
measure/src/test/resources/files/person_table.tsv/._SUCCESS.crc
create mode 100644
measure/src/test/resources/files/person_table.tsv/.part-00000-c3fdfa41-386d-4c4c-8a52-c690885f1569-c000.csv.crc
copy ui/angular/src/assets/.gitkeep =>
measure/src/test/resources/files/person_table.tsv/_SUCCESS (100%)
create mode 100644
measure/src/test/resources/files/person_table.tsv/part-00000-c3fdfa41-386d-4c4c-8a52-c690885f1569-c000.csv
delete mode 100644
measure/src/test/scala/org/apache/griffin/measure/configuration/dqdefinition/reader/DataConnectorFactorySpec.scala
create mode 100644
measure/src/test/scala/org/apache/griffin/measure/configuration/dqdefinition/reader/ParamEnumReaderSpec.scala
create mode 100644
measure/src/test/scala/org/apache/griffin/measure/datasource/connector/DataConnectorFactorySpec.scala
create mode 100644
measure/src/test/scala/org/apache/griffin/measure/datasource/connector/batch/ElasticSearchDataConnectorTest.scala
create mode 100644
measure/src/test/scala/org/apache/griffin/measure/datasource/connector/batch/FileBasedDataConnectorTest.scala
create mode 100644
measure/src/test/scala/org/apache/griffin/measure/datasource/connector/batch/JDBCBasedDataConnectorTest.scala
create mode 100644
measure/src/test/scala/org/apache/griffin/measure/step/builder/dsl/transform/CompletenessExpr2DQStepsTest.scala
create mode 100644 service/src/main/resources/assembly/assembly.xml
create mode 100644 service/src/main/resources/shell/griffin.sh
create mode 100644 service/src/main/resources/shell/setenv.sh
copy measure/src/main/resources/log4j.properties =>
service/src/main/resources/shell/start.sh (73%)
copy measure/src/main/resources/log4j.properties =>
service/src/main/resources/shell/stop.sh (73%)
