Batch | Kestra

Batch

Bulk insert rows into Actian Vector using prepared statements

yaml
type: "io.kestra.plugin.jdbc.actianvector.Batch"

Examples

yaml
id: actianvector_batch_query
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.jdbc.actianvector.Query
    url: jdbc:vectorwise://dev:port/base
    username: "{{ secret('VECTORWISE_USERNAME') }}"
    password: "{{ secret('VECTORWISE_PASSWORD') }}"
    sql: |
      SELECT *
      FROM xref
      LIMIT 1500;
    fetchType: STORE

  - id: update
    type: io.kestra.plugin.jdbc.actianvector.Batch
    from: "{{ outputs.query.uri }}"
    url: jdbc:vectorwise://prod:port/base
    username: "{{ secret('VECTORWISE_USERNAME') }}"
    password: "{{ secret('VECTORWISE_PASSWORD') }}"
    sql: insert into xref values( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? )

yaml
    id: actianvector_batch_query
    namespace: company.team

    tasks:
      - id: query
        type: io.kestra.plugin.jdbc.actianvector.Query
        url: jdbc:vectorwise://dev:port/base
        username: admin
        password: admin_passwd
        sql: |
          SELECT *
          FROM xref
          LIMIT 1500;
        fetchType: STORE

      - id: update
        type: io.kestra.plugin.jdbc.actianvector.Batch
        from: "{{ outputs.query.uri }}"
        url: jdbc:vectorwise://prod:port/base
        username: admin
        password: admin_passwd
        table: xref

Properties

from *string

url *string

chunk integerstring

Default1000

columns array

SubTypestring

password string

sql string

table string

timeZoneId string

username string

Outputs

rowCount integer

updatedCount integer

Metrics

query counter

Unitqueries

records counter

Unitrecords

updated counter

Unitrecords

Apache Cassandra

Tasks that integrate Apache Cassandra into Kestra workflows for querying and event-driven triggers.

Data

MongoDB

Tasks that query and manipulate MongoDB collections.

Data

Weaviate

Tasks that manage and query vectors in Weaviate.

DataAI

Batch

Bulk insert rows into Actian Vector using prepared statements

More Plugins in this Category

Apache Cassandra

MongoDB

Weaviate

1.8.0

Batch Bulk insert rows into Actian Vector using prepared statements

More Plugins in this Category

Apache Cassandra

MongoDB

Weaviate

1.8.0

Batch

Bulk insert rows into Actian Vector using prepared statements