| .github/ISSUE_TEMPLATE/bug_report.md | |
|
|
| .github/ISSUE_TEMPLATE/feature_request.md | |
|
|
| .gitignore | |
|
|
| .travis.yml | |
|
|
| CODE_OF_CONDUCT.md | |
|
|
| CONTRIBUTING.md | |
|
|
| DaFlow.png | |
|
|
| LICENSE | |
|
|
| README.md | |
|
|
| daflow-commons/README.md | |
|
|
| daflow-commons/pom.xml | |
|
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/CommonConstants.scala | 4 | A 0 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/Context.scala | 11 | A 0 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/ContextConstantEnum.scala | 8 | A 0 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/ExecutionResult.scala | 3 | A 0 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/NotificationMessages.scala | 13 | A 0 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/ProcessFrequencyEnum.scala | 18 | A 0 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/common/DataPath.scala | 7 | A 40 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/common/FieldMappingConf.scala | 2 | A 0 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/common/GeneralParamConf.scala | 2 | A 0 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/common/QueryConf.scala | 3 | A 0 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/extract/ExtractConf.scala | 6 | A 45 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/extract/ExtractionType.scala | 23 | A 0 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/job/DaFlowJobConf.scala | 5 | A 0 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/job/JobStaticParamConf.scala | 5 | A 0 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/load/LoadConf.scala | 5 | A 35 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/load/LoadType.scala | 21 | A 0 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/load/PartitioningDataConf.scala | 4 | A 0 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/transform/TransformConf.scala | 4 | A 40 mins |
|
| daflow-commons/src/main/scala/com/abhioncbr/daflow/commons/util/FileUtil.scala | 134 | A 0 mins |
|
| daflow-core/README.md | |
|
|
| daflow-core/pom.xml | |
|
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/LaunchETLSparkJobExecution.scala | 195 | B 6 hrs |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/extractData/AbstractExtractData.scala | 2 | A 0 mins |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/extractData/ExtractData.scala | 3 | A 0 mins |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/extractData/ExtractDataFromDB.scala | 67 | A 1 hr |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/extractData/ExtractDataFromFileSystem.scala | 60 | A 1 hr |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/extractData/ExtractDataFromHive.scala | 56 | A 1 hr |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/extractData/ExtractUtil.scala | 15 | A 0 mins |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/loadData/LoadData.scala | 6 | A 0 mins |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/loadData/LoadDataIntoFileSystem.scala | 50 | A 0 mins |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/loadData/LoadDataIntoHive.scala | 71 | A 1 hr |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/loadData/LoadUtil.scala | 7 | A 0 mins |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/transformData/Transform.scala | 2 | A 0 mins |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/transformData/TransformData.scala | 37 | A 55 mins |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/transformData/TransformRule.scala | 155 | A 1 hr |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/transformData/TransformStep.scala | 25 | A 0 mins |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/transformData/TransformUtil.scala | 62 | A 25 mins |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/validateData/ValidateData.scala | 7 | A 0 mins |
|
| daflow-core/src/main/scala/com/abhioncbr/daflow/core/validateData/ValidateTransformedData.scala | 2 | A 0 mins |
|
