From fe2f27361b943cb909a15eeebf8a0a0624938bd2 Mon Sep 17 00:00:00 2001 From: jrhizor Date: Tue, 10 Nov 2020 09:11:31 -0800 Subject: [PATCH] fix format build --- .../integrations/base/NamingHelper.java | 26 +++++++++++++++++++ .../bigquery/BigQueryIntegrationTest.java | 6 +++-- 2 files changed, 30 insertions(+), 2 deletions(-) diff --git a/airbyte-integrations/bases/base-java/src/main/java/io/airbyte/integrations/base/NamingHelper.java b/airbyte-integrations/bases/base-java/src/main/java/io/airbyte/integrations/base/NamingHelper.java index 5c2a3f079636..a7a10244fd00 100644 --- a/airbyte-integrations/bases/base-java/src/main/java/io/airbyte/integrations/base/NamingHelper.java +++ b/airbyte-integrations/bases/base-java/src/main/java/io/airbyte/integrations/base/NamingHelper.java @@ -1,7 +1,33 @@ +/* + * MIT License + * + * 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 + * in the Software without restriction, including without limitation the rights + * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell + * copies of the Software, and to permit persons to whom the Software is + * furnished to do so, subject to the following conditions: + * + * The above copyright notice and this permission notice shall be included in all + * copies or substantial portions of the Software. + * + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR + * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, + * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE + * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER + * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, + * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE + * SOFTWARE. + */ + package io.airbyte.integrations.base; public class NamingHelper { + public static String getRawTableName(String streamName) { return streamName + "_raw"; } + } diff --git a/airbyte-integrations/connectors/destination-bigquery/src/test-integration/java/io/airbyte/integrations/destination/bigquery/BigQueryIntegrationTest.java b/airbyte-integrations/connectors/destination-bigquery/src/test-integration/java/io/airbyte/integrations/destination/bigquery/BigQueryIntegrationTest.java index 4b512d7e93d7..f309875e27ce 100644 --- a/airbyte-integrations/connectors/destination-bigquery/src/test-integration/java/io/airbyte/integrations/destination/bigquery/BigQueryIntegrationTest.java +++ b/airbyte-integrations/connectors/destination-bigquery/src/test-integration/java/io/airbyte/integrations/destination/bigquery/BigQueryIntegrationTest.java @@ -88,7 +88,8 @@ protected JsonNode getFailCheckConfig() throws Exception { protected List retrieveRecords(TestDestinationEnv env, String streamName) throws Exception { final QueryJobConfiguration queryConfig = QueryJobConfiguration - .newBuilder(String.format("SELECT * FROM %s.%s;", dataset.getDatasetId().getDataset(), NamingHelper.getRawTableName(streamName.toLowerCase()))) + .newBuilder( + String.format("SELECT * FROM %s.%s;", dataset.getDatasetId().getDataset(), NamingHelper.getRawTableName(streamName.toLowerCase()))) .setUseLegacySql(false).build(); return StreamSupport @@ -102,7 +103,8 @@ protected List retrieveRecords(TestDestinationEnv env, String streamNa protected void setup(TestDestinationEnv testEnv) throws Exception { if (!Files.exists(CREDENTIALS_PATH)) { throw new IllegalStateException( - "Must provide path to a big query credentials file. By default {module-root}/" + CREDENTIALS_PATH + ". Override by setting setting path with the CREDENTIALS_PATH constant."); + "Must provide path to a big query credentials file. By default {module-root}/" + CREDENTIALS_PATH + + ". Override by setting setting path with the CREDENTIALS_PATH constant."); } final String credentialsJsonString = new String(Files.readAllBytes(CREDENTIALS_PATH));