(){}));
}
/**
* Returns an instance of one of these types:
*
- * - {@code NoEncryption}
- * - {@code AESCBCEnvelopeEncryption}
+ * - {@code SQLInserts}
+ * - {@code ExternalTableViaS3}
*
*
* Use {@code instanceof} to determine what type is returned. For example:
@@ -75,7 +75,7 @@ public boolean equals(java.lang.Object o) {
if (o == null || getClass() != o.getClass()) {
return false;
}
- DestinationRedshiftEncryption other = (DestinationRedshiftEncryption) o;
+ DestinationFireboltLoadingMethod other = (DestinationFireboltLoadingMethod) o;
return java.util.Objects.deepEquals(this.value.value(), other.value.value());
}
@@ -85,18 +85,18 @@ public int hashCode() {
}
@SuppressWarnings("serial")
- public static final class _Deserializer extends com.airbyte.api.utils.OneOfDeserializer {
+ public static final class _Deserializer extends com.airbyte.api.utils.OneOfDeserializer {
public _Deserializer() {
- super(DestinationRedshiftEncryption.class,
- Utils.TypeReferenceWithShape.of(new TypeReference() {}, Utils.JsonShape.DEFAULT),
- Utils.TypeReferenceWithShape.of(new TypeReference() {}, Utils.JsonShape.DEFAULT));
+ super(DestinationFireboltLoadingMethod.class,
+ Utils.TypeReferenceWithShape.of(new TypeReference() {}, Utils.JsonShape.DEFAULT),
+ Utils.TypeReferenceWithShape.of(new TypeReference() {}, Utils.JsonShape.DEFAULT));
}
}
@Override
public String toString() {
- return Utils.toString(DestinationRedshiftEncryption.class,
+ return Utils.toString(DestinationFireboltLoadingMethod.class,
"value", value);
}
diff --git a/src/main/java/com/airbyte/api/models/shared/DestinationLangchainMode.java b/src/main/java/com/airbyte/api/models/shared/DestinationFireboltMethod.java
similarity index 85%
rename from src/main/java/com/airbyte/api/models/shared/DestinationLangchainMode.java
rename to src/main/java/com/airbyte/api/models/shared/DestinationFireboltMethod.java
index 340994d0a..bd7694bc1 100644
--- a/src/main/java/com/airbyte/api/models/shared/DestinationLangchainMode.java
+++ b/src/main/java/com/airbyte/api/models/shared/DestinationFireboltMethod.java
@@ -15,13 +15,13 @@
import java.math.BigDecimal;
import java.math.BigInteger;
-public enum DestinationLangchainMode {
- OPENAI("openai");
+public enum DestinationFireboltMethod {
+ SQL("SQL");
@JsonValue
private final String value;
- private DestinationLangchainMode(String value) {
+ private DestinationFireboltMethod(String value) {
this.value = value;
}
diff --git a/src/main/java/com/airbyte/api/models/shared/DestinationFireboltSchemasMethod.java b/src/main/java/com/airbyte/api/models/shared/DestinationFireboltSchemasMethod.java
new file mode 100644
index 000000000..14506c67e
--- /dev/null
+++ b/src/main/java/com/airbyte/api/models/shared/DestinationFireboltSchemasMethod.java
@@ -0,0 +1,31 @@
+/*
+ * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
+ */
+
+package com.airbyte.api.models.shared;
+
+import com.airbyte.api.utils.Utils;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonValue;
+import com.fasterxml.jackson.core.type.TypeReference;
+import java.io.InputStream;
+import java.lang.Deprecated;
+import java.math.BigDecimal;
+import java.math.BigInteger;
+
+public enum DestinationFireboltSchemasMethod {
+ S3("S3");
+
+ @JsonValue
+ private final String value;
+
+ private DestinationFireboltSchemasMethod(String value) {
+ this.value = value;
+ }
+
+ public String value() {
+ return value;
+ }
+}
diff --git a/src/main/java/com/airbyte/api/models/shared/DestinationFirestore.java b/src/main/java/com/airbyte/api/models/shared/DestinationFirestore.java
index 7ac248fb9..b46ef87e6 100644
--- a/src/main/java/com/airbyte/api/models/shared/DestinationFirestore.java
+++ b/src/main/java/com/airbyte/api/models/shared/DestinationFirestore.java
@@ -22,7 +22,7 @@
public class DestinationFirestore {
/**
- * The contents of the JSON service account key. Check out the <a href="https://docs.airbyte.io/integrations/destinations/firestore">docs</a> if you need help generating this key. Default credentials will be used if this field is left empty.
+ * The contents of the JSON service account key. Check out the <a href="https://docs.airbyte.com/integrations/destinations/firestore">docs</a> if you need help generating this key. Default credentials will be used if this field is left empty.
*/
@JsonInclude(Include.NON_ABSENT)
@JsonProperty("credentials_json")
@@ -54,7 +54,7 @@ public DestinationFirestore(
}
/**
- * The contents of the JSON service account key. Check out the <a href="https://docs.airbyte.io/integrations/destinations/firestore">docs</a> if you need help generating this key. Default credentials will be used if this field is left empty.
+ * The contents of the JSON service account key. Check out the <a href="https://docs.airbyte.com/integrations/destinations/firestore">docs</a> if you need help generating this key. Default credentials will be used if this field is left empty.
*/
@SuppressWarnings("unchecked")
@JsonIgnore
@@ -80,7 +80,7 @@ public final static Builder builder() {
}
/**
- * The contents of the JSON service account key. Check out the <a href="https://docs.airbyte.io/integrations/destinations/firestore">docs</a> if you need help generating this key. Default credentials will be used if this field is left empty.
+ * The contents of the JSON service account key. Check out the <a href="https://docs.airbyte.com/integrations/destinations/firestore">docs</a> if you need help generating this key. Default credentials will be used if this field is left empty.
*/
public DestinationFirestore withCredentialsJson(String credentialsJson) {
Utils.checkNotNull(credentialsJson, "credentialsJson");
@@ -89,7 +89,7 @@ public DestinationFirestore withCredentialsJson(String credentialsJson) {
}
/**
- * The contents of the JSON service account key. Check out the <a href="https://docs.airbyte.io/integrations/destinations/firestore">docs</a> if you need help generating this key. Default credentials will be used if this field is left empty.
+ * The contents of the JSON service account key. Check out the <a href="https://docs.airbyte.com/integrations/destinations/firestore">docs</a> if you need help generating this key. Default credentials will be used if this field is left empty.
*/
public DestinationFirestore withCredentialsJson(Optional credentialsJson) {
Utils.checkNotNull(credentialsJson, "credentialsJson");
@@ -148,7 +148,7 @@ private Builder() {
}
/**
- * The contents of the JSON service account key. Check out the <a href="https://docs.airbyte.io/integrations/destinations/firestore">docs</a> if you need help generating this key. Default credentials will be used if this field is left empty.
+ * The contents of the JSON service account key. Check out the <a href="https://docs.airbyte.com/integrations/destinations/firestore">docs</a> if you need help generating this key. Default credentials will be used if this field is left empty.
*/
public Builder credentialsJson(String credentialsJson) {
Utils.checkNotNull(credentialsJson, "credentialsJson");
@@ -157,7 +157,7 @@ public Builder credentialsJson(String credentialsJson) {
}
/**
- * The contents of the JSON service account key. Check out the <a href="https://docs.airbyte.io/integrations/destinations/firestore">docs</a> if you need help generating this key. Default credentials will be used if this field is left empty.
+ * The contents of the JSON service account key. Check out the <a href="https://docs.airbyte.com/integrations/destinations/firestore">docs</a> if you need help generating this key. Default credentials will be used if this field is left empty.
*/
public Builder credentialsJson(Optional credentialsJson) {
Utils.checkNotNull(credentialsJson, "credentialsJson");
diff --git a/src/main/java/com/airbyte/api/models/shared/DestinationLangchain.java b/src/main/java/com/airbyte/api/models/shared/DestinationLangchain.java
deleted file mode 100644
index c324415d3..000000000
--- a/src/main/java/com/airbyte/api/models/shared/DestinationLangchain.java
+++ /dev/null
@@ -1,191 +0,0 @@
-/*
- * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
- */
-
-package com.airbyte.api.models.shared;
-
-import com.airbyte.api.utils.LazySingletonValue;
-import com.airbyte.api.utils.Utils;
-import com.fasterxml.jackson.annotation.JsonCreator;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.core.type.TypeReference;
-import java.io.InputStream;
-import java.lang.Deprecated;
-import java.math.BigDecimal;
-import java.math.BigInteger;
-
-public class DestinationLangchain {
-
- @JsonProperty("destinationType")
- private Langchain destinationType;
-
- /**
- * Embedding configuration
- */
- @JsonProperty("embedding")
- private DestinationLangchainEmbedding embedding;
-
- /**
- * Indexing configuration
- */
- @JsonProperty("indexing")
- private DestinationLangchainIndexing indexing;
-
- @JsonProperty("processing")
- private DestinationLangchainProcessingConfigModel processing;
-
- @JsonCreator
- public DestinationLangchain(
- @JsonProperty("embedding") DestinationLangchainEmbedding embedding,
- @JsonProperty("indexing") DestinationLangchainIndexing indexing,
- @JsonProperty("processing") DestinationLangchainProcessingConfigModel processing) {
- Utils.checkNotNull(embedding, "embedding");
- Utils.checkNotNull(indexing, "indexing");
- Utils.checkNotNull(processing, "processing");
- this.destinationType = Builder._SINGLETON_VALUE_DestinationType.value();
- this.embedding = embedding;
- this.indexing = indexing;
- this.processing = processing;
- }
-
- @JsonIgnore
- public Langchain destinationType() {
- return destinationType;
- }
-
- /**
- * Embedding configuration
- */
- @JsonIgnore
- public DestinationLangchainEmbedding embedding() {
- return embedding;
- }
-
- /**
- * Indexing configuration
- */
- @JsonIgnore
- public DestinationLangchainIndexing indexing() {
- return indexing;
- }
-
- @JsonIgnore
- public DestinationLangchainProcessingConfigModel processing() {
- return processing;
- }
-
- public final static Builder builder() {
- return new Builder();
- }
-
- /**
- * Embedding configuration
- */
- public DestinationLangchain withEmbedding(DestinationLangchainEmbedding embedding) {
- Utils.checkNotNull(embedding, "embedding");
- this.embedding = embedding;
- return this;
- }
-
- /**
- * Indexing configuration
- */
- public DestinationLangchain withIndexing(DestinationLangchainIndexing indexing) {
- Utils.checkNotNull(indexing, "indexing");
- this.indexing = indexing;
- return this;
- }
-
- public DestinationLangchain withProcessing(DestinationLangchainProcessingConfigModel processing) {
- Utils.checkNotNull(processing, "processing");
- this.processing = processing;
- return this;
- }
-
- @Override
- public boolean equals(java.lang.Object o) {
- if (this == o) {
- return true;
- }
- if (o == null || getClass() != o.getClass()) {
- return false;
- }
- DestinationLangchain other = (DestinationLangchain) o;
- return
- java.util.Objects.deepEquals(this.destinationType, other.destinationType) &&
- java.util.Objects.deepEquals(this.embedding, other.embedding) &&
- java.util.Objects.deepEquals(this.indexing, other.indexing) &&
- java.util.Objects.deepEquals(this.processing, other.processing);
- }
-
- @Override
- public int hashCode() {
- return java.util.Objects.hash(
- destinationType,
- embedding,
- indexing,
- processing);
- }
-
- @Override
- public String toString() {
- return Utils.toString(DestinationLangchain.class,
- "destinationType", destinationType,
- "embedding", embedding,
- "indexing", indexing,
- "processing", processing);
- }
-
- public final static class Builder {
-
- private DestinationLangchainEmbedding embedding;
-
- private DestinationLangchainIndexing indexing;
-
- private DestinationLangchainProcessingConfigModel processing;
-
- private Builder() {
- // force use of static builder() method
- }
-
- /**
- * Embedding configuration
- */
- public Builder embedding(DestinationLangchainEmbedding embedding) {
- Utils.checkNotNull(embedding, "embedding");
- this.embedding = embedding;
- return this;
- }
-
- /**
- * Indexing configuration
- */
- public Builder indexing(DestinationLangchainIndexing indexing) {
- Utils.checkNotNull(indexing, "indexing");
- this.indexing = indexing;
- return this;
- }
-
- public Builder processing(DestinationLangchainProcessingConfigModel processing) {
- Utils.checkNotNull(processing, "processing");
- this.processing = processing;
- return this;
- }
-
- public DestinationLangchain build() {
- return new DestinationLangchain(
- embedding,
- indexing,
- processing);
- }
-
- private static final LazySingletonValue _SINGLETON_VALUE_DestinationType =
- new LazySingletonValue<>(
- "destinationType",
- "\"langchain\"",
- new TypeReference() {});
- }
-}
-
diff --git a/src/main/java/com/airbyte/api/models/shared/DestinationLangchainFake.java b/src/main/java/com/airbyte/api/models/shared/DestinationLangchainFake.java
deleted file mode 100644
index d99e68075..000000000
--- a/src/main/java/com/airbyte/api/models/shared/DestinationLangchainFake.java
+++ /dev/null
@@ -1,90 +0,0 @@
-/*
- * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
- */
-
-package com.airbyte.api.models.shared;
-
-import com.airbyte.api.utils.LazySingletonValue;
-import com.airbyte.api.utils.Utils;
-import com.fasterxml.jackson.annotation.JsonCreator;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.annotation.JsonInclude.Include;
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.core.type.TypeReference;
-import java.io.InputStream;
-import java.lang.Deprecated;
-import java.math.BigDecimal;
-import java.math.BigInteger;
-import java.util.Optional;
-/**
- * DestinationLangchainFake - Use a fake embedding made out of random vectors with 1536 embedding dimensions. This is useful for testing the data pipeline without incurring any costs.
- */
-
-public class DestinationLangchainFake {
-
- @JsonInclude(Include.NON_ABSENT)
- @JsonProperty("mode")
- private Optional mode;
-
- @JsonCreator
- public DestinationLangchainFake() {
-
- this.mode = Builder._SINGLETON_VALUE_Mode.value();
- }
-
- @SuppressWarnings("unchecked")
- @JsonIgnore
- public Optional mode() {
- return (Optional) mode;
- }
-
- public final static Builder builder() {
- return new Builder();
- }
-
- @Override
- public boolean equals(java.lang.Object o) {
- if (this == o) {
- return true;
- }
- if (o == null || getClass() != o.getClass()) {
- return false;
- }
- DestinationLangchainFake other = (DestinationLangchainFake) o;
- return
- java.util.Objects.deepEquals(this.mode, other.mode);
- }
-
- @Override
- public int hashCode() {
- return java.util.Objects.hash(
- mode);
- }
-
- @Override
- public String toString() {
- return Utils.toString(DestinationLangchainFake.class,
- "mode", mode);
- }
-
- public final static class Builder {
-
- private Builder() {
- // force use of static builder() method
- }
-
- public DestinationLangchainFake build() {
- return new DestinationLangchainFake(
- );
- }
-
- private static final LazySingletonValue> _SINGLETON_VALUE_Mode =
- new LazySingletonValue<>(
- "mode",
- "\"fake\"",
- new TypeReference>() {});
- }
-}
-
diff --git a/src/main/java/com/airbyte/api/models/shared/DestinationLangchainIndexing.java b/src/main/java/com/airbyte/api/models/shared/DestinationLangchainIndexing.java
deleted file mode 100644
index 18ab9b53e..000000000
--- a/src/main/java/com/airbyte/api/models/shared/DestinationLangchainIndexing.java
+++ /dev/null
@@ -1,110 +0,0 @@
-/*
- * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
- */
-
-package com.airbyte.api.models.shared;
-
-import com.airbyte.api.utils.Utils;
-import com.fasterxml.jackson.annotation.JsonCreator;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.core.type.TypeReference;
-import java.io.InputStream;
-import java.lang.Deprecated;
-import java.math.BigDecimal;
-import java.math.BigInteger;
-
-import java.time.OffsetDateTime;
-import java.time.LocalDate;
-import com.fasterxml.jackson.core.type.TypeReference;
-import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
-import com.airbyte.api.utils.TypedObject;
-import com.airbyte.api.utils.Utils.JsonShape;
-
-/**
- * DestinationLangchainIndexing - Indexing configuration
- */
-
-@JsonDeserialize(using = DestinationLangchainIndexing._Deserializer.class)
-public class DestinationLangchainIndexing {
-
- @com.fasterxml.jackson.annotation.JsonValue
- private TypedObject value;
-
- private DestinationLangchainIndexing(TypedObject value) {
- this.value = value;
- }
-
- public static DestinationLangchainIndexing of(DestinationLangchainPinecone value) {
- Utils.checkNotNull(value, "value");
- return new DestinationLangchainIndexing(TypedObject.of(value, JsonShape.DEFAULT, new TypeReference(){}));
- }
-
- public static DestinationLangchainIndexing of(DocArrayHnswSearch value) {
- Utils.checkNotNull(value, "value");
- return new DestinationLangchainIndexing(TypedObject.of(value, JsonShape.DEFAULT, new TypeReference(){}));
- }
-
- public static DestinationLangchainIndexing of(ChromaLocalPersistance value) {
- Utils.checkNotNull(value, "value");
- return new DestinationLangchainIndexing(TypedObject.of(value, JsonShape.DEFAULT, new TypeReference(){}));
- }
-
- /**
- * Returns an instance of one of these types:
- *
- * - {@code DestinationLangchainPinecone}
- * - {@code DocArrayHnswSearch}
- * - {@code ChromaLocalPersistance}
- *
- *
- * Use {@code instanceof} to determine what type is returned. For example:
- *
- *
- * if (obj.value() instanceof String) {
- * String answer = (String) obj.value();
- * System.out.println("answer=" + answer);
- * }
- *
- *
- * @return value of oneOf type
- **/
- public java.lang.Object value() {
- return value.value();
- }
-
- @Override
- public boolean equals(java.lang.Object o) {
- if (this == o) {
- return true;
- }
- if (o == null || getClass() != o.getClass()) {
- return false;
- }
- DestinationLangchainIndexing other = (DestinationLangchainIndexing) o;
- return java.util.Objects.deepEquals(this.value.value(), other.value.value());
- }
-
- @Override
- public int hashCode() {
- return java.util.Objects.hash(value.value());
- }
-
- @SuppressWarnings("serial")
- public static final class _Deserializer extends com.airbyte.api.utils.OneOfDeserializer {
-
- public _Deserializer() {
- super(DestinationLangchainIndexing.class,
- Utils.TypeReferenceWithShape.of(new TypeReference() {}, Utils.JsonShape.DEFAULT),
- Utils.TypeReferenceWithShape.of(new TypeReference() {}, Utils.JsonShape.DEFAULT),
- Utils.TypeReferenceWithShape.of(new TypeReference() {}, Utils.JsonShape.DEFAULT));
- }
- }
-
- @Override
- public String toString() {
- return Utils.toString(DestinationLangchainIndexing.class,
- "value", value);
- }
-
-}
diff --git a/src/main/java/com/airbyte/api/models/shared/DestinationLangchainOpenAI.java b/src/main/java/com/airbyte/api/models/shared/DestinationLangchainOpenAI.java
deleted file mode 100644
index aed3bdfc6..000000000
--- a/src/main/java/com/airbyte/api/models/shared/DestinationLangchainOpenAI.java
+++ /dev/null
@@ -1,117 +0,0 @@
-/*
- * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
- */
-
-package com.airbyte.api.models.shared;
-
-import com.airbyte.api.utils.LazySingletonValue;
-import com.airbyte.api.utils.Utils;
-import com.fasterxml.jackson.annotation.JsonCreator;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.annotation.JsonInclude.Include;
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.core.type.TypeReference;
-import java.io.InputStream;
-import java.lang.Deprecated;
-import java.math.BigDecimal;
-import java.math.BigInteger;
-import java.util.Optional;
-/**
- * DestinationLangchainOpenAI - Use the OpenAI API to embed text. This option is using the text-embedding-ada-002 model with 1536 embedding dimensions.
- */
-
-public class DestinationLangchainOpenAI {
-
- @JsonInclude(Include.NON_ABSENT)
- @JsonProperty("mode")
- private Optional mode;
-
- @JsonProperty("openai_key")
- private String openaiKey;
-
- @JsonCreator
- public DestinationLangchainOpenAI(
- @JsonProperty("openai_key") String openaiKey) {
- Utils.checkNotNull(openaiKey, "openaiKey");
- this.mode = Builder._SINGLETON_VALUE_Mode.value();
- this.openaiKey = openaiKey;
- }
-
- @SuppressWarnings("unchecked")
- @JsonIgnore
- public Optional mode() {
- return (Optional) mode;
- }
-
- @JsonIgnore
- public String openaiKey() {
- return openaiKey;
- }
-
- public final static Builder builder() {
- return new Builder();
- }
-
- public DestinationLangchainOpenAI withOpenaiKey(String openaiKey) {
- Utils.checkNotNull(openaiKey, "openaiKey");
- this.openaiKey = openaiKey;
- return this;
- }
-
- @Override
- public boolean equals(java.lang.Object o) {
- if (this == o) {
- return true;
- }
- if (o == null || getClass() != o.getClass()) {
- return false;
- }
- DestinationLangchainOpenAI other = (DestinationLangchainOpenAI) o;
- return
- java.util.Objects.deepEquals(this.mode, other.mode) &&
- java.util.Objects.deepEquals(this.openaiKey, other.openaiKey);
- }
-
- @Override
- public int hashCode() {
- return java.util.Objects.hash(
- mode,
- openaiKey);
- }
-
- @Override
- public String toString() {
- return Utils.toString(DestinationLangchainOpenAI.class,
- "mode", mode,
- "openaiKey", openaiKey);
- }
-
- public final static class Builder {
-
- private String openaiKey;
-
- private Builder() {
- // force use of static builder() method
- }
-
- public Builder openaiKey(String openaiKey) {
- Utils.checkNotNull(openaiKey, "openaiKey");
- this.openaiKey = openaiKey;
- return this;
- }
-
- public DestinationLangchainOpenAI build() {
- return new DestinationLangchainOpenAI(
- openaiKey);
- }
-
- private static final LazySingletonValue> _SINGLETON_VALUE_Mode =
- new LazySingletonValue<>(
- "mode",
- "\"openai\"",
- new TypeReference>() {});
- }
-}
-
diff --git a/src/main/java/com/airbyte/api/models/shared/DestinationLangchainPinecone.java b/src/main/java/com/airbyte/api/models/shared/DestinationLangchainPinecone.java
deleted file mode 100644
index fdefc1ff4..000000000
--- a/src/main/java/com/airbyte/api/models/shared/DestinationLangchainPinecone.java
+++ /dev/null
@@ -1,199 +0,0 @@
-/*
- * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
- */
-
-package com.airbyte.api.models.shared;
-
-import com.airbyte.api.utils.LazySingletonValue;
-import com.airbyte.api.utils.Utils;
-import com.fasterxml.jackson.annotation.JsonCreator;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.annotation.JsonInclude.Include;
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.core.type.TypeReference;
-import java.io.InputStream;
-import java.lang.Deprecated;
-import java.math.BigDecimal;
-import java.math.BigInteger;
-import java.util.Optional;
-/**
- * DestinationLangchainPinecone - Pinecone is a popular vector store that can be used to store and retrieve embeddings. It is a managed service and can also be queried from outside of langchain.
- */
-
-public class DestinationLangchainPinecone {
-
- /**
- * Pinecone index to use
- */
- @JsonProperty("index")
- private String index;
-
- @JsonInclude(Include.NON_ABSENT)
- @JsonProperty("mode")
- private Optional mode;
-
- /**
- * Pinecone environment to use
- */
- @JsonProperty("pinecone_environment")
- private String pineconeEnvironment;
-
- @JsonProperty("pinecone_key")
- private String pineconeKey;
-
- @JsonCreator
- public DestinationLangchainPinecone(
- @JsonProperty("index") String index,
- @JsonProperty("pinecone_environment") String pineconeEnvironment,
- @JsonProperty("pinecone_key") String pineconeKey) {
- Utils.checkNotNull(index, "index");
- Utils.checkNotNull(pineconeEnvironment, "pineconeEnvironment");
- Utils.checkNotNull(pineconeKey, "pineconeKey");
- this.index = index;
- this.mode = Builder._SINGLETON_VALUE_Mode.value();
- this.pineconeEnvironment = pineconeEnvironment;
- this.pineconeKey = pineconeKey;
- }
-
- /**
- * Pinecone index to use
- */
- @JsonIgnore
- public String index() {
- return index;
- }
-
- @SuppressWarnings("unchecked")
- @JsonIgnore
- public Optional mode() {
- return (Optional) mode;
- }
-
- /**
- * Pinecone environment to use
- */
- @JsonIgnore
- public String pineconeEnvironment() {
- return pineconeEnvironment;
- }
-
- @JsonIgnore
- public String pineconeKey() {
- return pineconeKey;
- }
-
- public final static Builder builder() {
- return new Builder();
- }
-
- /**
- * Pinecone index to use
- */
- public DestinationLangchainPinecone withIndex(String index) {
- Utils.checkNotNull(index, "index");
- this.index = index;
- return this;
- }
-
- /**
- * Pinecone environment to use
- */
- public DestinationLangchainPinecone withPineconeEnvironment(String pineconeEnvironment) {
- Utils.checkNotNull(pineconeEnvironment, "pineconeEnvironment");
- this.pineconeEnvironment = pineconeEnvironment;
- return this;
- }
-
- public DestinationLangchainPinecone withPineconeKey(String pineconeKey) {
- Utils.checkNotNull(pineconeKey, "pineconeKey");
- this.pineconeKey = pineconeKey;
- return this;
- }
-
- @Override
- public boolean equals(java.lang.Object o) {
- if (this == o) {
- return true;
- }
- if (o == null || getClass() != o.getClass()) {
- return false;
- }
- DestinationLangchainPinecone other = (DestinationLangchainPinecone) o;
- return
- java.util.Objects.deepEquals(this.index, other.index) &&
- java.util.Objects.deepEquals(this.mode, other.mode) &&
- java.util.Objects.deepEquals(this.pineconeEnvironment, other.pineconeEnvironment) &&
- java.util.Objects.deepEquals(this.pineconeKey, other.pineconeKey);
- }
-
- @Override
- public int hashCode() {
- return java.util.Objects.hash(
- index,
- mode,
- pineconeEnvironment,
- pineconeKey);
- }
-
- @Override
- public String toString() {
- return Utils.toString(DestinationLangchainPinecone.class,
- "index", index,
- "mode", mode,
- "pineconeEnvironment", pineconeEnvironment,
- "pineconeKey", pineconeKey);
- }
-
- public final static class Builder {
-
- private String index;
-
- private String pineconeEnvironment;
-
- private String pineconeKey;
-
- private Builder() {
- // force use of static builder() method
- }
-
- /**
- * Pinecone index to use
- */
- public Builder index(String index) {
- Utils.checkNotNull(index, "index");
- this.index = index;
- return this;
- }
-
- /**
- * Pinecone environment to use
- */
- public Builder pineconeEnvironment(String pineconeEnvironment) {
- Utils.checkNotNull(pineconeEnvironment, "pineconeEnvironment");
- this.pineconeEnvironment = pineconeEnvironment;
- return this;
- }
-
- public Builder pineconeKey(String pineconeKey) {
- Utils.checkNotNull(pineconeKey, "pineconeKey");
- this.pineconeKey = pineconeKey;
- return this;
- }
-
- public DestinationLangchainPinecone build() {
- return new DestinationLangchainPinecone(
- index,
- pineconeEnvironment,
- pineconeKey);
- }
-
- private static final LazySingletonValue> _SINGLETON_VALUE_Mode =
- new LazySingletonValue<>(
- "mode",
- "\"pinecone\"",
- new TypeReference>() {});
- }
-}
-
diff --git a/src/main/java/com/airbyte/api/models/shared/DestinationLangchainProcessingConfigModel.java b/src/main/java/com/airbyte/api/models/shared/DestinationLangchainProcessingConfigModel.java
deleted file mode 100644
index 0c6d510fa..000000000
--- a/src/main/java/com/airbyte/api/models/shared/DestinationLangchainProcessingConfigModel.java
+++ /dev/null
@@ -1,223 +0,0 @@
-/*
- * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
- */
-
-package com.airbyte.api.models.shared;
-
-import com.airbyte.api.utils.LazySingletonValue;
-import com.airbyte.api.utils.Utils;
-import com.fasterxml.jackson.annotation.JsonCreator;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.annotation.JsonInclude.Include;
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.core.type.TypeReference;
-import java.io.InputStream;
-import java.lang.Deprecated;
-import java.math.BigDecimal;
-import java.math.BigInteger;
-import java.util.Optional;
-
-public class DestinationLangchainProcessingConfigModel {
-
- /**
- * Size of overlap between chunks in tokens to store in vector store to better capture relevant context
- */
- @JsonInclude(Include.NON_ABSENT)
- @JsonProperty("chunk_overlap")
- private Optional chunkOverlap;
-
- /**
- * Size of chunks in tokens to store in vector store (make sure it is not too big for the context if your LLM)
- */
- @JsonProperty("chunk_size")
- private long chunkSize;
-
- /**
- * List of fields in the record that should be used to calculate the embedding. All other fields are passed along as meta fields. The field list is applied to all streams in the same way and non-existing fields are ignored. If none are defined, all fields are considered text fields. When specifying text fields, you can access nested fields in the record by using dot notation, e.g. `user.name` will access the `name` field in the `user` object. It's also possible to use wildcards to access all fields in an object, e.g. `users.*.name` will access all `names` fields in all entries of the `users` array.
- */
- @JsonProperty("text_fields")
- private java.util.List textFields;
-
- @JsonCreator
- public DestinationLangchainProcessingConfigModel(
- @JsonProperty("chunk_overlap") Optional chunkOverlap,
- @JsonProperty("chunk_size") long chunkSize,
- @JsonProperty("text_fields") java.util.List textFields) {
- Utils.checkNotNull(chunkOverlap, "chunkOverlap");
- Utils.checkNotNull(chunkSize, "chunkSize");
- Utils.checkNotNull(textFields, "textFields");
- this.chunkOverlap = chunkOverlap;
- this.chunkSize = chunkSize;
- this.textFields = textFields;
- }
-
- public DestinationLangchainProcessingConfigModel(
- long chunkSize,
- java.util.List textFields) {
- this(Optional.empty(), chunkSize, textFields);
- }
-
- /**
- * Size of overlap between chunks in tokens to store in vector store to better capture relevant context
- */
- @SuppressWarnings("unchecked")
- @JsonIgnore
- public Optional chunkOverlap() {
- return (Optional) chunkOverlap;
- }
-
- /**
- * Size of chunks in tokens to store in vector store (make sure it is not too big for the context if your LLM)
- */
- @JsonIgnore
- public long chunkSize() {
- return chunkSize;
- }
-
- /**
- * List of fields in the record that should be used to calculate the embedding. All other fields are passed along as meta fields. The field list is applied to all streams in the same way and non-existing fields are ignored. If none are defined, all fields are considered text fields. When specifying text fields, you can access nested fields in the record by using dot notation, e.g. `user.name` will access the `name` field in the `user` object. It's also possible to use wildcards to access all fields in an object, e.g. `users.*.name` will access all `names` fields in all entries of the `users` array.
- */
- @JsonIgnore
- public java.util.List textFields() {
- return textFields;
- }
-
- public final static Builder builder() {
- return new Builder();
- }
-
- /**
- * Size of overlap between chunks in tokens to store in vector store to better capture relevant context
- */
- public DestinationLangchainProcessingConfigModel withChunkOverlap(long chunkOverlap) {
- Utils.checkNotNull(chunkOverlap, "chunkOverlap");
- this.chunkOverlap = Optional.ofNullable(chunkOverlap);
- return this;
- }
-
- /**
- * Size of overlap between chunks in tokens to store in vector store to better capture relevant context
- */
- public DestinationLangchainProcessingConfigModel withChunkOverlap(Optional chunkOverlap) {
- Utils.checkNotNull(chunkOverlap, "chunkOverlap");
- this.chunkOverlap = chunkOverlap;
- return this;
- }
-
- /**
- * Size of chunks in tokens to store in vector store (make sure it is not too big for the context if your LLM)
- */
- public DestinationLangchainProcessingConfigModel withChunkSize(long chunkSize) {
- Utils.checkNotNull(chunkSize, "chunkSize");
- this.chunkSize = chunkSize;
- return this;
- }
-
- /**
- * List of fields in the record that should be used to calculate the embedding. All other fields are passed along as meta fields. The field list is applied to all streams in the same way and non-existing fields are ignored. If none are defined, all fields are considered text fields. When specifying text fields, you can access nested fields in the record by using dot notation, e.g. `user.name` will access the `name` field in the `user` object. It's also possible to use wildcards to access all fields in an object, e.g. `users.*.name` will access all `names` fields in all entries of the `users` array.
- */
- public DestinationLangchainProcessingConfigModel withTextFields(java.util.List textFields) {
- Utils.checkNotNull(textFields, "textFields");
- this.textFields = textFields;
- return this;
- }
-
- @Override
- public boolean equals(java.lang.Object o) {
- if (this == o) {
- return true;
- }
- if (o == null || getClass() != o.getClass()) {
- return false;
- }
- DestinationLangchainProcessingConfigModel other = (DestinationLangchainProcessingConfigModel) o;
- return
- java.util.Objects.deepEquals(this.chunkOverlap, other.chunkOverlap) &&
- java.util.Objects.deepEquals(this.chunkSize, other.chunkSize) &&
- java.util.Objects.deepEquals(this.textFields, other.textFields);
- }
-
- @Override
- public int hashCode() {
- return java.util.Objects.hash(
- chunkOverlap,
- chunkSize,
- textFields);
- }
-
- @Override
- public String toString() {
- return Utils.toString(DestinationLangchainProcessingConfigModel.class,
- "chunkOverlap", chunkOverlap,
- "chunkSize", chunkSize,
- "textFields", textFields);
- }
-
- public final static class Builder {
-
- private Optional chunkOverlap;
-
- private Long chunkSize;
-
- private java.util.List textFields;
-
- private Builder() {
- // force use of static builder() method
- }
-
- /**
- * Size of overlap between chunks in tokens to store in vector store to better capture relevant context
- */
- public Builder chunkOverlap(long chunkOverlap) {
- Utils.checkNotNull(chunkOverlap, "chunkOverlap");
- this.chunkOverlap = Optional.ofNullable(chunkOverlap);
- return this;
- }
-
- /**
- * Size of overlap between chunks in tokens to store in vector store to better capture relevant context
- */
- public Builder chunkOverlap(Optional chunkOverlap) {
- Utils.checkNotNull(chunkOverlap, "chunkOverlap");
- this.chunkOverlap = chunkOverlap;
- return this;
- }
-
- /**
- * Size of chunks in tokens to store in vector store (make sure it is not too big for the context if your LLM)
- */
- public Builder chunkSize(long chunkSize) {
- Utils.checkNotNull(chunkSize, "chunkSize");
- this.chunkSize = chunkSize;
- return this;
- }
-
- /**
- * List of fields in the record that should be used to calculate the embedding. All other fields are passed along as meta fields. The field list is applied to all streams in the same way and non-existing fields are ignored. If none are defined, all fields are considered text fields. When specifying text fields, you can access nested fields in the record by using dot notation, e.g. `user.name` will access the `name` field in the `user` object. It's also possible to use wildcards to access all fields in an object, e.g. `users.*.name` will access all `names` fields in all entries of the `users` array.
- */
- public Builder textFields(java.util.List textFields) {
- Utils.checkNotNull(textFields, "textFields");
- this.textFields = textFields;
- return this;
- }
-
- public DestinationLangchainProcessingConfigModel build() {
- if (chunkOverlap == null) {
- chunkOverlap = _SINGLETON_VALUE_ChunkOverlap.value();
- }
- return new DestinationLangchainProcessingConfigModel(
- chunkOverlap,
- chunkSize,
- textFields);
- }
-
- private static final LazySingletonValue> _SINGLETON_VALUE_ChunkOverlap =
- new LazySingletonValue<>(
- "chunk_overlap",
- "0",
- new TypeReference>() {});
- }
-}
-
diff --git a/src/main/java/com/airbyte/api/models/shared/DestinationRedshiftEncryptionType.java b/src/main/java/com/airbyte/api/models/shared/DestinationRedshiftEncryptionType.java
deleted file mode 100644
index 797af9ca1..000000000
--- a/src/main/java/com/airbyte/api/models/shared/DestinationRedshiftEncryptionType.java
+++ /dev/null
@@ -1,31 +0,0 @@
-/*
- * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
- */
-
-package com.airbyte.api.models.shared;
-
-import com.airbyte.api.utils.Utils;
-import com.fasterxml.jackson.annotation.JsonCreator;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.annotation.JsonValue;
-import com.fasterxml.jackson.core.type.TypeReference;
-import java.io.InputStream;
-import java.lang.Deprecated;
-import java.math.BigDecimal;
-import java.math.BigInteger;
-
-public enum DestinationRedshiftEncryptionType {
- AES_CBC_ENVELOPE("aes_cbc_envelope");
-
- @JsonValue
- private final String value;
-
- private DestinationRedshiftEncryptionType(String value) {
- this.value = value;
- }
-
- public String value() {
- return value;
- }
-}
diff --git a/src/main/java/com/airbyte/api/models/shared/DestinationRedshiftSchemasMethod.java b/src/main/java/com/airbyte/api/models/shared/DestinationRedshiftSchemasMethod.java
deleted file mode 100644
index 844545ead..000000000
--- a/src/main/java/com/airbyte/api/models/shared/DestinationRedshiftSchemasMethod.java
+++ /dev/null
@@ -1,31 +0,0 @@
-/*
- * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
- */
-
-package com.airbyte.api.models.shared;
-
-import com.airbyte.api.utils.Utils;
-import com.fasterxml.jackson.annotation.JsonCreator;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.annotation.JsonValue;
-import com.fasterxml.jackson.core.type.TypeReference;
-import java.io.InputStream;
-import java.lang.Deprecated;
-import java.math.BigDecimal;
-import java.math.BigInteger;
-
-public enum DestinationRedshiftSchemasMethod {
- STANDARD("Standard");
-
- @JsonValue
- private final String value;
-
- private DestinationRedshiftSchemasMethod(String value) {
- this.value = value;
- }
-
- public String value() {
- return value;
- }
-}
diff --git a/src/main/java/com/airbyte/api/models/shared/DestinationS3.java b/src/main/java/com/airbyte/api/models/shared/DestinationS3.java
index ad8c6ffe2..86e2cd1fe 100644
--- a/src/main/java/com/airbyte/api/models/shared/DestinationS3.java
+++ b/src/main/java/com/airbyte/api/models/shared/DestinationS3.java
@@ -44,6 +44,13 @@ public class DestinationS3 {
@JsonProperty("format")
private DestinationS3OutputFormat format;
+ /**
+ * The Role ARN
+ */
+ @JsonInclude(Include.NON_ABSENT)
+ @JsonProperty("role_arn")
+ private Optional roleArn;
+
/**
* The name of the S3 bucket. Read more <a href="https://docs.aws.amazon.com/AmazonS3/latest/userguide/create-bucket-overview.html">here</a>.
*/
@@ -89,6 +96,7 @@ public DestinationS3(
@JsonProperty("access_key_id") Optional accessKeyId,
@JsonProperty("file_name_pattern") Optional fileNamePattern,
@JsonProperty("format") DestinationS3OutputFormat format,
+ @JsonProperty("role_arn") Optional roleArn,
@JsonProperty("s3_bucket_name") String s3BucketName,
@JsonProperty("s3_bucket_path") String s3BucketPath,
@JsonProperty("s3_bucket_region") Optional s3BucketRegion,
@@ -98,6 +106,7 @@ public DestinationS3(
Utils.checkNotNull(accessKeyId, "accessKeyId");
Utils.checkNotNull(fileNamePattern, "fileNamePattern");
Utils.checkNotNull(format, "format");
+ Utils.checkNotNull(roleArn, "roleArn");
Utils.checkNotNull(s3BucketName, "s3BucketName");
Utils.checkNotNull(s3BucketPath, "s3BucketPath");
Utils.checkNotNull(s3BucketRegion, "s3BucketRegion");
@@ -108,6 +117,7 @@ public DestinationS3(
this.destinationType = Builder._SINGLETON_VALUE_DestinationType.value();
this.fileNamePattern = fileNamePattern;
this.format = format;
+ this.roleArn = roleArn;
this.s3BucketName = s3BucketName;
this.s3BucketPath = s3BucketPath;
this.s3BucketRegion = s3BucketRegion;
@@ -120,7 +130,7 @@ public DestinationS3(
DestinationS3OutputFormat format,
String s3BucketName,
String s3BucketPath) {
- this(Optional.empty(), Optional.empty(), format, s3BucketName, s3BucketPath, Optional.empty(), Optional.empty(), Optional.empty(), Optional.empty());
+ this(Optional.empty(), Optional.empty(), format, Optional.empty(), s3BucketName, s3BucketPath, Optional.empty(), Optional.empty(), Optional.empty(), Optional.empty());
}
/**
@@ -154,6 +164,15 @@ public DestinationS3OutputFormat format() {
return format;
}
+ /**
+ * The Role ARN
+ */
+ @SuppressWarnings("unchecked")
+ @JsonIgnore
+ public Optional roleArn() {
+ return (Optional) roleArn;
+ }
+
/**
* The name of the S3 bucket. Read more <a href="https://docs.aws.amazon.com/AmazonS3/latest/userguide/create-bucket-overview.html">here</a>.
*/
@@ -255,6 +274,24 @@ public DestinationS3 withFormat(DestinationS3OutputFormat format) {
return this;
}
+ /**
+ * The Role ARN
+ */
+ public DestinationS3 withRoleArn(String roleArn) {
+ Utils.checkNotNull(roleArn, "roleArn");
+ this.roleArn = Optional.ofNullable(roleArn);
+ return this;
+ }
+
+ /**
+ * The Role ARN
+ */
+ public DestinationS3 withRoleArn(Optional roleArn) {
+ Utils.checkNotNull(roleArn, "roleArn");
+ this.roleArn = roleArn;
+ return this;
+ }
+
/**
* The name of the S3 bucket. Read more <a href="https://docs.aws.amazon.com/AmazonS3/latest/userguide/create-bucket-overview.html">here</a>.
*/
@@ -359,6 +396,7 @@ public boolean equals(java.lang.Object o) {
java.util.Objects.deepEquals(this.destinationType, other.destinationType) &&
java.util.Objects.deepEquals(this.fileNamePattern, other.fileNamePattern) &&
java.util.Objects.deepEquals(this.format, other.format) &&
+ java.util.Objects.deepEquals(this.roleArn, other.roleArn) &&
java.util.Objects.deepEquals(this.s3BucketName, other.s3BucketName) &&
java.util.Objects.deepEquals(this.s3BucketPath, other.s3BucketPath) &&
java.util.Objects.deepEquals(this.s3BucketRegion, other.s3BucketRegion) &&
@@ -374,6 +412,7 @@ public int hashCode() {
destinationType,
fileNamePattern,
format,
+ roleArn,
s3BucketName,
s3BucketPath,
s3BucketRegion,
@@ -389,6 +428,7 @@ public String toString() {
"destinationType", destinationType,
"fileNamePattern", fileNamePattern,
"format", format,
+ "roleArn", roleArn,
"s3BucketName", s3BucketName,
"s3BucketPath", s3BucketPath,
"s3BucketRegion", s3BucketRegion,
@@ -405,6 +445,8 @@ public final static class Builder {
private DestinationS3OutputFormat format;
+ private Optional roleArn = Optional.empty();
+
private String s3BucketName;
private String s3BucketPath;
@@ -466,6 +508,24 @@ public Builder format(DestinationS3OutputFormat format) {
return this;
}
+ /**
+ * The Role ARN
+ */
+ public Builder roleArn(String roleArn) {
+ Utils.checkNotNull(roleArn, "roleArn");
+ this.roleArn = Optional.ofNullable(roleArn);
+ return this;
+ }
+
+ /**
+ * The Role ARN
+ */
+ public Builder roleArn(Optional roleArn) {
+ Utils.checkNotNull(roleArn, "roleArn");
+ this.roleArn = roleArn;
+ return this;
+ }
+
/**
* The name of the S3 bucket. Read more <a href="https://docs.aws.amazon.com/AmazonS3/latest/userguide/create-bucket-overview.html">here</a>.
*/
@@ -567,6 +627,7 @@ public DestinationS3 build() {
accessKeyId,
fileNamePattern,
format,
+ roleArn,
s3BucketName,
s3BucketPath,
s3BucketRegion,
diff --git a/src/main/java/com/airbyte/api/models/shared/DestinationSnowflake.java b/src/main/java/com/airbyte/api/models/shared/DestinationSnowflake.java
index bcff0c111..f833cd5fd 100644
--- a/src/main/java/com/airbyte/api/models/shared/DestinationSnowflake.java
+++ b/src/main/java/com/airbyte/api/models/shared/DestinationSnowflake.java
@@ -87,7 +87,7 @@ public class DestinationSnowflake {
private String username;
/**
- * Enter the name of the <a href="https://docs.snowflake.com/en/user-guide/warehouses-overview.html#overview-of-warehouses">warehouse</a> that you want to sync data into
+ * Enter the name of the <a href="https://docs.snowflake.com/en/user-guide/warehouses-overview.html#overview-of-warehouses">warehouse</a> that you want to use as a compute cluster
*/
@JsonProperty("warehouse")
private String warehouse;
@@ -228,7 +228,7 @@ public String username() {
}
/**
- * Enter the name of the <a href="https://docs.snowflake.com/en/user-guide/warehouses-overview.html#overview-of-warehouses">warehouse</a> that you want to sync data into
+ * Enter the name of the <a href="https://docs.snowflake.com/en/user-guide/warehouses-overview.html#overview-of-warehouses">warehouse</a> that you want to use as a compute cluster
*/
@JsonIgnore
public String warehouse() {
@@ -369,7 +369,7 @@ public DestinationSnowflake withUsername(String username) {
}
/**
- * Enter the name of the <a href="https://docs.snowflake.com/en/user-guide/warehouses-overview.html#overview-of-warehouses">warehouse</a> that you want to sync data into
+ * Enter the name of the <a href="https://docs.snowflake.com/en/user-guide/warehouses-overview.html#overview-of-warehouses">warehouse</a> that you want to use as a compute cluster
*/
public DestinationSnowflake withWarehouse(String warehouse) {
Utils.checkNotNull(warehouse, "warehouse");
@@ -593,7 +593,7 @@ public Builder username(String username) {
}
/**
- * Enter the name of the <a href="https://docs.snowflake.com/en/user-guide/warehouses-overview.html#overview-of-warehouses">warehouse</a> that you want to sync data into
+ * Enter the name of the <a href="https://docs.snowflake.com/en/user-guide/warehouses-overview.html#overview-of-warehouses">warehouse</a> that you want to use as a compute cluster
*/
public Builder warehouse(String warehouse) {
Utils.checkNotNull(warehouse, "warehouse");
diff --git a/src/main/java/com/airbyte/api/models/shared/DestinationSnowflakeCortex.java b/src/main/java/com/airbyte/api/models/shared/DestinationSnowflakeCortex.java
index fb2bac38d..340febf24 100644
--- a/src/main/java/com/airbyte/api/models/shared/DestinationSnowflakeCortex.java
+++ b/src/main/java/com/airbyte/api/models/shared/DestinationSnowflakeCortex.java
@@ -46,7 +46,7 @@ public class DestinationSnowflakeCortex {
* Snowflake can be used to store vector data and retrieve embeddings.
*/
@JsonProperty("indexing")
- private DestinationSnowflakeCortexIndexing indexing;
+ private SnowflakeConnection indexing;
/**
* Do not store the text that gets embedded along with the vector and the metadata in the destination. If set to true, only the vector and the metadata will be stored - in this case raw text for LLM use cases needs to be retrieved from another source.
@@ -61,7 +61,7 @@ public class DestinationSnowflakeCortex {
@JsonCreator
public DestinationSnowflakeCortex(
@JsonProperty("embedding") DestinationSnowflakeCortexEmbedding embedding,
- @JsonProperty("indexing") DestinationSnowflakeCortexIndexing indexing,
+ @JsonProperty("indexing") SnowflakeConnection indexing,
@JsonProperty("omit_raw_text") Optional omitRawText,
@JsonProperty("processing") DestinationSnowflakeCortexProcessingConfigModel processing) {
Utils.checkNotNull(embedding, "embedding");
@@ -77,7 +77,7 @@ public DestinationSnowflakeCortex(
public DestinationSnowflakeCortex(
DestinationSnowflakeCortexEmbedding embedding,
- DestinationSnowflakeCortexIndexing indexing,
+ SnowflakeConnection indexing,
DestinationSnowflakeCortexProcessingConfigModel processing) {
this(embedding, indexing, Optional.empty(), processing);
}
@@ -99,7 +99,7 @@ public DestinationSnowflakeCortexEmbedding embedding() {
* Snowflake can be used to store vector data and retrieve embeddings.
*/
@JsonIgnore
- public DestinationSnowflakeCortexIndexing indexing() {
+ public SnowflakeConnection indexing() {
return indexing;
}
@@ -133,7 +133,7 @@ public DestinationSnowflakeCortex withEmbedding(DestinationSnowflakeCortexEmbedd
/**
* Snowflake can be used to store vector data and retrieve embeddings.
*/
- public DestinationSnowflakeCortex withIndexing(DestinationSnowflakeCortexIndexing indexing) {
+ public DestinationSnowflakeCortex withIndexing(SnowflakeConnection indexing) {
Utils.checkNotNull(indexing, "indexing");
this.indexing = indexing;
return this;
@@ -204,7 +204,7 @@ public final static class Builder {
private DestinationSnowflakeCortexEmbedding embedding;
- private DestinationSnowflakeCortexIndexing indexing;
+ private SnowflakeConnection indexing;
private Optional omitRawText;
@@ -226,7 +226,7 @@ public Builder embedding(DestinationSnowflakeCortexEmbedding embedding) {
/**
* Snowflake can be used to store vector data and retrieve embeddings.
*/
- public Builder indexing(DestinationSnowflakeCortexIndexing indexing) {
+ public Builder indexing(SnowflakeConnection indexing) {
Utils.checkNotNull(indexing, "indexing");
this.indexing = indexing;
return this;
diff --git a/src/main/java/com/airbyte/api/models/shared/DetectChangesWithXminSystemColumn.java b/src/main/java/com/airbyte/api/models/shared/DetectChangesWithXminSystemColumn.java
index 9b23bdd97..16cfa3ae4 100644
--- a/src/main/java/com/airbyte/api/models/shared/DetectChangesWithXminSystemColumn.java
+++ b/src/main/java/com/airbyte/api/models/shared/DetectChangesWithXminSystemColumn.java
@@ -16,7 +16,7 @@
import java.math.BigDecimal;
import java.math.BigInteger;
/**
- * DetectChangesWithXminSystemColumn - <i>Recommended</i> - Incrementally reads new inserts and updates via Postgres <a href="https://docs.airbyte.com/integrations/sources/postgres/#xmin">Xmin system column</a>. Only recommended for tables up to 500GB.
+ * DetectChangesWithXminSystemColumn - <i>Recommended</i> - Incrementally reads new inserts and updates via Postgres <a href="https://docs.airbyte.com/integrations/sources/postgres/#xmin">Xmin system column</a>. Suitable for databases that have low transaction pressure.
*/
public class DetectChangesWithXminSystemColumn {
diff --git a/src/main/java/com/airbyte/api/models/shared/DocArrayHnswSearch.java b/src/main/java/com/airbyte/api/models/shared/DocArrayHnswSearch.java
deleted file mode 100644
index d0f6d1074..000000000
--- a/src/main/java/com/airbyte/api/models/shared/DocArrayHnswSearch.java
+++ /dev/null
@@ -1,129 +0,0 @@
-/*
- * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
- */
-
-package com.airbyte.api.models.shared;
-
-import com.airbyte.api.utils.LazySingletonValue;
-import com.airbyte.api.utils.Utils;
-import com.fasterxml.jackson.annotation.JsonCreator;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.annotation.JsonInclude.Include;
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.core.type.TypeReference;
-import java.io.InputStream;
-import java.lang.Deprecated;
-import java.math.BigDecimal;
-import java.math.BigInteger;
-import java.util.Optional;
-/**
- * DocArrayHnswSearch - DocArrayHnswSearch is a lightweight Document Index implementation provided by Docarray that runs fully locally and is best suited for small- to medium-sized datasets. It stores vectors on disk in hnswlib, and stores all other data in SQLite.
- */
-
-public class DocArrayHnswSearch {
-
- /**
- * Path to the directory where hnswlib and meta data files will be written. The files will be placed inside that local mount. All files in the specified destination directory will be deleted on each run.
- */
- @JsonProperty("destination_path")
- private String destinationPath;
-
- @JsonInclude(Include.NON_ABSENT)
- @JsonProperty("mode")
- private Optional mode;
-
- @JsonCreator
- public DocArrayHnswSearch(
- @JsonProperty("destination_path") String destinationPath) {
- Utils.checkNotNull(destinationPath, "destinationPath");
- this.destinationPath = destinationPath;
- this.mode = Builder._SINGLETON_VALUE_Mode.value();
- }
-
- /**
- * Path to the directory where hnswlib and meta data files will be written. The files will be placed inside that local mount. All files in the specified destination directory will be deleted on each run.
- */
- @JsonIgnore
- public String destinationPath() {
- return destinationPath;
- }
-
- @SuppressWarnings("unchecked")
- @JsonIgnore
- public Optional mode() {
- return (Optional) mode;
- }
-
- public final static Builder builder() {
- return new Builder();
- }
-
- /**
- * Path to the directory where hnswlib and meta data files will be written. The files will be placed inside that local mount. All files in the specified destination directory will be deleted on each run.
- */
- public DocArrayHnswSearch withDestinationPath(String destinationPath) {
- Utils.checkNotNull(destinationPath, "destinationPath");
- this.destinationPath = destinationPath;
- return this;
- }
-
- @Override
- public boolean equals(java.lang.Object o) {
- if (this == o) {
- return true;
- }
- if (o == null || getClass() != o.getClass()) {
- return false;
- }
- DocArrayHnswSearch other = (DocArrayHnswSearch) o;
- return
- java.util.Objects.deepEquals(this.destinationPath, other.destinationPath) &&
- java.util.Objects.deepEquals(this.mode, other.mode);
- }
-
- @Override
- public int hashCode() {
- return java.util.Objects.hash(
- destinationPath,
- mode);
- }
-
- @Override
- public String toString() {
- return Utils.toString(DocArrayHnswSearch.class,
- "destinationPath", destinationPath,
- "mode", mode);
- }
-
- public final static class Builder {
-
- private String destinationPath;
-
- private Builder() {
- // force use of static builder() method
- }
-
- /**
- * Path to the directory where hnswlib and meta data files will be written. The files will be placed inside that local mount. All files in the specified destination directory will be deleted on each run.
- */
- public Builder destinationPath(String destinationPath) {
- Utils.checkNotNull(destinationPath, "destinationPath");
- this.destinationPath = destinationPath;
- return this;
- }
-
- public DocArrayHnswSearch build() {
- return new DocArrayHnswSearch(
- destinationPath);
- }
-
- private static final LazySingletonValue> _SINGLETON_VALUE_Mode =
- new LazySingletonValue<>(
- "mode",
- "\"DocArrayHnswSearch\"",
- new TypeReference>() {});
- }
-}
-
diff --git a/src/main/java/com/airbyte/api/models/shared/DestinationLangchainSchemasIndexingIndexingMode.java b/src/main/java/com/airbyte/api/models/shared/DomainRegionCode.java
similarity index 76%
rename from src/main/java/com/airbyte/api/models/shared/DestinationLangchainSchemasIndexingIndexingMode.java
rename to src/main/java/com/airbyte/api/models/shared/DomainRegionCode.java
index c07e1e701..1a3655254 100644
--- a/src/main/java/com/airbyte/api/models/shared/DestinationLangchainSchemasIndexingIndexingMode.java
+++ b/src/main/java/com/airbyte/api/models/shared/DomainRegionCode.java
@@ -15,13 +15,17 @@
import java.math.BigDecimal;
import java.math.BigInteger;
-public enum DestinationLangchainSchemasIndexingIndexingMode {
- DOC_ARRAY_HNSW_SEARCH("DocArrayHnswSearch");
+/**
+ * DomainRegionCode - Domain region code. 'EU' or 'US' are possible values. The default is 'US'.
+ */
+public enum DomainRegionCode {
+ US("US"),
+ EU("EU");
@JsonValue
private final String value;
- private DestinationLangchainSchemasIndexingIndexingMode(String value) {
+ private DomainRegionCode(String value) {
this.value = value;
}
diff --git a/src/main/java/com/airbyte/api/models/shared/ExternalTableViaS3.java b/src/main/java/com/airbyte/api/models/shared/ExternalTableViaS3.java
new file mode 100644
index 000000000..5818a93e7
--- /dev/null
+++ b/src/main/java/com/airbyte/api/models/shared/ExternalTableViaS3.java
@@ -0,0 +1,244 @@
+/*
+ * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
+ */
+
+package com.airbyte.api.models.shared;
+
+import com.airbyte.api.utils.LazySingletonValue;
+import com.airbyte.api.utils.Utils;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.core.type.TypeReference;
+import java.io.InputStream;
+import java.lang.Deprecated;
+import java.math.BigDecimal;
+import java.math.BigInteger;
+
+public class ExternalTableViaS3 {
+
+ /**
+ * AWS access key granting read and write access to S3.
+ */
+ @JsonProperty("aws_key_id")
+ private String awsKeyId;
+
+ /**
+ * Corresponding secret part of the AWS Key
+ */
+ @JsonProperty("aws_key_secret")
+ private String awsKeySecret;
+
+ @JsonProperty("method")
+ private DestinationFireboltSchemasMethod method;
+
+ /**
+ * The name of the S3 bucket.
+ */
+ @JsonProperty("s3_bucket")
+ private String s3Bucket;
+
+ /**
+ * Region name of the S3 bucket.
+ */
+ @JsonProperty("s3_region")
+ private String s3Region;
+
+ @JsonCreator
+ public ExternalTableViaS3(
+ @JsonProperty("aws_key_id") String awsKeyId,
+ @JsonProperty("aws_key_secret") String awsKeySecret,
+ @JsonProperty("s3_bucket") String s3Bucket,
+ @JsonProperty("s3_region") String s3Region) {
+ Utils.checkNotNull(awsKeyId, "awsKeyId");
+ Utils.checkNotNull(awsKeySecret, "awsKeySecret");
+ Utils.checkNotNull(s3Bucket, "s3Bucket");
+ Utils.checkNotNull(s3Region, "s3Region");
+ this.awsKeyId = awsKeyId;
+ this.awsKeySecret = awsKeySecret;
+ this.method = Builder._SINGLETON_VALUE_Method.value();
+ this.s3Bucket = s3Bucket;
+ this.s3Region = s3Region;
+ }
+
+ /**
+ * AWS access key granting read and write access to S3.
+ */
+ @JsonIgnore
+ public String awsKeyId() {
+ return awsKeyId;
+ }
+
+ /**
+ * Corresponding secret part of the AWS Key
+ */
+ @JsonIgnore
+ public String awsKeySecret() {
+ return awsKeySecret;
+ }
+
+ @JsonIgnore
+ public DestinationFireboltSchemasMethod method() {
+ return method;
+ }
+
+ /**
+ * The name of the S3 bucket.
+ */
+ @JsonIgnore
+ public String s3Bucket() {
+ return s3Bucket;
+ }
+
+ /**
+ * Region name of the S3 bucket.
+ */
+ @JsonIgnore
+ public String s3Region() {
+ return s3Region;
+ }
+
+ public final static Builder builder() {
+ return new Builder();
+ }
+
+ /**
+ * AWS access key granting read and write access to S3.
+ */
+ public ExternalTableViaS3 withAwsKeyId(String awsKeyId) {
+ Utils.checkNotNull(awsKeyId, "awsKeyId");
+ this.awsKeyId = awsKeyId;
+ return this;
+ }
+
+ /**
+ * Corresponding secret part of the AWS Key
+ */
+ public ExternalTableViaS3 withAwsKeySecret(String awsKeySecret) {
+ Utils.checkNotNull(awsKeySecret, "awsKeySecret");
+ this.awsKeySecret = awsKeySecret;
+ return this;
+ }
+
+ /**
+ * The name of the S3 bucket.
+ */
+ public ExternalTableViaS3 withS3Bucket(String s3Bucket) {
+ Utils.checkNotNull(s3Bucket, "s3Bucket");
+ this.s3Bucket = s3Bucket;
+ return this;
+ }
+
+ /**
+ * Region name of the S3 bucket.
+ */
+ public ExternalTableViaS3 withS3Region(String s3Region) {
+ Utils.checkNotNull(s3Region, "s3Region");
+ this.s3Region = s3Region;
+ return this;
+ }
+
+ @Override
+ public boolean equals(java.lang.Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ ExternalTableViaS3 other = (ExternalTableViaS3) o;
+ return
+ java.util.Objects.deepEquals(this.awsKeyId, other.awsKeyId) &&
+ java.util.Objects.deepEquals(this.awsKeySecret, other.awsKeySecret) &&
+ java.util.Objects.deepEquals(this.method, other.method) &&
+ java.util.Objects.deepEquals(this.s3Bucket, other.s3Bucket) &&
+ java.util.Objects.deepEquals(this.s3Region, other.s3Region);
+ }
+
+ @Override
+ public int hashCode() {
+ return java.util.Objects.hash(
+ awsKeyId,
+ awsKeySecret,
+ method,
+ s3Bucket,
+ s3Region);
+ }
+
+ @Override
+ public String toString() {
+ return Utils.toString(ExternalTableViaS3.class,
+ "awsKeyId", awsKeyId,
+ "awsKeySecret", awsKeySecret,
+ "method", method,
+ "s3Bucket", s3Bucket,
+ "s3Region", s3Region);
+ }
+
+ public final static class Builder {
+
+ private String awsKeyId;
+
+ private String awsKeySecret;
+
+ private String s3Bucket;
+
+ private String s3Region;
+
+ private Builder() {
+ // force use of static builder() method
+ }
+
+ /**
+ * AWS access key granting read and write access to S3.
+ */
+ public Builder awsKeyId(String awsKeyId) {
+ Utils.checkNotNull(awsKeyId, "awsKeyId");
+ this.awsKeyId = awsKeyId;
+ return this;
+ }
+
+ /**
+ * Corresponding secret part of the AWS Key
+ */
+ public Builder awsKeySecret(String awsKeySecret) {
+ Utils.checkNotNull(awsKeySecret, "awsKeySecret");
+ this.awsKeySecret = awsKeySecret;
+ return this;
+ }
+
+ /**
+ * The name of the S3 bucket.
+ */
+ public Builder s3Bucket(String s3Bucket) {
+ Utils.checkNotNull(s3Bucket, "s3Bucket");
+ this.s3Bucket = s3Bucket;
+ return this;
+ }
+
+ /**
+ * Region name of the S3 bucket.
+ */
+ public Builder s3Region(String s3Region) {
+ Utils.checkNotNull(s3Region, "s3Region");
+ this.s3Region = s3Region;
+ return this;
+ }
+
+ public ExternalTableViaS3 build() {
+ return new ExternalTableViaS3(
+ awsKeyId,
+ awsKeySecret,
+ s3Bucket,
+ s3Region);
+ }
+
+ private static final LazySingletonValue _SINGLETON_VALUE_Method =
+ new LazySingletonValue<>(
+ "method",
+ "\"S3\"",
+ new TypeReference() {});
+ }
+}
+
diff --git a/src/main/java/com/airbyte/api/models/shared/FacebookMarketing.java b/src/main/java/com/airbyte/api/models/shared/FacebookMarketing.java
index 56de493f6..1398c77b5 100644
--- a/src/main/java/com/airbyte/api/models/shared/FacebookMarketing.java
+++ b/src/main/java/com/airbyte/api/models/shared/FacebookMarketing.java
@@ -20,89 +20,40 @@
public class FacebookMarketing {
- /**
- * The Client Id for your OAuth app
- */
@JsonInclude(Include.NON_ABSENT)
- @JsonProperty("client_id")
- private Optional clientId;
-
- /**
- * The Client Secret for your OAuth app
- */
- @JsonInclude(Include.NON_ABSENT)
- @JsonProperty("client_secret")
- private Optional clientSecret;
+ @JsonProperty("credentials")
+ private Optional credentials;
@JsonCreator
public FacebookMarketing(
- @JsonProperty("client_id") Optional clientId,
- @JsonProperty("client_secret") Optional clientSecret) {
- Utils.checkNotNull(clientId, "clientId");
- Utils.checkNotNull(clientSecret, "clientSecret");
- this.clientId = clientId;
- this.clientSecret = clientSecret;
+ @JsonProperty("credentials") Optional credentials) {
+ Utils.checkNotNull(credentials, "credentials");
+ this.credentials = credentials;
}
public FacebookMarketing() {
- this(Optional.empty(), Optional.empty());
- }
-
- /**
- * The Client Id for your OAuth app
- */
- @SuppressWarnings("unchecked")
- @JsonIgnore
- public Optional clientId() {
- return (Optional) clientId;
+ this(Optional.empty());
}
- /**
- * The Client Secret for your OAuth app
- */
@SuppressWarnings("unchecked")
@JsonIgnore
- public Optional clientSecret() {
- return (Optional) clientSecret;
+ public Optional credentials() {
+ return (Optional) credentials;
}
public final static Builder builder() {
return new Builder();
}
- /**
- * The Client Id for your OAuth app
- */
- public FacebookMarketing withClientId(String clientId) {
- Utils.checkNotNull(clientId, "clientId");
- this.clientId = Optional.ofNullable(clientId);
+ public FacebookMarketing withCredentials(FacebookMarketingCredentials credentials) {
+ Utils.checkNotNull(credentials, "credentials");
+ this.credentials = Optional.ofNullable(credentials);
return this;
}
- /**
- * The Client Id for your OAuth app
- */
- public FacebookMarketing withClientId(Optional clientId) {
- Utils.checkNotNull(clientId, "clientId");
- this.clientId = clientId;
- return this;
- }
-
- /**
- * The Client Secret for your OAuth app
- */
- public FacebookMarketing withClientSecret(String clientSecret) {
- Utils.checkNotNull(clientSecret, "clientSecret");
- this.clientSecret = Optional.ofNullable(clientSecret);
- return this;
- }
-
- /**
- * The Client Secret for your OAuth app
- */
- public FacebookMarketing withClientSecret(Optional clientSecret) {
- Utils.checkNotNull(clientSecret, "clientSecret");
- this.clientSecret = clientSecret;
+ public FacebookMarketing withCredentials(Optional credentials) {
+ Utils.checkNotNull(credentials, "credentials");
+ this.credentials = credentials;
return this;
}
@@ -116,74 +67,44 @@ public boolean equals(java.lang.Object o) {
}
FacebookMarketing other = (FacebookMarketing) o;
return
- java.util.Objects.deepEquals(this.clientId, other.clientId) &&
- java.util.Objects.deepEquals(this.clientSecret, other.clientSecret);
+ java.util.Objects.deepEquals(this.credentials, other.credentials);
}
@Override
public int hashCode() {
return java.util.Objects.hash(
- clientId,
- clientSecret);
+ credentials);
}
@Override
public String toString() {
return Utils.toString(FacebookMarketing.class,
- "clientId", clientId,
- "clientSecret", clientSecret);
+ "credentials", credentials);
}
public final static class Builder {
- private Optional clientId = Optional.empty();
-
- private Optional clientSecret = Optional.empty();
+ private Optional credentials = Optional.empty();
private Builder() {
// force use of static builder() method
}
- /**
- * The Client Id for your OAuth app
- */
- public Builder clientId(String clientId) {
- Utils.checkNotNull(clientId, "clientId");
- this.clientId = Optional.ofNullable(clientId);
- return this;
- }
-
- /**
- * The Client Id for your OAuth app
- */
- public Builder clientId(Optional clientId) {
- Utils.checkNotNull(clientId, "clientId");
- this.clientId = clientId;
- return this;
- }
-
- /**
- * The Client Secret for your OAuth app
- */
- public Builder clientSecret(String clientSecret) {
- Utils.checkNotNull(clientSecret, "clientSecret");
- this.clientSecret = Optional.ofNullable(clientSecret);
+ public Builder credentials(FacebookMarketingCredentials credentials) {
+ Utils.checkNotNull(credentials, "credentials");
+ this.credentials = Optional.ofNullable(credentials);
return this;
}
- /**
- * The Client Secret for your OAuth app
- */
- public Builder clientSecret(Optional clientSecret) {
- Utils.checkNotNull(clientSecret, "clientSecret");
- this.clientSecret = clientSecret;
+ public Builder credentials(Optional credentials) {
+ Utils.checkNotNull(credentials, "credentials");
+ this.credentials = credentials;
return this;
}
public FacebookMarketing build() {
return new FacebookMarketing(
- clientId,
- clientSecret);
+ credentials);
}
}
}
diff --git a/src/main/java/com/airbyte/api/models/shared/FacebookMarketingCredentials.java b/src/main/java/com/airbyte/api/models/shared/FacebookMarketingCredentials.java
new file mode 100644
index 000000000..5590e7a52
--- /dev/null
+++ b/src/main/java/com/airbyte/api/models/shared/FacebookMarketingCredentials.java
@@ -0,0 +1,190 @@
+/*
+ * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
+ */
+
+package com.airbyte.api.models.shared;
+
+import com.airbyte.api.utils.Utils;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude.Include;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.core.type.TypeReference;
+import java.io.InputStream;
+import java.lang.Deprecated;
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.util.Optional;
+
+public class FacebookMarketingCredentials {
+
+ /**
+ * The Client Id for your OAuth app
+ */
+ @JsonInclude(Include.NON_ABSENT)
+ @JsonProperty("client_id")
+ private Optional clientId;
+
+ /**
+ * The Client Secret for your OAuth app
+ */
+ @JsonInclude(Include.NON_ABSENT)
+ @JsonProperty("client_secret")
+ private Optional clientSecret;
+
+ @JsonCreator
+ public FacebookMarketingCredentials(
+ @JsonProperty("client_id") Optional clientId,
+ @JsonProperty("client_secret") Optional clientSecret) {
+ Utils.checkNotNull(clientId, "clientId");
+ Utils.checkNotNull(clientSecret, "clientSecret");
+ this.clientId = clientId;
+ this.clientSecret = clientSecret;
+ }
+
+ public FacebookMarketingCredentials() {
+ this(Optional.empty(), Optional.empty());
+ }
+
+ /**
+ * The Client Id for your OAuth app
+ */
+ @SuppressWarnings("unchecked")
+ @JsonIgnore
+ public Optional clientId() {
+ return (Optional) clientId;
+ }
+
+ /**
+ * The Client Secret for your OAuth app
+ */
+ @SuppressWarnings("unchecked")
+ @JsonIgnore
+ public Optional clientSecret() {
+ return (Optional) clientSecret;
+ }
+
+ public final static Builder builder() {
+ return new Builder();
+ }
+
+ /**
+ * The Client Id for your OAuth app
+ */
+ public FacebookMarketingCredentials withClientId(String clientId) {
+ Utils.checkNotNull(clientId, "clientId");
+ this.clientId = Optional.ofNullable(clientId);
+ return this;
+ }
+
+ /**
+ * The Client Id for your OAuth app
+ */
+ public FacebookMarketingCredentials withClientId(Optional clientId) {
+ Utils.checkNotNull(clientId, "clientId");
+ this.clientId = clientId;
+ return this;
+ }
+
+ /**
+ * The Client Secret for your OAuth app
+ */
+ public FacebookMarketingCredentials withClientSecret(String clientSecret) {
+ Utils.checkNotNull(clientSecret, "clientSecret");
+ this.clientSecret = Optional.ofNullable(clientSecret);
+ return this;
+ }
+
+ /**
+ * The Client Secret for your OAuth app
+ */
+ public FacebookMarketingCredentials withClientSecret(Optional clientSecret) {
+ Utils.checkNotNull(clientSecret, "clientSecret");
+ this.clientSecret = clientSecret;
+ return this;
+ }
+
+ @Override
+ public boolean equals(java.lang.Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ FacebookMarketingCredentials other = (FacebookMarketingCredentials) o;
+ return
+ java.util.Objects.deepEquals(this.clientId, other.clientId) &&
+ java.util.Objects.deepEquals(this.clientSecret, other.clientSecret);
+ }
+
+ @Override
+ public int hashCode() {
+ return java.util.Objects.hash(
+ clientId,
+ clientSecret);
+ }
+
+ @Override
+ public String toString() {
+ return Utils.toString(FacebookMarketingCredentials.class,
+ "clientId", clientId,
+ "clientSecret", clientSecret);
+ }
+
+ public final static class Builder {
+
+ private Optional clientId = Optional.empty();
+
+ private Optional clientSecret = Optional.empty();
+
+ private Builder() {
+ // force use of static builder() method
+ }
+
+ /**
+ * The Client Id for your OAuth app
+ */
+ public Builder clientId(String clientId) {
+ Utils.checkNotNull(clientId, "clientId");
+ this.clientId = Optional.ofNullable(clientId);
+ return this;
+ }
+
+ /**
+ * The Client Id for your OAuth app
+ */
+ public Builder clientId(Optional clientId) {
+ Utils.checkNotNull(clientId, "clientId");
+ this.clientId = clientId;
+ return this;
+ }
+
+ /**
+ * The Client Secret for your OAuth app
+ */
+ public Builder clientSecret(String clientSecret) {
+ Utils.checkNotNull(clientSecret, "clientSecret");
+ this.clientSecret = Optional.ofNullable(clientSecret);
+ return this;
+ }
+
+ /**
+ * The Client Secret for your OAuth app
+ */
+ public Builder clientSecret(Optional clientSecret) {
+ Utils.checkNotNull(clientSecret, "clientSecret");
+ this.clientSecret = clientSecret;
+ return this;
+ }
+
+ public FacebookMarketingCredentials build() {
+ return new FacebookMarketingCredentials(
+ clientId,
+ clientSecret);
+ }
+ }
+}
+
diff --git a/src/main/java/com/airbyte/api/models/shared/FilterAppliedWhileFetchingRecordsBasedOnAttributeKeyAndAttributeValueWhichWillBeAppendedOnTheRequestBody.java b/src/main/java/com/airbyte/api/models/shared/FilterAppliedWhileFetchingRecordsBasedOnAttributeKeyAndAttributeValueWhichWillBeAppendedOnTheRequestBody.java
new file mode 100644
index 000000000..6c63d20df
--- /dev/null
+++ b/src/main/java/com/airbyte/api/models/shared/FilterAppliedWhileFetchingRecordsBasedOnAttributeKeyAndAttributeValueWhichWillBeAppendedOnTheRequestBody.java
@@ -0,0 +1,173 @@
+/*
+ * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
+ */
+
+package com.airbyte.api.models.shared;
+
+import com.airbyte.api.utils.LazySingletonValue;
+import com.airbyte.api.utils.Utils;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude.Include;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.core.type.TypeReference;
+import java.io.InputStream;
+import java.lang.Deprecated;
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.util.Optional;
+
+public class FilterAppliedWhileFetchingRecordsBasedOnAttributeKeyAndAttributeValueWhichWillBeAppendedOnTheRequestBody {
+
+ @JsonInclude(Include.NON_ABSENT)
+ @JsonProperty("attribute_key")
+ private Optional attributeKey;
+
+ @JsonInclude(Include.NON_ABSENT)
+ @JsonProperty("attribute_value")
+ private Optional attributeValue;
+
+ @JsonCreator
+ public FilterAppliedWhileFetchingRecordsBasedOnAttributeKeyAndAttributeValueWhichWillBeAppendedOnTheRequestBody(
+ @JsonProperty("attribute_key") Optional attributeKey,
+ @JsonProperty("attribute_value") Optional attributeValue) {
+ Utils.checkNotNull(attributeKey, "attributeKey");
+ Utils.checkNotNull(attributeValue, "attributeValue");
+ this.attributeKey = attributeKey;
+ this.attributeValue = attributeValue;
+ }
+
+ public FilterAppliedWhileFetchingRecordsBasedOnAttributeKeyAndAttributeValueWhichWillBeAppendedOnTheRequestBody() {
+ this(Optional.empty(), Optional.empty());
+ }
+
+ @SuppressWarnings("unchecked")
+ @JsonIgnore
+ public Optional attributeKey() {
+ return (Optional) attributeKey;
+ }
+
+ @SuppressWarnings("unchecked")
+ @JsonIgnore
+ public Optional attributeValue() {
+ return (Optional) attributeValue;
+ }
+
+ public final static Builder builder() {
+ return new Builder();
+ }
+
+ public FilterAppliedWhileFetchingRecordsBasedOnAttributeKeyAndAttributeValueWhichWillBeAppendedOnTheRequestBody withAttributeKey(String attributeKey) {
+ Utils.checkNotNull(attributeKey, "attributeKey");
+ this.attributeKey = Optional.ofNullable(attributeKey);
+ return this;
+ }
+
+ public FilterAppliedWhileFetchingRecordsBasedOnAttributeKeyAndAttributeValueWhichWillBeAppendedOnTheRequestBody withAttributeKey(Optional attributeKey) {
+ Utils.checkNotNull(attributeKey, "attributeKey");
+ this.attributeKey = attributeKey;
+ return this;
+ }
+
+ public FilterAppliedWhileFetchingRecordsBasedOnAttributeKeyAndAttributeValueWhichWillBeAppendedOnTheRequestBody withAttributeValue(String attributeValue) {
+ Utils.checkNotNull(attributeValue, "attributeValue");
+ this.attributeValue = Optional.ofNullable(attributeValue);
+ return this;
+ }
+
+ public FilterAppliedWhileFetchingRecordsBasedOnAttributeKeyAndAttributeValueWhichWillBeAppendedOnTheRequestBody withAttributeValue(Optional attributeValue) {
+ Utils.checkNotNull(attributeValue, "attributeValue");
+ this.attributeValue = attributeValue;
+ return this;
+ }
+
+ @Override
+ public boolean equals(java.lang.Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ FilterAppliedWhileFetchingRecordsBasedOnAttributeKeyAndAttributeValueWhichWillBeAppendedOnTheRequestBody other = (FilterAppliedWhileFetchingRecordsBasedOnAttributeKeyAndAttributeValueWhichWillBeAppendedOnTheRequestBody) o;
+ return
+ java.util.Objects.deepEquals(this.attributeKey, other.attributeKey) &&
+ java.util.Objects.deepEquals(this.attributeValue, other.attributeValue);
+ }
+
+ @Override
+ public int hashCode() {
+ return java.util.Objects.hash(
+ attributeKey,
+ attributeValue);
+ }
+
+ @Override
+ public String toString() {
+ return Utils.toString(FilterAppliedWhileFetchingRecordsBasedOnAttributeKeyAndAttributeValueWhichWillBeAppendedOnTheRequestBody.class,
+ "attributeKey", attributeKey,
+ "attributeValue", attributeValue);
+ }
+
+ public final static class Builder {
+
+ private Optional attributeKey;
+
+ private Optional attributeValue;
+
+ private Builder() {
+ // force use of static builder() method
+ }
+
+ public Builder attributeKey(String attributeKey) {
+ Utils.checkNotNull(attributeKey, "attributeKey");
+ this.attributeKey = Optional.ofNullable(attributeKey);
+ return this;
+ }
+
+ public Builder attributeKey(Optional attributeKey) {
+ Utils.checkNotNull(attributeKey, "attributeKey");
+ this.attributeKey = attributeKey;
+ return this;
+ }
+
+ public Builder attributeValue(String attributeValue) {
+ Utils.checkNotNull(attributeValue, "attributeValue");
+ this.attributeValue = Optional.ofNullable(attributeValue);
+ return this;
+ }
+
+ public Builder attributeValue(Optional attributeValue) {
+ Utils.checkNotNull(attributeValue, "attributeValue");
+ this.attributeValue = attributeValue;
+ return this;
+ }
+
+ public FilterAppliedWhileFetchingRecordsBasedOnAttributeKeyAndAttributeValueWhichWillBeAppendedOnTheRequestBody build() {
+ if (attributeKey == null) {
+ attributeKey = _SINGLETON_VALUE_AttributeKey.value();
+ }
+ if (attributeValue == null) {
+ attributeValue = _SINGLETON_VALUE_AttributeValue.value();
+ }
+ return new FilterAppliedWhileFetchingRecordsBasedOnAttributeKeyAndAttributeValueWhichWillBeAppendedOnTheRequestBody(
+ attributeKey,
+ attributeValue);
+ }
+
+ private static final LazySingletonValue> _SINGLETON_VALUE_AttributeKey =
+ new LazySingletonValue<>(
+ "attribute_key",
+ "\"EventName\"",
+ new TypeReference>() {});
+
+ private static final LazySingletonValue> _SINGLETON_VALUE_AttributeValue =
+ new LazySingletonValue<>(
+ "attribute_value",
+ "\"ListInstanceAssociations\"",
+ new TypeReference>() {});
+ }
+}
+
diff --git a/src/main/java/com/airbyte/api/models/shared/Langchain.java b/src/main/java/com/airbyte/api/models/shared/Fleetio.java
similarity index 88%
rename from src/main/java/com/airbyte/api/models/shared/Langchain.java
rename to src/main/java/com/airbyte/api/models/shared/Fleetio.java
index 20891ace3..c83889442 100644
--- a/src/main/java/com/airbyte/api/models/shared/Langchain.java
+++ b/src/main/java/com/airbyte/api/models/shared/Fleetio.java
@@ -15,13 +15,13 @@
import java.math.BigDecimal;
import java.math.BigInteger;
-public enum Langchain {
- LANGCHAIN("langchain");
+public enum Fleetio {
+ FLEETIO("fleetio");
@JsonValue
private final String value;
- private Langchain(String value) {
+ private Fleetio(String value) {
this.value = value;
}
diff --git a/src/main/java/com/airbyte/api/models/shared/Goldcast.java b/src/main/java/com/airbyte/api/models/shared/Goldcast.java
new file mode 100644
index 000000000..b6356eada
--- /dev/null
+++ b/src/main/java/com/airbyte/api/models/shared/Goldcast.java
@@ -0,0 +1,31 @@
+/*
+ * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
+ */
+
+package com.airbyte.api.models.shared;
+
+import com.airbyte.api.utils.Utils;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonValue;
+import com.fasterxml.jackson.core.type.TypeReference;
+import java.io.InputStream;
+import java.lang.Deprecated;
+import java.math.BigDecimal;
+import java.math.BigInteger;
+
+public enum Goldcast {
+ GOLDCAST("goldcast");
+
+ @JsonValue
+ private final String value;
+
+ private Goldcast(String value) {
+ this.value = value;
+ }
+
+ public String value() {
+ return value;
+ }
+}
diff --git a/src/main/java/com/airbyte/api/models/shared/GoogleAnalyticsV4ServiceAccountOnly.java b/src/main/java/com/airbyte/api/models/shared/GoogleAnalyticsV4ServiceAccountOnly.java
deleted file mode 100644
index 252b54f38..000000000
--- a/src/main/java/com/airbyte/api/models/shared/GoogleAnalyticsV4ServiceAccountOnly.java
+++ /dev/null
@@ -1,31 +0,0 @@
-/*
- * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
- */
-
-package com.airbyte.api.models.shared;
-
-import com.airbyte.api.utils.Utils;
-import com.fasterxml.jackson.annotation.JsonCreator;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.annotation.JsonValue;
-import com.fasterxml.jackson.core.type.TypeReference;
-import java.io.InputStream;
-import java.lang.Deprecated;
-import java.math.BigDecimal;
-import java.math.BigInteger;
-
-public enum GoogleAnalyticsV4ServiceAccountOnly {
- GOOGLE_ANALYTICS_V4_SERVICE_ACCOUNT_ONLY("google-analytics-v4-service-account-only");
-
- @JsonValue
- private final String value;
-
- private GoogleAnalyticsV4ServiceAccountOnly(String value) {
- this.value = value;
- }
-
- public String value() {
- return value;
- }
-}
diff --git a/src/main/java/com/airbyte/api/models/shared/InsightConfig.java b/src/main/java/com/airbyte/api/models/shared/InsightConfig.java
index cfccf5869..19eb4273d 100644
--- a/src/main/java/com/airbyte/api/models/shared/InsightConfig.java
+++ b/src/main/java/com/airbyte/api/models/shared/InsightConfig.java
@@ -97,7 +97,7 @@ public class InsightConfig {
private Optional startDate;
/**
- * Time window in days by which to aggregate statistics. The sync will be chunked into N day intervals, where N is the number of days you specified. For example, if you set this value to 7, then all statistics will be reported as 7-day aggregates by starting from the start_date. If the start and end dates are October 1st and October 30th, then the connector will output 5 records: 01 - 06, 07 - 13, 14 - 20, 21 - 27, and 28 - 30 (3 days only).
+ * Time window in days by which to aggregate statistics. The sync will be chunked into N day intervals, where N is the number of days you specified. For example, if you set this value to 7, then all statistics will be reported as 7-day aggregates by starting from the start_date. If the start and end dates are October 1st and October 30th, then the connector will output 5 records: 01 - 06, 07 - 13, 14 - 20, 21 - 27, and 28 - 30 (3 days only). The minimum allowed value for this field is 1, and the maximum is 89.
*/
@JsonInclude(Include.NON_ABSENT)
@JsonProperty("time_increment")
@@ -235,7 +235,7 @@ public Optional startDate() {
}
/**
- * Time window in days by which to aggregate statistics. The sync will be chunked into N day intervals, where N is the number of days you specified. For example, if you set this value to 7, then all statistics will be reported as 7-day aggregates by starting from the start_date. If the start and end dates are October 1st and October 30th, then the connector will output 5 records: 01 - 06, 07 - 13, 14 - 20, 21 - 27, and 28 - 30 (3 days only).
+ * Time window in days by which to aggregate statistics. The sync will be chunked into N day intervals, where N is the number of days you specified. For example, if you set this value to 7, then all statistics will be reported as 7-day aggregates by starting from the start_date. If the start and end dates are October 1st and October 30th, then the connector will output 5 records: 01 - 06, 07 - 13, 14 - 20, 21 - 27, and 28 - 30 (3 days only). The minimum allowed value for this field is 1, and the maximum is 89.
*/
@SuppressWarnings("unchecked")
@JsonIgnore
@@ -419,7 +419,7 @@ public InsightConfig withStartDate(Optional startDate)
}
/**
- * Time window in days by which to aggregate statistics. The sync will be chunked into N day intervals, where N is the number of days you specified. For example, if you set this value to 7, then all statistics will be reported as 7-day aggregates by starting from the start_date. If the start and end dates are October 1st and October 30th, then the connector will output 5 records: 01 - 06, 07 - 13, 14 - 20, 21 - 27, and 28 - 30 (3 days only).
+ * Time window in days by which to aggregate statistics. The sync will be chunked into N day intervals, where N is the number of days you specified. For example, if you set this value to 7, then all statistics will be reported as 7-day aggregates by starting from the start_date. If the start and end dates are October 1st and October 30th, then the connector will output 5 records: 01 - 06, 07 - 13, 14 - 20, 21 - 27, and 28 - 30 (3 days only). The minimum allowed value for this field is 1, and the maximum is 89.
*/
public InsightConfig withTimeIncrement(long timeIncrement) {
Utils.checkNotNull(timeIncrement, "timeIncrement");
@@ -428,7 +428,7 @@ public InsightConfig withTimeIncrement(long timeIncrement) {
}
/**
- * Time window in days by which to aggregate statistics. The sync will be chunked into N day intervals, where N is the number of days you specified. For example, if you set this value to 7, then all statistics will be reported as 7-day aggregates by starting from the start_date. If the start and end dates are October 1st and October 30th, then the connector will output 5 records: 01 - 06, 07 - 13, 14 - 20, 21 - 27, and 28 - 30 (3 days only).
+ * Time window in days by which to aggregate statistics. The sync will be chunked into N day intervals, where N is the number of days you specified. For example, if you set this value to 7, then all statistics will be reported as 7-day aggregates by starting from the start_date. If the start and end dates are October 1st and October 30th, then the connector will output 5 records: 01 - 06, 07 - 13, 14 - 20, 21 - 27, and 28 - 30 (3 days only). The minimum allowed value for this field is 1, and the maximum is 89.
*/
public InsightConfig withTimeIncrement(Optional timeIncrement) {
Utils.checkNotNull(timeIncrement, "timeIncrement");
@@ -691,7 +691,7 @@ public Builder startDate(Optional startDate) {
}
/**
- * Time window in days by which to aggregate statistics. The sync will be chunked into N day intervals, where N is the number of days you specified. For example, if you set this value to 7, then all statistics will be reported as 7-day aggregates by starting from the start_date. If the start and end dates are October 1st and October 30th, then the connector will output 5 records: 01 - 06, 07 - 13, 14 - 20, 21 - 27, and 28 - 30 (3 days only).
+ * Time window in days by which to aggregate statistics. The sync will be chunked into N day intervals, where N is the number of days you specified. For example, if you set this value to 7, then all statistics will be reported as 7-day aggregates by starting from the start_date. If the start and end dates are October 1st and October 30th, then the connector will output 5 records: 01 - 06, 07 - 13, 14 - 20, 21 - 27, and 28 - 30 (3 days only). The minimum allowed value for this field is 1, and the maximum is 89.
*/
public Builder timeIncrement(long timeIncrement) {
Utils.checkNotNull(timeIncrement, "timeIncrement");
@@ -700,7 +700,7 @@ public Builder timeIncrement(long timeIncrement) {
}
/**
- * Time window in days by which to aggregate statistics. The sync will be chunked into N day intervals, where N is the number of days you specified. For example, if you set this value to 7, then all statistics will be reported as 7-day aggregates by starting from the start_date. If the start and end dates are October 1st and October 30th, then the connector will output 5 records: 01 - 06, 07 - 13, 14 - 20, 21 - 27, and 28 - 30 (3 days only).
+ * Time window in days by which to aggregate statistics. The sync will be chunked into N day intervals, where N is the number of days you specified. For example, if you set this value to 7, then all statistics will be reported as 7-day aggregates by starting from the start_date. If the start and end dates are October 1st and October 30th, then the connector will output 5 records: 01 - 06, 07 - 13, 14 - 20, 21 - 27, and 28 - 30 (3 days only). The minimum allowed value for this field is 1, and the maximum is 89.
*/
public Builder timeIncrement(Optional timeIncrement) {
Utils.checkNotNull(timeIncrement, "timeIncrement");
diff --git a/src/main/java/com/airbyte/api/models/shared/JobTypeEnum.java b/src/main/java/com/airbyte/api/models/shared/JobTypeEnum.java
index b93caf12d..fe339d980 100644
--- a/src/main/java/com/airbyte/api/models/shared/JobTypeEnum.java
+++ b/src/main/java/com/airbyte/api/models/shared/JobTypeEnum.java
@@ -20,7 +20,9 @@
*/
public enum JobTypeEnum {
SYNC("sync"),
- RESET("reset");
+ RESET("reset"),
+ REFRESH("refresh"),
+ CLEAR("clear");
@JsonValue
private final String value;
diff --git a/src/main/java/com/airbyte/api/models/shared/NoEncryption.java b/src/main/java/com/airbyte/api/models/shared/NoEncryption.java
deleted file mode 100644
index 219f047fc..000000000
--- a/src/main/java/com/airbyte/api/models/shared/NoEncryption.java
+++ /dev/null
@@ -1,90 +0,0 @@
-/*
- * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
- */
-
-package com.airbyte.api.models.shared;
-
-import com.airbyte.api.utils.LazySingletonValue;
-import com.airbyte.api.utils.Utils;
-import com.fasterxml.jackson.annotation.JsonCreator;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.annotation.JsonInclude.Include;
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.core.type.TypeReference;
-import java.io.InputStream;
-import java.lang.Deprecated;
-import java.math.BigDecimal;
-import java.math.BigInteger;
-import java.util.Optional;
-/**
- * NoEncryption - Staging data will be stored in plaintext.
- */
-
-public class NoEncryption {
-
- @JsonInclude(Include.NON_ABSENT)
- @JsonProperty("encryption_type")
- private Optional encryptionType;
-
- @JsonCreator
- public NoEncryption() {
-
- this.encryptionType = Builder._SINGLETON_VALUE_EncryptionType.value();
- }
-
- @SuppressWarnings("unchecked")
- @JsonIgnore
- public Optional encryptionType() {
- return (Optional) encryptionType;
- }
-
- public final static Builder builder() {
- return new Builder();
- }
-
- @Override
- public boolean equals(java.lang.Object o) {
- if (this == o) {
- return true;
- }
- if (o == null || getClass() != o.getClass()) {
- return false;
- }
- NoEncryption other = (NoEncryption) o;
- return
- java.util.Objects.deepEquals(this.encryptionType, other.encryptionType);
- }
-
- @Override
- public int hashCode() {
- return java.util.Objects.hash(
- encryptionType);
- }
-
- @Override
- public String toString() {
- return Utils.toString(NoEncryption.class,
- "encryptionType", encryptionType);
- }
-
- public final static class Builder {
-
- private Builder() {
- // force use of static builder() method
- }
-
- public NoEncryption build() {
- return new NoEncryption(
- );
- }
-
- private static final LazySingletonValue> _SINGLETON_VALUE_EncryptionType =
- new LazySingletonValue<>(
- "encryption_type",
- "\"none\"",
- new TypeReference>() {});
- }
-}
-
diff --git a/src/main/java/com/airbyte/api/models/shared/OrganizationResponse.java b/src/main/java/com/airbyte/api/models/shared/OrganizationResponse.java
new file mode 100644
index 000000000..ff9ed3a66
--- /dev/null
+++ b/src/main/java/com/airbyte/api/models/shared/OrganizationResponse.java
@@ -0,0 +1,151 @@
+/*
+ * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
+ */
+
+package com.airbyte.api.models.shared;
+
+import com.airbyte.api.utils.Utils;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.core.type.TypeReference;
+import java.io.InputStream;
+import java.lang.Deprecated;
+import java.math.BigDecimal;
+import java.math.BigInteger;
+/**
+ * OrganizationResponse - Provides details of a single organization for a user.
+ */
+
+public class OrganizationResponse {
+
+ @JsonProperty("email")
+ private String email;
+
+ @JsonProperty("organizationId")
+ private String organizationId;
+
+ @JsonProperty("organizationName")
+ private String organizationName;
+
+ @JsonCreator
+ public OrganizationResponse(
+ @JsonProperty("email") String email,
+ @JsonProperty("organizationId") String organizationId,
+ @JsonProperty("organizationName") String organizationName) {
+ Utils.checkNotNull(email, "email");
+ Utils.checkNotNull(organizationId, "organizationId");
+ Utils.checkNotNull(organizationName, "organizationName");
+ this.email = email;
+ this.organizationId = organizationId;
+ this.organizationName = organizationName;
+ }
+
+ @JsonIgnore
+ public String email() {
+ return email;
+ }
+
+ @JsonIgnore
+ public String organizationId() {
+ return organizationId;
+ }
+
+ @JsonIgnore
+ public String organizationName() {
+ return organizationName;
+ }
+
+ public final static Builder builder() {
+ return new Builder();
+ }
+
+ public OrganizationResponse withEmail(String email) {
+ Utils.checkNotNull(email, "email");
+ this.email = email;
+ return this;
+ }
+
+ public OrganizationResponse withOrganizationId(String organizationId) {
+ Utils.checkNotNull(organizationId, "organizationId");
+ this.organizationId = organizationId;
+ return this;
+ }
+
+ public OrganizationResponse withOrganizationName(String organizationName) {
+ Utils.checkNotNull(organizationName, "organizationName");
+ this.organizationName = organizationName;
+ return this;
+ }
+
+ @Override
+ public boolean equals(java.lang.Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ OrganizationResponse other = (OrganizationResponse) o;
+ return
+ java.util.Objects.deepEquals(this.email, other.email) &&
+ java.util.Objects.deepEquals(this.organizationId, other.organizationId) &&
+ java.util.Objects.deepEquals(this.organizationName, other.organizationName);
+ }
+
+ @Override
+ public int hashCode() {
+ return java.util.Objects.hash(
+ email,
+ organizationId,
+ organizationName);
+ }
+
+ @Override
+ public String toString() {
+ return Utils.toString(OrganizationResponse.class,
+ "email", email,
+ "organizationId", organizationId,
+ "organizationName", organizationName);
+ }
+
+ public final static class Builder {
+
+ private String email;
+
+ private String organizationId;
+
+ private String organizationName;
+
+ private Builder() {
+ // force use of static builder() method
+ }
+
+ public Builder email(String email) {
+ Utils.checkNotNull(email, "email");
+ this.email = email;
+ return this;
+ }
+
+ public Builder organizationId(String organizationId) {
+ Utils.checkNotNull(organizationId, "organizationId");
+ this.organizationId = organizationId;
+ return this;
+ }
+
+ public Builder organizationName(String organizationName) {
+ Utils.checkNotNull(organizationName, "organizationName");
+ this.organizationName = organizationName;
+ return this;
+ }
+
+ public OrganizationResponse build() {
+ return new OrganizationResponse(
+ email,
+ organizationId,
+ organizationName);
+ }
+ }
+}
+
diff --git a/src/main/java/com/airbyte/api/models/shared/OrganizationsResponse.java b/src/main/java/com/airbyte/api/models/shared/OrganizationsResponse.java
new file mode 100644
index 000000000..3a07d5e7c
--- /dev/null
+++ b/src/main/java/com/airbyte/api/models/shared/OrganizationsResponse.java
@@ -0,0 +1,93 @@
+/*
+ * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
+ */
+
+package com.airbyte.api.models.shared;
+
+import com.airbyte.api.utils.Utils;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.core.type.TypeReference;
+import java.io.InputStream;
+import java.lang.Deprecated;
+import java.math.BigDecimal;
+import java.math.BigInteger;
+/**
+ * OrganizationsResponse - List/Array of multiple organizations.
+ */
+
+public class OrganizationsResponse {
+
+ @JsonProperty("data")
+ private java.util.List data;
+
+ @JsonCreator
+ public OrganizationsResponse(
+ @JsonProperty("data") java.util.List data) {
+ Utils.checkNotNull(data, "data");
+ this.data = data;
+ }
+
+ @JsonIgnore
+ public java.util.List data() {
+ return data;
+ }
+
+ public final static Builder builder() {
+ return new Builder();
+ }
+
+ public OrganizationsResponse withData(java.util.List data) {
+ Utils.checkNotNull(data, "data");
+ this.data = data;
+ return this;
+ }
+
+ @Override
+ public boolean equals(java.lang.Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ OrganizationsResponse other = (OrganizationsResponse) o;
+ return
+ java.util.Objects.deepEquals(this.data, other.data);
+ }
+
+ @Override
+ public int hashCode() {
+ return java.util.Objects.hash(
+ data);
+ }
+
+ @Override
+ public String toString() {
+ return Utils.toString(OrganizationsResponse.class,
+ "data", data);
+ }
+
+ public final static class Builder {
+
+ private java.util.List data;
+
+ private Builder() {
+ // force use of static builder() method
+ }
+
+ public Builder data(java.util.List data) {
+ Utils.checkNotNull(data, "data");
+ this.data = data;
+ return this;
+ }
+
+ public OrganizationsResponse build() {
+ return new OrganizationsResponse(
+ data);
+ }
+ }
+}
+
diff --git a/src/main/java/com/airbyte/api/models/shared/PermissionCreateRequest.java b/src/main/java/com/airbyte/api/models/shared/PermissionCreateRequest.java
index bd95326b4..3ea439095 100644
--- a/src/main/java/com/airbyte/api/models/shared/PermissionCreateRequest.java
+++ b/src/main/java/com/airbyte/api/models/shared/PermissionCreateRequest.java
@@ -25,10 +25,10 @@ public class PermissionCreateRequest {
private Optional organizationId;
/**
- * Describes what actions/endpoints the permission entitles to
+ * Subset of `PermissionType` (removing `instance_admin`), could be used in public-api.
*/
@JsonProperty("permissionType")
- private PermissionType permissionType;
+ private PublicPermissionType permissionType;
/**
* Internal Airbyte user ID
@@ -43,7 +43,7 @@ public class PermissionCreateRequest {
@JsonCreator
public PermissionCreateRequest(
@JsonProperty("organizationId") Optional organizationId,
- @JsonProperty("permissionType") PermissionType permissionType,
+ @JsonProperty("permissionType") PublicPermissionType permissionType,
@JsonProperty("userId") String userId,
@JsonProperty("workspaceId") Optional workspaceId) {
Utils.checkNotNull(organizationId, "organizationId");
@@ -57,7 +57,7 @@ public PermissionCreateRequest(
}
public PermissionCreateRequest(
- PermissionType permissionType,
+ PublicPermissionType permissionType,
String userId) {
this(Optional.empty(), permissionType, userId, Optional.empty());
}
@@ -69,10 +69,10 @@ public Optional organizationId() {
}
/**
- * Describes what actions/endpoints the permission entitles to
+ * Subset of `PermissionType` (removing `instance_admin`), could be used in public-api.
*/
@JsonIgnore
- public PermissionType permissionType() {
+ public PublicPermissionType permissionType() {
return permissionType;
}
@@ -107,9 +107,9 @@ public PermissionCreateRequest withOrganizationId(Optional org
}
/**
- * Describes what actions/endpoints the permission entitles to
+ * Subset of `PermissionType` (removing `instance_admin`), could be used in public-api.
*/
- public PermissionCreateRequest withPermissionType(PermissionType permissionType) {
+ public PermissionCreateRequest withPermissionType(PublicPermissionType permissionType) {
Utils.checkNotNull(permissionType, "permissionType");
this.permissionType = permissionType;
return this;
@@ -174,7 +174,7 @@ public final static class Builder {
private Optional organizationId = Optional.empty();
- private PermissionType permissionType;
+ private PublicPermissionType permissionType;
private String userId;
@@ -197,9 +197,9 @@ public Builder organizationId(Optional organizationId) {
}
/**
- * Describes what actions/endpoints the permission entitles to
+ * Subset of `PermissionType` (removing `instance_admin`), could be used in public-api.
*/
- public Builder permissionType(PermissionType permissionType) {
+ public Builder permissionType(PublicPermissionType permissionType) {
Utils.checkNotNull(permissionType, "permissionType");
this.permissionType = permissionType;
return this;
diff --git a/src/main/java/com/airbyte/api/models/shared/PublicPermissionType.java b/src/main/java/com/airbyte/api/models/shared/PublicPermissionType.java
new file mode 100644
index 000000000..c8244fdb6
--- /dev/null
+++ b/src/main/java/com/airbyte/api/models/shared/PublicPermissionType.java
@@ -0,0 +1,40 @@
+/*
+ * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
+ */
+
+package com.airbyte.api.models.shared;
+
+import com.airbyte.api.utils.Utils;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonValue;
+import com.fasterxml.jackson.core.type.TypeReference;
+import java.io.InputStream;
+import java.lang.Deprecated;
+import java.math.BigDecimal;
+import java.math.BigInteger;
+
+/**
+ * PublicPermissionType - Subset of `PermissionType` (removing `instance_admin`), could be used in public-api.
+ */
+public enum PublicPermissionType {
+ ORGANIZATION_ADMIN("organization_admin"),
+ ORGANIZATION_EDITOR("organization_editor"),
+ ORGANIZATION_READER("organization_reader"),
+ ORGANIZATION_MEMBER("organization_member"),
+ WORKSPACE_ADMIN("workspace_admin"),
+ WORKSPACE_EDITOR("workspace_editor"),
+ WORKSPACE_READER("workspace_reader");
+
+ @JsonValue
+ private final String value;
+
+ private PublicPermissionType(String value) {
+ this.value = value;
+ }
+
+ public String value() {
+ return value;
+ }
+}
diff --git a/src/main/java/com/airbyte/api/models/shared/Queries.java b/src/main/java/com/airbyte/api/models/shared/Queries.java
new file mode 100644
index 000000000..c9fac755c
--- /dev/null
+++ b/src/main/java/com/airbyte/api/models/shared/Queries.java
@@ -0,0 +1,184 @@
+/*
+ * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.
+ */
+
+package com.airbyte.api.models.shared;
+
+import com.airbyte.api.utils.Utils;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.core.type.TypeReference;
+import java.io.InputStream;
+import java.lang.Deprecated;
+import java.math.BigDecimal;
+import java.math.BigInteger;
+
+public class Queries {
+
+ /**
+ * A data source that is powered by the platform.
+ */
+ @JsonProperty("data_source")
+ private SourceDatadogDataSource dataSource;
+
+ /**
+ * The variable name for use in queries.
+ */
+ @JsonProperty("name")
+ private String name;
+
+ /**
+ * A classic query string.
+ */
+ @JsonProperty("query")
+ private String query;
+
+ @JsonCreator
+ public Queries(
+ @JsonProperty("data_source") SourceDatadogDataSource dataSource,
+ @JsonProperty("name") String name,
+ @JsonProperty("query") String query) {
+ Utils.checkNotNull(dataSource, "dataSource");
+ Utils.checkNotNull(name, "name");
+ Utils.checkNotNull(query, "query");
+ this.dataSource = dataSource;
+ this.name = name;
+ this.query = query;
+ }
+
+ /**
+ * A data source that is powered by the platform.
+ */
+ @JsonIgnore
+ public SourceDatadogDataSource dataSource() {
+ return dataSource;
+ }
+
+ /**
+ * The variable name for use in queries.
+ */
+ @JsonIgnore
+ public String name() {
+ return name;
+ }
+
+ /**
+ * A classic query string.
+ */
+ @JsonIgnore
+ public String query() {
+ return query;
+ }
+
+ public final static Builder builder() {
+ return new Builder();
+ }
+
+ /**
+ * A data source that is powered by the platform.
+ */
+ public Queries withDataSource(SourceDatadogDataSource dataSource) {
+ Utils.checkNotNull(dataSource, "dataSource");
+ this.dataSource = dataSource;
+ return this;
+ }
+
+ /**
+ * The variable name for use in queries.
+ */
+ public Queries withName(String name) {
+ Utils.checkNotNull(name, "name");
+ this.name = name;
+ return this;
+ }
+
+ /**
+ * A classic query string.
+ */
+ public Queries withQuery(String query) {
+ Utils.checkNotNull(query, "query");
+ this.query = query;
+ return this;
+ }
+
+ @Override
+ public boolean equals(java.lang.Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ Queries other = (Queries) o;
+ return
+ java.util.Objects.deepEquals(this.dataSource, other.dataSource) &&
+ java.util.Objects.deepEquals(this.name, other.name) &&
+ java.util.Objects.deepEquals(this.query, other.query);
+ }
+
+ @Override
+ public int hashCode() {
+ return java.util.Objects.hash(
+ dataSource,
+ name,
+ query);
+ }
+
+ @Override
+ public String toString() {
+ return Utils.toString(Queries.class,
+ "dataSource", dataSource,
+ "name", name,
+ "query", query);
+ }
+
+ public final static class Builder {
+
+ private SourceDatadogDataSource dataSource;
+
+ private String name;
+
+ private String query;
+
+ private Builder() {
+ // force use of static builder() method
+ }
+
+ /**
+ * A data source that is powered by the platform.
+ */
+ public Builder dataSource(SourceDatadogDataSource dataSource) {
+ Utils.checkNotNull(dataSource, "dataSource");
+ this.dataSource = dataSource;
+ return this;
+ }
+
+ /**
+ * The variable name for use in queries.
+ */
+ public Builder name(String name) {
+ Utils.checkNotNull(name, "name");
+ this.name = name;
+ return this;
+ }
+
+ /**
+ * A classic query string.
+ */
+ public Builder query(String query) {
+ Utils.checkNotNull(query, "query");
+ this.query = query;
+ return this;
+ }
+
+ public Queries build() {
+ return new Queries(
+ dataSource,
+ name,
+ query);
+ }
+ }
+}
+
diff --git a/src/main/java/com/airbyte/api/models/shared/ReadChangesUsingBinaryLogCDC.java b/src/main/java/com/airbyte/api/models/shared/ReadChangesUsingBinaryLogCDC.java
index 52ec6fb40..5d0e40fde 100644
--- a/src/main/java/com/airbyte/api/models/shared/ReadChangesUsingBinaryLogCDC.java
+++ b/src/main/java/com/airbyte/api/models/shared/ReadChangesUsingBinaryLogCDC.java
@@ -24,6 +24,13 @@
public class ReadChangesUsingBinaryLogCDC {
+ /**
+ * The amount of time an initial load is allowed to continue for before catching up on CDC logs.
+ */
+ @JsonInclude(Include.NON_ABSENT)
+ @JsonProperty("initial_load_timeout_hours")
+ private Optional initialLoadTimeoutHours;
+
/**
* The amount of time the connector will wait when it launches to determine if there is new data to sync or not. Defaults to 300 seconds. Valid range: 120 seconds to 1200 seconds. Read about <a href="https://docs.airbyte.com/integrations/sources/mysql/#change-data-capture-cdc">initial waiting time</a>.
*/
@@ -50,12 +57,15 @@ public class ReadChangesUsingBinaryLogCDC {
@JsonCreator
public ReadChangesUsingBinaryLogCDC(
+ @JsonProperty("initial_load_timeout_hours") Optional initialLoadTimeoutHours,
@JsonProperty("initial_waiting_seconds") Optional initialWaitingSeconds,
@JsonProperty("invalid_cdc_cursor_position_behavior") Optional invalidCdcCursorPositionBehavior,
@JsonProperty("server_time_zone") Optional serverTimeZone) {
+ Utils.checkNotNull(initialLoadTimeoutHours, "initialLoadTimeoutHours");
Utils.checkNotNull(initialWaitingSeconds, "initialWaitingSeconds");
Utils.checkNotNull(invalidCdcCursorPositionBehavior, "invalidCdcCursorPositionBehavior");
Utils.checkNotNull(serverTimeZone, "serverTimeZone");
+ this.initialLoadTimeoutHours = initialLoadTimeoutHours;
this.initialWaitingSeconds = initialWaitingSeconds;
this.invalidCdcCursorPositionBehavior = invalidCdcCursorPositionBehavior;
this.method = Builder._SINGLETON_VALUE_Method.value();
@@ -63,7 +73,16 @@ public ReadChangesUsingBinaryLogCDC(
}
public ReadChangesUsingBinaryLogCDC() {
- this(Optional.empty(), Optional.empty(), Optional.empty());
+ this(Optional.empty(), Optional.empty(), Optional.empty(), Optional.empty());
+ }
+
+ /**
+ * The amount of time an initial load is allowed to continue for before catching up on CDC logs.
+ */
+ @SuppressWarnings("unchecked")
+ @JsonIgnore
+ public Optional initialLoadTimeoutHours() {
+ return (Optional) initialLoadTimeoutHours;
}
/**
@@ -102,6 +121,24 @@ public final static Builder builder() {
return new Builder();
}
+ /**
+ * The amount of time an initial load is allowed to continue for before catching up on CDC logs.
+ */
+ public ReadChangesUsingBinaryLogCDC withInitialLoadTimeoutHours(long initialLoadTimeoutHours) {
+ Utils.checkNotNull(initialLoadTimeoutHours, "initialLoadTimeoutHours");
+ this.initialLoadTimeoutHours = Optional.ofNullable(initialLoadTimeoutHours);
+ return this;
+ }
+
+ /**
+ * The amount of time an initial load is allowed to continue for before catching up on CDC logs.
+ */
+ public ReadChangesUsingBinaryLogCDC withInitialLoadTimeoutHours(Optional initialLoadTimeoutHours) {
+ Utils.checkNotNull(initialLoadTimeoutHours, "initialLoadTimeoutHours");
+ this.initialLoadTimeoutHours = initialLoadTimeoutHours;
+ return this;
+ }
+
/**
* The amount of time the connector will wait when it launches to determine if there is new data to sync or not. Defaults to 300 seconds. Valid range: 120 seconds to 1200 seconds. Read about <a href="https://docs.airbyte.com/integrations/sources/mysql/#change-data-capture-cdc">initial waiting time</a>.
*/
@@ -166,6 +203,7 @@ public boolean equals(java.lang.Object o) {
}
ReadChangesUsingBinaryLogCDC other = (ReadChangesUsingBinaryLogCDC) o;
return
+ java.util.Objects.deepEquals(this.initialLoadTimeoutHours, other.initialLoadTimeoutHours) &&
java.util.Objects.deepEquals(this.initialWaitingSeconds, other.initialWaitingSeconds) &&
java.util.Objects.deepEquals(this.invalidCdcCursorPositionBehavior, other.invalidCdcCursorPositionBehavior) &&
java.util.Objects.deepEquals(this.method, other.method) &&
@@ -175,6 +213,7 @@ public boolean equals(java.lang.Object o) {
@Override
public int hashCode() {
return java.util.Objects.hash(
+ initialLoadTimeoutHours,
initialWaitingSeconds,
invalidCdcCursorPositionBehavior,
method,
@@ -184,6 +223,7 @@ public int hashCode() {
@Override
public String toString() {
return Utils.toString(ReadChangesUsingBinaryLogCDC.class,
+ "initialLoadTimeoutHours", initialLoadTimeoutHours,
"initialWaitingSeconds", initialWaitingSeconds,
"invalidCdcCursorPositionBehavior", invalidCdcCursorPositionBehavior,
"method", method,
@@ -192,6 +232,8 @@ public String toString() {
public final static class Builder {
+ private Optional initialLoadTimeoutHours;
+
private Optional initialWaitingSeconds;
private Optional invalidCdcCursorPositionBehavior;
@@ -202,6 +244,24 @@ private Builder() {
// force use of static builder() method
}
+ /**
+ * The amount of time an initial load is allowed to continue for before catching up on CDC logs.
+ */
+ public Builder initialLoadTimeoutHours(long initialLoadTimeoutHours) {
+ Utils.checkNotNull(initialLoadTimeoutHours, "initialLoadTimeoutHours");
+ this.initialLoadTimeoutHours = Optional.ofNullable(initialLoadTimeoutHours);
+ return this;
+ }
+
+ /**
+ * The amount of time an initial load is allowed to continue for before catching up on CDC logs.
+ */
+ public Builder initialLoadTimeoutHours(Optional initialLoadTimeoutHours) {
+ Utils.checkNotNull(initialLoadTimeoutHours, "initialLoadTimeoutHours");
+ this.initialLoadTimeoutHours = initialLoadTimeoutHours;
+ return this;
+ }
+
/**
* The amount of time the connector will wait when it launches to determine if there is new data to sync or not. Defaults to 300 seconds. Valid range: 120 seconds to 1200 seconds. Read about <a href="https://docs.airbyte.com/integrations/sources/mysql/#change-data-capture-cdc">initial waiting time</a>.
*/
@@ -257,6 +317,9 @@ public Builder serverTimeZone(Optional serverTimeZone) {
}
public ReadChangesUsingBinaryLogCDC build() {
+ if (initialLoadTimeoutHours == null) {
+ initialLoadTimeoutHours = _SINGLETON_VALUE_InitialLoadTimeoutHours.value();
+ }
if (initialWaitingSeconds == null) {
initialWaitingSeconds = _SINGLETON_VALUE_InitialWaitingSeconds.value();
}
@@ -264,11 +327,18 @@ public ReadChangesUsingBinaryLogCDC build() {
invalidCdcCursorPositionBehavior = _SINGLETON_VALUE_InvalidCdcCursorPositionBehavior.value();
}
return new ReadChangesUsingBinaryLogCDC(
+ initialLoadTimeoutHours,
initialWaitingSeconds,
invalidCdcCursorPositionBehavior,
serverTimeZone);
}
+ private static final LazySingletonValue> _SINGLETON_VALUE_InitialLoadTimeoutHours =
+ new LazySingletonValue<>(
+ "initial_load_timeout_hours",
+ "8",
+ new TypeReference>() {});
+
private static final LazySingletonValue