Path Lines of Code CHANGELOG.md 2001 README.md 68 conf/aws/log4j.properties 29 conf/aws/quartz.properties 19 conf/cli/gobblin-cli.properties 33 conf/cli/log4j.properties 26 conf/cluster-master/log4j.properties 25 conf/cluster-master/quartz.properties 3 conf/cluster-worker/log4j.properties 24 conf/cluster-worker/quartz.properties 3 conf/gobblin-as-service/log4j.properties 24 conf/gobblin-as-service/quartz.properties 3 conf/mapreduce/log4j.properties 27 conf/standalone/log4j.properties 28 conf/standalone/quartz.properties 3 conf/yarn/log4j.properties 29 conf/yarn/quartz.properties 19 config/checkstyle/checkstyle.xml 18 config/checkstyle/suppressions.xml 8 dev/README.md 59 dev/requirements.txt 4 gobblin-admin/README.md 38 gobblin-admin/src/main/resources/static/config.json 434 gobblin-aws/src/test/resources/log4j.properties 29 gobblin-binary-management/src/test/resources/avroWriterTest/data1.json 2 gobblin-binary-management/src/test/resources/avroWriterTest/data2.json 1 gobblin-binary-management/src/test/resources/orcWriterTest/data1.json 1 gobblin-binary-management/src/test/resources/orcWriterTest/data2.json 1 gobblin-compaction/compaction.properties 19 gobblin-compaction/src/main/resources/orcCompactionTest/data1.json 1 gobblin-core-base/src/test/resources/avroProjectionConverter/simpleRecord.json 4 gobblin-core/src/main/resources/mysql/mysql.properties 41 gobblin-core/src/main/resources/sftp/sftp-example.properties 29 gobblin-core/src/main/resources/sqlserver/sqlserver.properties 40 gobblin-core/src/test/resources/converter/JsonElementConversionFactoryTest.json 856 gobblin-core/src/test/resources/converter/JsonStringToJsonIntermediateConverter.json 919 gobblin-core/src/test/resources/converter/complex1.json 527 gobblin-core/src/test/resources/converter/complex2.json 186 gobblin-core/src/test/resources/converter/complex3.json 548 gobblin-core/src/test/resources/converter/csv/10_fields.json 12 gobblin-core/src/test/resources/converter/csv/11_fields_with_null.json 13 gobblin-core/src/test/resources/converter/csv/schema_with_10_fields.json 82 gobblin-core/src/test/resources/converter/csv/schema_with_11_fields.json 90 gobblin-core/src/test/resources/converter/jsonToAvroRecord.json 29 gobblin-core/src/test/resources/converter/nested_json.json 49 gobblin-core/src/test/resources/converter/nested_schema.json 140 gobblin-core/src/test/resources/converter/record3.json 27 gobblin-core/src/test/resources/converter/schema.json 400 gobblin-core/src/test/resources/publisher/sample_metadata.json 18 gobblin-core/src/test/resources/serde/serde.properties 26 gobblin-core/src/test/resources/source/2017-12/metadata.json 1 gobblin-core/src/test/resources/source/2017-12/simplejson.json 3 gobblin-core/src/test/resources/source/2018-01/metadata.json 1 gobblin-core/src/test/resources/source/2018-01/simplejson.json 3 gobblin-core/src/test/resources/source/2018-01/simplejson2.json 3 gobblin-core/src/test/resources/writer/hive_writer.properties 19 gobblin-data-management/config-example/gobblin-retention.properties 21 gobblin-data-management/src/main/resources/data-management.properties 70 gobblin-data-management/src/test/resources/avroToOrcQueryUtilsTest/arrayWithinRecordWithinArrayWithinRecord_nested.json 21 gobblin-data-management/src/test/resources/avroToOrcQueryUtilsTest/optionWithinOptionWithinRecord_nested.json 31 gobblin-data-management/src/test/resources/avroToOrcQueryUtilsTest/recordWithinOptionWithinRecord_nested.json 21 gobblin-data-management/src/test/resources/avroToOrcQueryUtilsTest/recordWithinRecordWithinRecord_nested.json 34 gobblin-data-management/src/test/resources/avroToOrcQueryUtilsTest/schemaWithLogicalField.json 47 gobblin-data-management/src/test/resources/avroToOrcSchemaEvolutionTest/source_schema.json 34 gobblin-data-management/src/test/resources/convertibleHiveDatasetTest/flattenedAndNestedOrc.properties 31 gobblin-data-management/src/test/resources/hiveConverterTest/recordWithinRecordWithinRecord_nested.json 34 gobblin-data-management/src/test/resources/hiveMaterializerTest/source/part1/data.txt 4 gobblin-data-management/src/test/resources/hiveMaterializerTest/source/part2/data.txt 4 gobblin-data-management/src/test/resources/inputStreamExtractorTest/first.txt 1 gobblin-data-management/src/test/resources/inputStreamExtractorTest/second.txt 1 gobblin-data-management/src/test/resources/manifestBasedDistcpTest/longNestedDirectoryTreeManifest.json 26 gobblin-data-management/src/test/resources/manifestBasedDistcpTest/manifestRootDirEmpty.json 8 gobblin-data-management/src/test/resources/manifestBasedDistcpTest/missingFileNameManifest.json 7 gobblin-data-management/src/test/resources/manifestBasedDistcpTest/sampleManifest.json 14 gobblin-data-management/src/test/resources/manifestBasedDistcpTest/sampleManifestWithOnlyDirectory.json 8 gobblin-data-management/src/test/resources/retentionIntegrationTest/testHiveTimeBasedRetention/jobProps.properties 18 gobblin-docs/Powered-By.md 23 gobblin-docs/case-studies/Hive-Distcp.md 72 gobblin-docs/case-studies/Publishing-Data-to-S3.md 106 gobblin-docs/case-studies/Writing-ORC-Data.md 36 gobblin-docs/data-management/DistcpNgEvents.md 23 gobblin-docs/data-management/Gobblin-Retention.md 277 gobblin-docs/developer-guide/CodingStyle.md 40 gobblin-docs/developer-guide/Contributing.md 13 gobblin-docs/developer-guide/Customization-for-Converter-and-Operator.md 1 gobblin-docs/developer-guide/Customization-for-New-Source.md 1 gobblin-docs/developer-guide/Documentation-Architecture.md 13 gobblin-docs/developer-guide/Gobblin-Compliance-Design.md 73 gobblin-docs/developer-guide/GobblinModules.md 55 gobblin-docs/developer-guide/HighLevelConsumer.md 52 gobblin-docs/developer-guide/IDE-setup.md 21 gobblin-docs/developer-guide/Monitoring-Design.md 3 gobblin-docs/index.md 8 gobblin-docs/metrics/Existing-Reporters.md 16 gobblin-docs/metrics/Gobblin-Metrics-Architecture.md 46 gobblin-docs/metrics/Gobblin-Metrics-Performance.md 42 gobblin-docs/metrics/Gobblin-Metrics-next-generation-instrumentation-for-applications.md 30 gobblin-docs/metrics/Gobblin-Metrics.md 83 gobblin-docs/metrics/Implementing-New-Reporters.md 79 gobblin-docs/miscellaneous/Camus-to-Gobblin-Migration.md 78 gobblin-docs/miscellaneous/Exactly-Once-Support.md 132 gobblin-docs/project/Feature-List.md 16 gobblin-docs/project/Posts.md 1 gobblin-docs/project/Talks-and-Tech-Blogs.md 14 gobblin-docs/sinks/AvroHdfsDataWriter.md 11 gobblin-docs/sinks/ConsoleWriter.md 5 gobblin-docs/sinks/CouchbaseWriter.md 125 gobblin-docs/sinks/Gobblin-JDBC-Writer.md 161 gobblin-docs/sinks/Http.md 88 gobblin-docs/sinks/Kafka.md 56 gobblin-docs/sinks/ParquetHdfsDataWriter.md 32 gobblin-docs/sinks/SimpleBytesWriter.md 9 gobblin-docs/sources/AvroFileSource.md 6 gobblin-docs/sources/CopySource.md 6 gobblin-docs/sources/GoogleAnalyticsSource.md 6 gobblin-docs/sources/GoogleDriveSource.md 6 gobblin-docs/sources/HadoopTextInputSource.md 6 gobblin-docs/sources/HelloWorldSource.md 6 gobblin-docs/sources/HiveAvroToOrcSource.md 6 gobblin-docs/sources/HivePurgerSource.md 6 gobblin-docs/sources/HiveSource.md 6 gobblin-docs/sources/KafkaSource.md 6 gobblin-docs/sources/MySQLSource.md 6 gobblin-docs/sources/OracleSource.md 6 gobblin-docs/sources/QueryBasedSource.md 94 gobblin-docs/sources/RestApiSource.md 39 gobblin-docs/sources/SalesforceSource.md 6 gobblin-docs/sources/SftpSource.md 6 gobblin-docs/sources/SimpleJsonSource.md 6 gobblin-docs/sources/SqlServerSource.md 6 gobblin-docs/sources/TeradataSource.md 6 gobblin-docs/sources/WikipediaSource.md 6 gobblin-docs/user-guide/Azure-Kubernetes-Deployment.md 55 gobblin-docs/user-guide/Building-Gobblin-as-a-Service.md 37 gobblin-docs/user-guide/Building-Gobblin.md 33 gobblin-docs/user-guide/Compaction.md 168 gobblin-docs/user-guide/Config-Management.md 106 gobblin-docs/user-guide/Configuration-Properties-Glossary.md 385 gobblin-docs/user-guide/Docker-Integration.md 61 gobblin-docs/user-guide/FAQs.md 43 gobblin-docs/user-guide/Gobblin-CLI.md 197 gobblin-docs/user-guide/Gobblin-Compliance.md 40 gobblin-docs/user-guide/Gobblin-Deployment.md 47 gobblin-docs/user-guide/Gobblin-as-a-Library.md 58 gobblin-docs/user-guide/Gobblin-genericLoad.md 13 gobblin-docs/user-guide/Gobblin-template.md 47 gobblin-docs/user-guide/Job-Execution-History-Store.md 148 gobblin-docs/user-guide/Monitoring.md 64 gobblin-docs/user-guide/Partitioned-Writers.md 54 gobblin-docs/user-guide/Run-Gobblin-Streaming-kafka-hdfs-Locally.md 16 gobblin-docs/user-guide/Source-schema-and-Converters.md 340 gobblin-docs/user-guide/State-Management-and-Watermarks.md 48 gobblin-docs/user-guide/Troubleshooting.md 80 gobblin-docs/user-guide/Working-with-Job-Configuration-Files.md 75 gobblin-hive-registration/src/test/resources/avro_input/input.json 5 gobblin-iceberg/src/test/resources/publisherTest/data.json 8 gobblin-kubernetes/gobblin-service/base-cluster/README.md 2 gobblin-kubernetes/gobblin-service/mysql-cluster/README.md 3 gobblin-metastore/src/main/resources/readme.txt 20 gobblin-metrics-libs/gobblin-metrics-base/config/checkstyle/suppressions.xml 8 gobblin-metrics-libs/gobblin-metrics-base/src/test/resources/log4j.properties 26 gobblin-modules/gobblin-azkaban/src/main/resources/conf/gobblin_conf/log4j-yarn.properties 23 gobblin-modules/gobblin-azkaban/src/main/resources/conf/properties/common.properties 55 gobblin-modules/gobblin-azkaban/src/main/resources/conf/properties/local.properties 15 gobblin-modules/gobblin-azkaban/src/test/resources/azkakaban-job-basic.properties 6 gobblin-modules/gobblin-crypto-provider/README.md 2 gobblin-modules/gobblin-grok/src/test/resources/converter/grok/convertedRecord.json 1 gobblin-modules/gobblin-grok/src/test/resources/converter/grok/convertedS3AccessLogRecord.json 1 gobblin-modules/gobblin-grok/src/test/resources/converter/grok/s3AccessLogSchema.json 138 gobblin-modules/gobblin-grok/src/test/resources/converter/grok/schemaWithNonNullableFields.json 66 gobblin-modules/gobblin-grok/src/test/resources/converter/grok/schemaWithNullableFields.json 66 gobblin-modules/gobblin-kafka-08/resource/job-props/testKafkaIngest.properties 25 gobblin-modules/gobblin-orc/src/test/resources/converter_memory_manager_nested_test/data.json 38 gobblin-modules/gobblin-orc/src/test/resources/decimal_test/data.json 6 gobblin-modules/gobblin-orc/src/test/resources/list_map_test/data.json 66 gobblin-modules/gobblin-orc/src/test/resources/orc_writer_list_test/data.json 61 gobblin-modules/gobblin-orc/src/test/resources/orc_writer_test/data.json 8 gobblin-modules/gobblin-orc/src/test/resources/orc_writer_test/data_multi.json 16 gobblin-modules/gobblin-orc/src/test/resources/union_test/data.json 25 gobblin-modules/gobblin-parquet-apache/src/test/resources/converter/JsonIntermediateToParquetConverter.json 259 gobblin-modules/gobblin-parquet/src/test/resources/converter/JsonIntermediateToParquetConverter.json 259 gobblin-modules/gobblin-sql/src/test/resources/converter/pickfields_nested_with_union.json 194 gobblin-oozie/src/test/resources/local/gobblin-oozie-example-system.properties 46 gobblin-oozie/src/test/resources/local/gobblin-oozie-example-workflow.properties 24 gobblin-oozie/src/test/resources/mapreduce/gobblin-oozie-mr-example-sysconfig.properties 50 gobblin-oozie/src/test/resources/mapreduce/gobblin-oozie-mr-example-workflow.properties 24 gobblin-rest-service/gobblin-rest-api/config/checkstyle/suppressions.xml 8 gobblin-rest-service/gobblin-rest-api/src/main/idl/org.apache.gobblin.rest.jobExecutions.restspec.json 23 gobblin-rest-service/gobblin-rest-api/src/main/snapshot/org.apache.gobblin.rest.jobExecutions.snapshot.json 350 gobblin-rest-service/gobblin-rest-server/config/checkstyle/suppressions.xml 8 gobblin-rest-service/gobblin-rest-server/gradle.properties 17 gobblin-rest-service/gobblin-rest-server/src/test/resources/gobblin-rest-server-test-log4j.properties 26 gobblin-restli/README.md 17 gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/config/checkstyle/suppressions.xml 8 gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/org.apache.gobblin.service.flowconfigsV2.restspec.json 90 gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/org.apache.gobblin.service.flowexecutions.restspec.json 75 gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/org.apache.gobblin.service.flowstatuses.restspec.json 40 gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/org.apache.gobblin.service.flowconfigsV2.snapshot.json 192 gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/org.apache.gobblin.service.flowexecutions.snapshot.json 338 gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/org.apache.gobblin.service.flowstatuses.snapshot.json 306 gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/test/resources/TestGroups.json 3 gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/config/checkstyle/suppressions.xml 8 gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/config/checkstyle/suppressions.xml 8 gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/org.apache.gobblin.restli.throttling.permits.restspec.json 22 gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/org.apache.gobblin.restli.throttling.policies.restspec.json 20 gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/org.apache.gobblin.restli.throttling.permits.snapshot.json 95 gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/org.apache.gobblin.restli.throttling.policies.snapshot.json 55 gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/webapp/WEB-INF/log4j.properties 23 gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/test/resources/log4j.properties 23 gobblin-runtime/src/test/resources/GobblinClustersNames.properties 20 gobblin-runtime/src/test/resources/gobblin.mr-test.properties 30 gobblin-salesforce/src/main/resources/azkaban/common.properties 80 gobblin-salesforce/src/main/resources/stand-alone/common.properties 55 gobblin-service/src/test/resources/TestGroups.json 3 gobblin-service/src/test/resources/flowgraph/datanodes/AdlsDataNode-1.properties 3 gobblin-service/src/test/resources/flowgraph/datanodes/HdfsDataNode-1.properties 3 gobblin-service/src/test/resources/flowgraph/datanodes/HdfsDataNode-2.properties 3 gobblin-service/src/test/resources/flowgraph/datanodes/HdfsDataNode-3.properties 3 gobblin-service/src/test/resources/flowgraph/datanodes/HdfsDataNode-4.properties 3 gobblin-service/src/test/resources/flowgraph/datanodes/LocalFsDataNode-1.properties 3 gobblin-service/src/test/resources/flowgraph/flowedges/adls-1-to-adls-1-retention-1.properties 5 gobblin-service/src/test/resources/flowgraph/flowedges/adls-1-to-adls-1-retention-2.properties 5 gobblin-service/src/test/resources/flowgraph/flowedges/hdfs-1-to-gridfs.properties 5 gobblin-service/src/test/resources/flowgraph/flowedges/hdfs-1-to-hdfs-1-encrypt.properties 5 gobblin-service/src/test/resources/flowgraph/flowedges/hdfs-1-to-hdfs-1-retention.properties 5 gobblin-service/src/test/resources/flowgraph/flowedges/hdfs-1-to-hdfs-3.properties 5 gobblin-service/src/test/resources/flowgraph/flowedges/hdfs-2-hdfs-2-retention.properties 5 gobblin-service/src/test/resources/flowgraph/flowedges/hdfs-2-to-hdfs-2-encrypt.properties 5 gobblin-service/src/test/resources/flowgraph/flowedges/hdfs-2-to-hdfs-4.properties 5 gobblin-service/src/test/resources/flowgraph/flowedges/hdfs-3-to-adls-1.properties 8 gobblin-service/src/test/resources/flowgraph/flowedges/hdfs-3-to-hdfs-3-retention.properties 5 gobblin-service/src/test/resources/flowgraph/flowedges/hdfs-4-to-adls-1.properties 8 gobblin-service/src/test/resources/flowgraph/flowedges/hdfs-4-to-hdfs-4-retention.properties 5 gobblin-service/src/test/resources/flowgraph/flowedges/local-to-hdfs-1.properties 5 gobblin-service/src/test/resources/flowgraph/flowedges/local-to-hdfs-2.properties 5 gobblin-service/src/test/resources/flowgraph/flowedges/local-to-local-retention.properties 5 gobblin-service/src/test/resources/topologyspec_catalog/azkaban01.properties 2 gobblin-service/src/test/resources/topologyspec_catalog/azkaban02.properties 2 gobblin-service/src/test/resources/topologyspec_catalog/azkaban03.properties 2 gobblin-service/src/test/resources/topologyspec_catalog/azkaban04.properties 2 gobblin-service/src/test/resources/topologyspec_catalog/local01.properties 2 gobblin-service/src/test/resources/topologyspec_catalog/testExecutor1.properties 3 gobblin-service/src/test/resources/topologyspec_catalog/testExecutor2.properties 3 gobblin-test-harness/resource/dataManagement/copy/job-props/copy.properties 26 gobblin-test-harness/src/test/resources/runtime_test/skip_workunits_test.properties 25 gobblin-test-harness/src/test/resources/runtime_test/task_skip_err_records.properties 35 gobblin-test-harness/src/test/resources/runtime_test/writer_output_format_test.properties 31 gobblin-test/resource/gobblin.mr-test.properties 30 gobblin-test/resource/gobblin.test.properties 29 gobblin-test/resource/quartz.properties 19 gobblin-utility/src/test/resources/GobblinClustersNames.properties 23 gobblin-utility/src/test/resources/flattenAvro/arrayWithinRecordWithinArrayWithinRecord_flattened.json 21 gobblin-utility/src/test/resources/flattenAvro/arrayWithinRecordWithinArrayWithinRecord_original.json 21 gobblin-utility/src/test/resources/flattenAvro/nonNullDefaultWithinOptionWithinRecord_flattened.json 37 gobblin-utility/src/test/resources/flattenAvro/nonNullDefaultWithinOptionWithinRecord_original.json 33 gobblin-utility/src/test/resources/flattenAvro/optionWithinOptionWithinRecord_flattened.json 23 gobblin-utility/src/test/resources/flattenAvro/optionWithinOptionWithinRecord_original.json 31 gobblin-utility/src/test/resources/flattenAvro/recordWithinArrayWithinArray_flattened.json 14 gobblin-utility/src/test/resources/flattenAvro/recordWithinArrayWithinArray_original.json 14 gobblin-utility/src/test/resources/flattenAvro/recordWithinMapWithinMap_flattened.json 14 gobblin-utility/src/test/resources/flattenAvro/recordWithinMapWithinMap_original.json 14 gobblin-utility/src/test/resources/flattenAvro/recordWithinOptionWithinRecord_flattened.json 18 gobblin-utility/src/test/resources/flattenAvro/recordWithinOptionWithinRecord_original.json 21 gobblin-utility/src/test/resources/flattenAvro/recordWithinRecordWithinRecord_flattened.json 24 gobblin-utility/src/test/resources/flattenAvro/recordWithinRecordWithinRecord_original.json 34 gobblin-utility/src/test/resources/flattenAvro/recordWithinRecord_flattened.json 16 gobblin-utility/src/test/resources/flattenAvro/recordWithinRecord_original.json 21 gobblin-utility/src/test/resources/flattenAvro/recordWithinUnionWithinRecord_flattened.json 16 gobblin-utility/src/test/resources/flattenAvro/recordWithinUnionWithinRecord_original.json 25 gobblin-utility/src/test/resources/log4j.properties 23 gobblin-utility/src/test/resources/props/schema_with_field_props.json 23 gobblin-utility/src/test/resources/props/schema_with_logical_field.json 34 gobblin-utility/src/test/resources/props/schema_with_props.json 22 gobblin-utility/src/test/resources/props/schema_without_field_props.json 22 gobblin-utility/src/test/resources/props/schema_without_props.json 20 gobblin-utility/src/test/resources/pullFileLoaderTest/root.properties 18 gobblin-utility/src/test/resources/test_data.json 2 gobblin-yarn/src/test/resources/log4j-yarn.properties 29 gobblin-yarn/src/test/resources/log4j.properties 29 gradle.properties 32