Introducing Airbyte (#348)
This commit is contained in:
4
.env
4
.env
@@ -1,10 +1,10 @@
|
||||
VERSION=0.1.0
|
||||
DATABASE_USER=docker
|
||||
DATABASE_PASSWORD=docker
|
||||
DATABASE_DB=dataline
|
||||
DATABASE_DB=airbyte
|
||||
CONFIG_ROOT=/data
|
||||
WORKSPACE_ROOT=/tmp/workspace
|
||||
WORKSPACE_DOCKER_MOUNT=workspace
|
||||
LOCAL_ROOT=/tmp/dataline_local
|
||||
LOCAL_ROOT=/tmp/airbyte_local
|
||||
LOCAL_DOCKER_MOUNT=local
|
||||
TRACKING_STRATEGY=segment
|
||||
|
||||
4
.env.dev
4
.env.dev
@@ -3,11 +3,11 @@
|
||||
VERSION=dev
|
||||
DATABASE_USER=docker
|
||||
DATABASE_PASSWORD=docker
|
||||
DATABASE_DB=dataline
|
||||
DATABASE_DB=airbyte
|
||||
DEV_ROOT=/tmp/dev_root
|
||||
CONFIG_ROOT=/tmp/data
|
||||
WORKSPACE_ROOT=/tmp/workspace
|
||||
WORKSPACE_DOCKER_MOUNT=dev-workspace
|
||||
LOCAL_ROOT=/tmp/dataline_local
|
||||
LOCAL_ROOT=/tmp/airbyte_local
|
||||
LOCAL_DOCKER_MOUNT=dev-local
|
||||
TRACKING_STRATEGY=logging
|
||||
|
||||
6
.github/workflows/gradle.yml
vendored
6
.github/workflows/gradle.yml
vendored
@@ -1,4 +1,4 @@
|
||||
name: Dataline CI
|
||||
name: Airbyte CI
|
||||
|
||||
on: push
|
||||
|
||||
@@ -8,7 +8,7 @@ jobs:
|
||||
GRADLE_PATH: /tmp/gradle
|
||||
runs-on: ubuntu-latest
|
||||
steps:
|
||||
- name: Checkout Dataline
|
||||
- name: Checkout Airbyte
|
||||
uses: actions/checkout@v2
|
||||
|
||||
- name: Cache java deps
|
||||
@@ -62,7 +62,7 @@ jobs:
|
||||
- name: Push Core Docker Images
|
||||
if: success() && github.ref == 'refs/heads/master'
|
||||
run: |
|
||||
docker login -u datalinebot -p ${DOCKER_PASSWORD}
|
||||
docker login -u airbytebot -p ${DOCKER_PASSWORD}
|
||||
docker-compose -f docker-compose.build.yaml push
|
||||
env:
|
||||
DOCKER_PASSWORD: ${{ secrets.DOCKER_PASSWORD }}
|
||||
|
||||
1
.gitignore
vendored
1
.gitignore
vendored
@@ -3,5 +3,4 @@
|
||||
build
|
||||
!tools/build
|
||||
.DS_Store
|
||||
dataline-db/pg_data/*
|
||||
data
|
||||
|
||||
@@ -1,2 +1,2 @@
|
||||
# Code of conduct
|
||||
View in [docs.dataline.io](https://docs.dataline.io/contributing/contributing-to-dataline/code-of-conduct)
|
||||
View in [docs.airbyte.io](https://docs.airbyte.io/contributing/contributing-to-airbyte/code-of-conduct)
|
||||
|
||||
@@ -1,2 +1,2 @@
|
||||
# Contributing
|
||||
View on [docs.dataline.io](https://docs.dataline.io/contributing/contributing-to-dataline)
|
||||
View on [docs.airbyte.io](https://docs.airbyte.io/contributing/contributing-to-airbyte)
|
||||
|
||||
2
LICENSE
2
LICENSE
@@ -1,6 +1,6 @@
|
||||
MIT License
|
||||
|
||||
Copyright (c) 2020 Dataline
|
||||
Copyright (c) 2020 Airbyte
|
||||
|
||||
Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
of this software and associated documentation files (the "Software"), to deal
|
||||
|
||||
30
README.md
30
README.md
@@ -1,21 +1,21 @@
|
||||
# Getting Started
|
||||
|
||||
 
|
||||
 
|
||||
|
||||
[](https://dataline.io)
|
||||
[](https://airbyte.io)
|
||||
|
||||
### Data integration made simple, secure and reliable.
|
||||
|
||||
The new open-source standard to sync data from applications & databases to warehouses.
|
||||
|
||||
[](https://docs.dataline.io/deployment/deploying-dataline/with-docker) [](https://docs.dataline.io/deployment/deploying-dataline/on-aws-ec2) [](https://docs.dataline.io/deployment/deploying-dataline/on-gcp-compute-engine)
|
||||
[](https://docs.airbyte.io/deployment/deploying-airbyte/with-docker) [](https://docs.airbyte.io/deployment/deploying-airbyte/on-aws-ec2) [](https://docs.airbyte.io/deployment/deploying-airbyte/on-gcp-compute-engine)
|
||||
|
||||

|
||||
|
||||
Dataline is on a mission to make data integration pipelines a commodity.
|
||||
Airbyte is on a mission to make data integration pipelines a commodity.
|
||||
|
||||
* **Maintenance-free connectors you can use in minutes**. Just authenticate your sources and warehouse, and get connectors that adapts to schema and API changes for you.
|
||||
* On a mission to **cover the long tail of integrations**, as Dataline will be very active in maintaining the pipelines’ reliability.
|
||||
* On a mission to **cover the long tail of integrations**, as Airbyte will be very active in maintaining the pipelines’ reliability.
|
||||
* **Building new integrations made trivial**. We make it very easy to add new integrations that you need, by offering scheduling and orchestration.
|
||||
* **Your data stays in your cloud**. Have full control over your data, and the costs of your data transfers.
|
||||
* **No more security compliance process** to go through as self-hosted.
|
||||
@@ -26,8 +26,8 @@ Dataline is on a mission to make data integration pipelines a commodity.
|
||||
### Quick start
|
||||
|
||||
```bash
|
||||
git clone git@github.com:datalineio/dataline.git
|
||||
cd dataline
|
||||
git clone git@github.com:airbytehq/airbyte.git
|
||||
cd airbyte
|
||||
docker-compose up
|
||||
```
|
||||
|
||||
@@ -42,25 +42,25 @@ Now visit [http://localhost:8000](http://localhost:8000)
|
||||
* **Manual full refresh**: Sometimes, you need to re-sync all your data to start again.
|
||||
* **Granular system logs**: No opacity whatsoever to let you control and trust.
|
||||
|
||||
[See more on our website.](https://dataline.io/features/)
|
||||
[See more on our website.](https://airbyte.io/features/)
|
||||
|
||||
## Contributing
|
||||
|
||||
We love contributions to Dataline, big or small. See our [Contributing Guide](https://docs.dataline.io/contributing/contributing-to-dataline) on how to get started. Not sure where to start? We’ve listed some [good first issues](https://github.com/datalineio/dataline/labels/good%20first%20issue) to start with. You can also [book a free, no-pressure pairing session](https://drift.me/micheltricot/meeting) with one of our core contributors.
|
||||
We love contributions to Airbyte, big or small. See our [Contributing Guide](https://docs.airbyte.io/contributing/contributing-to-airbyte) on how to get started. Not sure where to start? We’ve listed some [good first issues](https://github.com/airbytehq/airbyte/labels/good%20first%20issue) to start with. You can also [book a free, no-pressure pairing session](https://drift.me/micheltricot/meeting) with one of our core contributors.
|
||||
|
||||
## Community support
|
||||
|
||||
For general help using Dataline, please refer to the official Dataline documentation. For additional help, you can use one of these channels to ask a question:
|
||||
For general help using Airbyte, please refer to the official Airbyte documentation. For additional help, you can use one of these channels to ask a question:
|
||||
|
||||
* [Slack](https://join.slack.com/t/datalinehq/shared_invite/zt-h5m88w3a-twQ_6AF9e8SnAzOIkHu2VQ) \(For live discussion with the Community and Dataline team\)
|
||||
* [GitHub](https://github.com/datalineio/dataline) \(Bug reports, Contributions\)
|
||||
* [Twitter](https://twitter.com/datalinehq) \(Get the news fast\)
|
||||
* [Slack](https://join.slack.com/t/airbytehq/shared_invite/zt-h5m88w3a-twQ_6AF9e8SnAzOIkHu2VQ) \(For live discussion with the Community and Airbyte team\)
|
||||
* [GitHub](https://github.com/airbytehq/airbyte) \(Bug reports, Contributions\)
|
||||
* [Twitter](https://twitter.com/airbytehq) \(Get the news fast\)
|
||||
|
||||
## Roadmap
|
||||
|
||||
Check out our [roadmap](https://github.com/datalineio/dataline/projects/1) to get informed of the latest features released and the upcoming ones. You may also give us insights and vote for a specific feature. For our high-level roadmap and strategy, you can check [our handbook](https://docs.dataline.io/company-handbook/company-handbook/roadmap).
|
||||
Check out our [roadmap](https://github.com/airbytehq/airbyte/projects/1) to get informed of the latest features released and the upcoming ones. You may also give us insights and vote for a specific feature. For our high-level roadmap and strategy, you can check [our handbook](https://docs.airbyte.io/company-handbook/company-handbook/roadmap).
|
||||
|
||||
## License
|
||||
|
||||
Dataline is licensed under the MIT license. See the [LICENSE](https://docs.dataline.io/license) file for licensing information.
|
||||
Airbyte is licensed under the MIT license. See the [LICENSE](https://docs.airbyte.io/license) file for licensing information.
|
||||
|
||||
|
||||
7
airbyte-analytics/build.gradle
Normal file
7
airbyte-analytics/build.gradle
Normal file
@@ -0,0 +1,7 @@
|
||||
dependencies {
|
||||
implementation 'com.segment.analytics.java:analytics:2.1.1'
|
||||
|
||||
|
||||
implementation project(':airbyte-config:models')
|
||||
implementation project(':airbyte-config:persistence')
|
||||
}
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.analytics;
|
||||
package io.airbyte.analytics;
|
||||
|
||||
import java.util.Collections;
|
||||
import java.util.Map;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.analytics;
|
||||
package io.airbyte.analytics;
|
||||
|
||||
import com.google.common.annotations.VisibleForTesting;
|
||||
import com.google.common.collect.ImmutableMap;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.analytics;
|
||||
package io.airbyte.analytics;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,15 +22,15 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.analytics;
|
||||
package io.airbyte.analytics;
|
||||
|
||||
import com.google.common.annotations.VisibleForTesting;
|
||||
import io.dataline.commons.json.JsonValidationException;
|
||||
import io.dataline.config.Configs;
|
||||
import io.dataline.config.StandardWorkspace;
|
||||
import io.dataline.config.persistence.ConfigNotFoundException;
|
||||
import io.dataline.config.persistence.ConfigRepository;
|
||||
import io.dataline.config.persistence.PersistenceConstants;
|
||||
import io.airbyte.commons.json.JsonValidationException;
|
||||
import io.airbyte.config.Configs;
|
||||
import io.airbyte.config.StandardWorkspace;
|
||||
import io.airbyte.config.persistence.ConfigNotFoundException;
|
||||
import io.airbyte.config.persistence.ConfigRepository;
|
||||
import io.airbyte.config.persistence.PersistenceConstants;
|
||||
import java.io.IOException;
|
||||
import java.util.function.Supplier;
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.analytics;
|
||||
package io.airbyte.analytics;
|
||||
|
||||
import java.util.Objects;
|
||||
import java.util.Optional;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.analytics;
|
||||
package io.airbyte.analytics;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||
import static org.mockito.Mockito.mock;
|
||||
@@ -40,7 +40,7 @@ import org.mockito.ArgumentCaptor;
|
||||
|
||||
class SegmentTrackingClientTest {
|
||||
|
||||
private static final TrackingIdentity identity = new TrackingIdentity(UUID.randomUUID(), "a@dataline.io", false, false, true);
|
||||
private static final TrackingIdentity identity = new TrackingIdentity(UUID.randomUUID(), "a@airbyte.io", false, false, true);
|
||||
|
||||
private Analytics analytics;
|
||||
private SegmentTrackingClient segmentTrackingClient;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,19 +22,19 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.analytics;
|
||||
package io.airbyte.analytics;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||
import static org.junit.jupiter.api.Assertions.assertTrue;
|
||||
import static org.mockito.Mockito.mock;
|
||||
import static org.mockito.Mockito.when;
|
||||
|
||||
import io.dataline.commons.json.JsonValidationException;
|
||||
import io.dataline.config.Configs;
|
||||
import io.dataline.config.StandardWorkspace;
|
||||
import io.dataline.config.persistence.ConfigNotFoundException;
|
||||
import io.dataline.config.persistence.ConfigRepository;
|
||||
import io.dataline.config.persistence.PersistenceConstants;
|
||||
import io.airbyte.commons.json.JsonValidationException;
|
||||
import io.airbyte.config.Configs;
|
||||
import io.airbyte.config.StandardWorkspace;
|
||||
import io.airbyte.config.persistence.ConfigNotFoundException;
|
||||
import io.airbyte.config.persistence.ConfigRepository;
|
||||
import io.airbyte.config.persistence.PersistenceConstants;
|
||||
import java.io.IOException;
|
||||
import java.util.UUID;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
@@ -91,7 +91,7 @@ class TrackingClientSingletonTest {
|
||||
void testGetTrackingIdentityNonAnonymous() throws JsonValidationException, IOException, ConfigNotFoundException {
|
||||
final StandardWorkspace workspace = new StandardWorkspace()
|
||||
.withCustomerId(UUID.randomUUID())
|
||||
.withEmail("a@dataline.io")
|
||||
.withEmail("a@airbyte.io")
|
||||
.withAnonymousDataCollection(false)
|
||||
.withNews(true)
|
||||
.withSecurityUpdates(true);
|
||||
@@ -108,7 +108,7 @@ class TrackingClientSingletonTest {
|
||||
void testGetTrackingIdentityAnonymous() throws JsonValidationException, IOException, ConfigNotFoundException {
|
||||
final StandardWorkspace workspace = new StandardWorkspace()
|
||||
.withCustomerId(UUID.randomUUID())
|
||||
.withEmail("a@dataline.io")
|
||||
.withEmail("a@airbyte.io")
|
||||
.withAnonymousDataCollection(true)
|
||||
.withNews(true)
|
||||
.withSecurityUpdates(true);
|
||||
@@ -17,9 +17,9 @@ task generateApiServer(type: GenerateTask) {
|
||||
inputSpec = specFile
|
||||
outputDir = serverOutputDir
|
||||
|
||||
apiPackage = "io.dataline.api"
|
||||
invokerPackage = "io.dataline.api.invoker"
|
||||
modelPackage = "io.dataline.api.model"
|
||||
apiPackage = "io.airbyte.api"
|
||||
invokerPackage = "io.airbyte.api.invoker"
|
||||
modelPackage = "io.airbyte.api.model"
|
||||
|
||||
importMappings = [
|
||||
'SourceSpecification' : 'com.fasterxml.jackson.databind.JsonNode',
|
||||
@@ -48,9 +48,9 @@ task generateApiClient(type: GenerateTask) {
|
||||
inputSpec = specFile
|
||||
outputDir = clientOutputDir
|
||||
|
||||
apiPackage = "io.dataline.api.client"
|
||||
invokerPackage = "io.dataline.api.client.invoker"
|
||||
modelPackage = "io.dataline.api.client.model"
|
||||
apiPackage = "io.airbyte.api.client"
|
||||
invokerPackage = "io.airbyte.api.client.invoker"
|
||||
modelPackage = "io.airbyte.api.client.model"
|
||||
|
||||
importMappings = [
|
||||
'SourceSpecification' : 'com.fasterxml.jackson.databind.JsonNode',
|
||||
@@ -79,9 +79,9 @@ task generateApiDocs(type: GenerateTask) {
|
||||
inputSpec = specFile
|
||||
outputDir = docsOutputDir
|
||||
|
||||
apiPackage = "io.dataline.api.client"
|
||||
invokerPackage = "io.dataline.api.client.invoker"
|
||||
modelPackage = "io.dataline.api.client.model"
|
||||
apiPackage = "io.airbyte.api.client"
|
||||
invokerPackage = "io.airbyte.api.client.invoker"
|
||||
modelPackage = "io.airbyte.api.client.model"
|
||||
|
||||
importMappings = [
|
||||
'SourceSpecification' : 'com.fasterxml.jackson.databind.JsonNode',
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,9 +22,9 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.api.client;
|
||||
package io.airbyte.api.client;
|
||||
|
||||
import io.dataline.api.client.invoker.ApiClient;
|
||||
import io.airbyte.api.client.invoker.ApiClient;
|
||||
|
||||
/**
|
||||
* This class is meant to consolidate all our API endpoints into a fluent-ish client. Currently, all
|
||||
@@ -38,7 +38,7 @@ import io.dataline.api.client.invoker.ApiClient;
|
||||
*
|
||||
* This is currently manually maintained. We could look into autogenerating it if needed.
|
||||
*/
|
||||
public class DatalineApiClient {
|
||||
public class AirbyteApiClient {
|
||||
|
||||
private final ConnectionApi connectionApi;
|
||||
private final DestinationApi destinationApi;
|
||||
@@ -50,7 +50,7 @@ public class DatalineApiClient {
|
||||
private final SourceSpecificationApi sourceSpecificationApi;
|
||||
private final WorkspaceApi workspaceApi;
|
||||
|
||||
public DatalineApiClient(ApiClient apiClient) {
|
||||
public AirbyteApiClient(ApiClient apiClient) {
|
||||
connectionApi = new ConnectionApi(apiClient);
|
||||
destinationApi = new DestinationApi(apiClient);
|
||||
destinationImplementationApi = new DestinationImplementationApi(apiClient);
|
||||
@@ -1,8 +1,8 @@
|
||||
openapi: 3.0.0
|
||||
info:
|
||||
description: |
|
||||
Dataline Configuration API
|
||||
[https://dataline.io](https://dataline.io).
|
||||
Airbyte Configuration API
|
||||
[https://airbyte.io](https://airbyte.io).
|
||||
|
||||
This API is a collection HTTP RPC-style methods. While it is not a REST API, those familiar with REST should find the conventions of this API recognizable.
|
||||
|
||||
@@ -20,15 +20,15 @@ info:
|
||||
* Adding new HTTP endpoints.
|
||||
|
||||
version: "1.0.0-oas3"
|
||||
title: Dataline Configuration API
|
||||
title: Airbyte Configuration API
|
||||
contact:
|
||||
email: contact@dataline.io
|
||||
email: contact@airbyte.io
|
||||
license:
|
||||
name: MIT
|
||||
url: "https://opensource.org/licenses/MIT"
|
||||
externalDocs:
|
||||
description: Find out more about Dataline
|
||||
url: "https://dataline.io"
|
||||
description: Find out more about Airbyte
|
||||
url: "https://airbyte.io"
|
||||
servers:
|
||||
- url: "localhost:8001"
|
||||
tags:
|
||||
@@ -125,7 +125,7 @@ paths:
|
||||
post:
|
||||
tags:
|
||||
- source
|
||||
summary: List all of the sources that Dataline supports
|
||||
summary: List all of the sources that Airbyte supports
|
||||
operationId: listSources
|
||||
responses:
|
||||
"200":
|
||||
@@ -341,7 +341,7 @@ paths:
|
||||
post:
|
||||
tags:
|
||||
- destination
|
||||
summary: List all of the destinations that Dataline supports
|
||||
summary: List all of the destinations that Airbyte supports
|
||||
operationId: listDestinations
|
||||
responses:
|
||||
"200":
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,9 +22,9 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.concurrency;
|
||||
package io.airbyte.commons.concurrency;
|
||||
|
||||
import io.dataline.commons.functional.CheckedConsumer;
|
||||
import io.airbyte.commons.functional.CheckedConsumer;
|
||||
import java.util.concurrent.Callable;
|
||||
|
||||
public class LifecycledCallable<T> implements Callable<T> {
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.concurrency;
|
||||
package io.airbyte.commons.concurrency;
|
||||
|
||||
import java.util.concurrent.Callable;
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.enums;
|
||||
package io.airbyte.commons.enums;
|
||||
|
||||
import com.google.common.base.Preconditions;
|
||||
import com.google.common.collect.Sets;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.functional;
|
||||
package io.airbyte.commons.functional;
|
||||
|
||||
@FunctionalInterface
|
||||
public interface CheckedConsumer<T, E extends Throwable> {
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.functional;
|
||||
package io.airbyte.commons.functional;
|
||||
|
||||
@FunctionalInterface
|
||||
public interface CheckedSupplier<T, E extends Throwable> {
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.functional;
|
||||
package io.airbyte.commons.functional;
|
||||
|
||||
import java.util.function.Consumer;
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.io;
|
||||
package io.airbyte.commons.io;
|
||||
|
||||
import com.google.common.base.Charsets;
|
||||
import java.io.BufferedReader;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,9 +22,9 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.io;
|
||||
package io.airbyte.commons.io;
|
||||
|
||||
import io.dataline.commons.concurrency.VoidCallable;
|
||||
import io.airbyte.commons.concurrency.VoidCallable;
|
||||
import java.io.BufferedReader;
|
||||
import java.io.InputStream;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.json;
|
||||
package io.airbyte.commons.json;
|
||||
|
||||
import com.fasterxml.jackson.databind.JsonNode;
|
||||
import com.google.common.base.Preconditions;
|
||||
@@ -30,7 +30,7 @@ import com.networknt.schema.JsonSchemaFactory;
|
||||
import com.networknt.schema.SchemaValidatorsConfig;
|
||||
import com.networknt.schema.SpecVersion;
|
||||
import com.networknt.schema.ValidationMessage;
|
||||
import io.dataline.commons.string.Strings;
|
||||
import io.airbyte.commons.string.Strings;
|
||||
import java.io.File;
|
||||
import java.io.IOException;
|
||||
import java.util.Set;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.json;
|
||||
package io.airbyte.commons.json;
|
||||
|
||||
public class JsonValidationException extends Exception {
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.json;
|
||||
package io.airbyte.commons.json;
|
||||
|
||||
import com.fasterxml.jackson.core.JsonProcessingException;
|
||||
import com.fasterxml.jackson.core.type.TypeReference;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.resources;
|
||||
package io.airbyte.commons.resources;
|
||||
|
||||
import com.google.common.base.Preconditions;
|
||||
import com.google.common.io.Resources;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.string;
|
||||
package io.airbyte.commons.string;
|
||||
|
||||
import com.google.common.collect.Streams;
|
||||
import java.util.stream.Collectors;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.concurrency;
|
||||
package io.airbyte.commons.concurrency;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||
import static org.junit.jupiter.api.Assertions.assertThrows;
|
||||
@@ -30,7 +30,7 @@ import static org.mockito.Mockito.inOrder;
|
||||
import static org.mockito.Mockito.mock;
|
||||
import static org.mockito.Mockito.when;
|
||||
|
||||
import io.dataline.commons.functional.CheckedConsumer;
|
||||
import io.airbyte.commons.functional.CheckedConsumer;
|
||||
import java.util.concurrent.Callable;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.Test;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,10 +22,10 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.enums;
|
||||
package io.airbyte.commons.enums;
|
||||
|
||||
import static io.dataline.commons.enums.Enums.convertTo;
|
||||
import static io.dataline.commons.enums.Enums.isCompatible;
|
||||
import static io.airbyte.commons.enums.Enums.convertTo;
|
||||
import static io.airbyte.commons.enums.Enums.isCompatible;
|
||||
|
||||
import org.junit.jupiter.api.Assertions;
|
||||
import org.junit.jupiter.api.Test;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.io;
|
||||
package io.airbyte.commons.io;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
|
||||
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.io;
|
||||
package io.airbyte.commons.io;
|
||||
|
||||
import static org.mockito.ArgumentMatchers.*;
|
||||
import static org.mockito.Mockito.spy;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.json;
|
||||
package io.airbyte.commons.json;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
|
||||
import static org.junit.jupiter.api.Assertions.assertFalse;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.json;
|
||||
package io.airbyte.commons.json;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import com.fasterxml.jackson.core.type.TypeReference;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,11 +22,11 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.logging;
|
||||
package io.airbyte.commons.logging;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertTrue;
|
||||
|
||||
import io.dataline.commons.io.IOs;
|
||||
import io.airbyte.commons.io.IOs;
|
||||
import java.io.IOException;
|
||||
import java.nio.file.Files;
|
||||
import java.nio.file.Path;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.resources;
|
||||
package io.airbyte.commons.resources;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.*;
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.commons.string;
|
||||
package io.airbyte.commons.string;
|
||||
|
||||
import com.google.common.collect.Lists;
|
||||
import org.junit.jupiter.api.Assertions;
|
||||
@@ -19,7 +19,7 @@
|
||||
"examples": ["\""]
|
||||
},
|
||||
"destination_path": {
|
||||
"description": "Path to write the data. This path will be concatenated onto the `LOCAL_ROOT`. e.g. If `LOCAL_ROOT = /tmp/dataline_local` and destination_path is `cars/models`, then the directory `/tmp/dataline_local/cars/models`. By default `LOCAL_ROOT` is `/tmp/dataline_local`.",
|
||||
"description": "Path to write the data. This path will be concatenated onto the `LOCAL_ROOT`. e.g. If `LOCAL_ROOT = /tmp/airbyte_local` and destination_path is `cars/models`, then the directory `/tmp/airbyte_local/cars/models`. By default `LOCAL_ROOT` is `/tmp/airbyte_local`.",
|
||||
"type": "string"
|
||||
}
|
||||
}
|
||||
@@ -6,7 +6,7 @@ jsonSchema2Pojo {
|
||||
source = files("${sourceSets.main.output.resourcesDir}/json")
|
||||
targetDirectory = new File(project.buildDir, 'generated/src/gen/java/')
|
||||
|
||||
targetPackage = 'io.dataline.config'
|
||||
targetPackage = 'io.airbyte.config'
|
||||
useLongIntegers = true
|
||||
|
||||
removeOldOutput = true
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,10 +22,10 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.config;
|
||||
package io.airbyte.config;
|
||||
|
||||
import io.dataline.commons.io.IOs;
|
||||
import io.dataline.commons.resources.MoreResources;
|
||||
import io.airbyte.commons.io.IOs;
|
||||
import io.airbyte.commons.resources.MoreResources;
|
||||
import java.io.File;
|
||||
import java.io.IOException;
|
||||
import java.nio.file.Files;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.config;
|
||||
package io.airbyte.config;
|
||||
|
||||
import java.nio.file.Path;
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.config;
|
||||
package io.airbyte.config;
|
||||
|
||||
import com.google.common.base.Preconditions;
|
||||
import java.nio.file.Path;
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,9 +22,9 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.config.helpers;
|
||||
package io.airbyte.config.helpers;
|
||||
|
||||
import io.dataline.config.Schedule;
|
||||
import io.airbyte.config.Schedule;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
public class ScheduleHelpers {
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/DataType.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/DataType.json",
|
||||
"title": "DataType",
|
||||
"description": "standard data types.",
|
||||
"type": "string",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/DestinationConnectionImplementation.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/DestinationConnectionImplementation.json",
|
||||
"title": "DestinationConnectionImplementation",
|
||||
"description": "information required for connection to a destination.",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/DestinationSpecification.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/DestinationSpecification.json",
|
||||
"title": "DestinationConnectionSpecification",
|
||||
"description": "specification for how to configure a connection to a destination",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/JobCheckConnectionConfig.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/JobCheckConnectionConfig.json",
|
||||
"title": "JobCheckConnectionConfig",
|
||||
"description": "job check connection config",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/JobConfig.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/JobConfig.json",
|
||||
"title": "JobConfig",
|
||||
"description": "job config",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/JobCheckConnectionConfig.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/JobCheckConnectionConfig.json",
|
||||
"title": "JobCheckConnectionConfig",
|
||||
"description": "job check connection config",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/JobOutput.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/JobOutput.json",
|
||||
"title": "JobOutput",
|
||||
"description": "job output",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/JobSyncConfig.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/JobSyncConfig.json",
|
||||
"title": "JobSyncConfig",
|
||||
"description": "job sync config",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/SourceConnectionConfiguration.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/SourceConnectionConfiguration.json",
|
||||
"title": "SourceConnectionConfiguration",
|
||||
"description": "information required for connection to a destination.",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/SourceSpecification.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/SourceSpecification.json",
|
||||
"title": "SourceConnectionSpecification",
|
||||
"description": "specification for how to configure a connection to a source",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/PublicCheckConnection.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/PublicCheckConnection.json",
|
||||
"title": "PublicCheckConnection",
|
||||
"description": "information required for connection.",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/StandardCheckConnectionOutput.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/StandardCheckConnectionOutput.json",
|
||||
"title": "StandardCheckConnectionOutput",
|
||||
"description": "describes the result of a 'check connection' action.",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/StandardDataSchema.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/StandardDataSchema.json",
|
||||
"title": "StandardDataSchema",
|
||||
"type": "object",
|
||||
"definitions": {
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/Destination.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/Destination.json",
|
||||
"title": "Source",
|
||||
"description": "describes a destination",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/StandardDiscoverSchemaOutput.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/StandardDiscoverSchemaOutput.json",
|
||||
"title": "StandardDiscoverSchemaOutput",
|
||||
"description": "information required for connection.",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/StandardDiscoverSchemaOutput.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/StandardDiscoverSchemaOutput.json",
|
||||
"title": "StandardDiscoverSchemaOutput",
|
||||
"description": "describes the standard output for any discovery run.",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/Source.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/Source.json",
|
||||
"title": "Source",
|
||||
"description": "describes a source",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/StandardSync.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/StandardSync.json",
|
||||
"title": "StandardSync",
|
||||
"description": "configuration required for sync for ALL taps",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/JobSyncConfig.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/JobSyncConfig.json",
|
||||
"title": "JobSyncConfig",
|
||||
"description": "job sync config",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/StandardSyncOutput.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/StandardSyncOutput.json",
|
||||
"title": "StandardSyncOutput",
|
||||
"description": "job sync config",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/StandardSyncSchedule.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/StandardSyncSchedule.json",
|
||||
"description": "ideally this should be a union but java codegen does not handle the union type properly.",
|
||||
"title": "StandardScheduleConfiguration",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/StandardSyncSummary.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/StandardSyncSummary.json",
|
||||
"title": "StandardSyncSummary",
|
||||
"description": "standard information output by ALL taps for a sync step (our version of state.json)",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/StandardTapConfig.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/StandardTapConfig.json",
|
||||
"title": "StandardTapConfig",
|
||||
"description": "StandardTapConfig",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/StandardTargetConfig.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/StandardTargetConfig.json",
|
||||
"title": "StandardTargetConfig",
|
||||
"description": "StandardTargetConfig",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/StandardWorkspaceConfiguration.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/StandardWorkspaceConfiguration.json",
|
||||
"title": "StandardWorkspace",
|
||||
"description": "workspace configuration",
|
||||
"type": "object",
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"$schema": "http://json-schema.org/draft-07/schema#",
|
||||
"$id": "https://github.com/datalineio/dataline/blob/master/dataline-config/src/main/resources/json/State.json",
|
||||
"$id": "https://github.com/airbytehq/airbyte/blob/master/airbyte-config/src/main/resources/json/State.json",
|
||||
"title": "State",
|
||||
"description": "information output by the connection.",
|
||||
"type": "object",
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.config;
|
||||
package io.airbyte.config;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertTrue;
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,7 +22,7 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.config;
|
||||
package io.airbyte.config;
|
||||
|
||||
import static org.mockito.Mockito.when;
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,11 +22,11 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.config.helpers;
|
||||
package io.airbyte.config.helpers;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||
|
||||
import io.dataline.config.Schedule;
|
||||
import io.airbyte.config.Schedule;
|
||||
import java.util.Arrays;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
dependencies {
|
||||
implementation group: 'commons-io', name: 'commons-io', version: '2.7'
|
||||
|
||||
implementation project(':dataline-config:models')
|
||||
implementation project(':airbyte-config:models')
|
||||
}
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,9 +22,9 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.config.persistence;
|
||||
package io.airbyte.config.persistence;
|
||||
|
||||
import io.dataline.config.ConfigSchema;
|
||||
import io.airbyte.config.ConfigSchema;
|
||||
|
||||
public class ConfigNotFoundException extends Exception {
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
/*
|
||||
* MIT License
|
||||
*
|
||||
* Copyright (c) 2020 Dataline
|
||||
* Copyright (c) 2020 Airbyte
|
||||
*
|
||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
* of this software and associated documentation files (the "Software"), to deal
|
||||
@@ -22,10 +22,10 @@
|
||||
* SOFTWARE.
|
||||
*/
|
||||
|
||||
package io.dataline.config.persistence;
|
||||
package io.airbyte.config.persistence;
|
||||
|
||||
import io.dataline.commons.json.JsonValidationException;
|
||||
import io.dataline.config.ConfigSchema;
|
||||
import io.airbyte.commons.json.JsonValidationException;
|
||||
import io.airbyte.config.ConfigSchema;
|
||||
import java.io.IOException;
|
||||
import java.util.List;
|
||||
|
||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user