diff --git a/examples/applications/query-couchbase/write.yaml b/examples/applications/query-couchbase/write.yaml index 1ef3b6033..3767fd5cd 100644 --- a/examples/applications/query-couchbase/write.yaml +++ b/examples/applications/query-couchbase/write.yaml @@ -20,6 +20,21 @@ topics: creation-mode: create-if-not-exists errors: on-failure: skip +assets: + - name: "Couchbase Assets" + asset-type: "couchbase-assets" + creation-mode: create-if-not-exists + deletion-mode: none + config: + datasource: "CouchbaseDatasource" # Index name comes from datasource + username: "PLACEHOLDER" + password: "PLACEHOLDER" + connection_string: "PLACEHOLDER" + bucket: "PLACEHOLDER" + scope: "PLACEHOLDER" + collection: "PLACEHOLDER" + dimension: 1536 + port: 8091 pipeline: - name: "compute-embeddings" type: "compute-ai-embeddings" diff --git a/langstream-core/src/main/java/ai/langstream/impl/assets/CouchbaseAssetsProvider.java b/langstream-core/src/main/java/ai/langstream/impl/assets/CouchbaseAssetsProvider.java index b74cb7106..aac51b7ce 100644 --- a/langstream-core/src/main/java/ai/langstream/impl/assets/CouchbaseAssetsProvider.java +++ b/langstream-core/src/main/java/ai/langstream/impl/assets/CouchbaseAssetsProvider.java @@ -78,7 +78,7 @@ public static class InstanceConfig { """ Connection string for the instance. """) - private int coonnection_string; + private int connection_string; @ConfigProperty( required = true, @@ -111,6 +111,14 @@ public static class InstanceConfig { The name of the port. """) private int port; + + @ConfigProperty( + required = true, + description = + """ + The dimension size of the vector. + """) + private int dimension; } @Data