Write to a database

Create an indexed Calgary database (.cydb) from any input

2 tools: Google BigQuery Output, MongoDB Output (deprecated)

Create or update a table directly in the database from an in-DB stream

Create a catalog

Create a schema under a catalog

Create an in-memory table from a query or values list

Create a virtual table from a query

Create and drop schemas in a catalog

Create and drop tables, including from a query

Remove rows matching a condition from a table; in-memory tables support it

Remove a registered external catalog

Remove a table from the catalog

Remove a view from the catalog

Insert rows from a query or values into a table

Create an in-memory table from the query result

Change column values of rows matching a condition; in-memory tables support it

DataFrame method: Turn the DataFrame into a table provider that can be registered as a view

DataFrame method: Execute and write the results into a registered table

Write rows to a Google BigQuery table on the Beam engine

Write rows to a Google Cloud Bigtable table on the Beam engine

Bulk load an existing text file into a SQL Server table

Bulk load a text file into a MySQL table with LOAD DATA

Write rows to a Cassandra table

Bulk load rows into CrateDB through its HTTP endpoint or COPY

Delete database rows whose keys match each input row

Bulk load rows into Apache Doris through stream load

Insert, update or delete entries in an LDAP directory

Bulk load rows into SQL Server through the JDBC bulk copy API

Write rows to a table in a Microsoft Access database file

Bulk load rows into MonetDB

Insert, update or upsert documents in a MongoDB collection

Delete documents from a MongoDB collection

Bulk load rows into MySQL through a FIFO file and LOAD DATA

Map fields onto a graph model and write nodes and relationships to Neo4j

Run the Neo4j bulk import command over prepared CSV files

Create or merge one or two nodes and a relationship in Neo4j per row

Bulk load rows into Oracle through SQL*Loader

Bulk load rows into PostgreSQL through COPY FROM STDIN

Write string, hash, set or list values to Redis

Bulk load rows into Amazon Redshift through COPY from S3

Bulk load rows into Snowflake through staged files and COPY

Insert rows into a database table, with batching and partitioned table names

Bulk load rows into Teradata with the fastload utility

Bulk load rows into Vertica through a COPY stream

Upsert text chunks and their embeddings into a PostgreSQL pgvector table

Record sink: write records through a database connection

17 processors, MongoDB, DynamoDB, Elasticsearch, Cosmos DB, Data Explorer, BigQuery, Redis, Splunk; incl. deletes

Translate incoming records to SQL statements and execute them as a single transaction

Put FlowFile content into a map cache under a key computed from attributes

Send records to whichever record sink service is configured

Execute a SQL update or insert held in FlowFile content, with parameters from attributes

Generate the table changes a database needs to accept the incoming flat records

80 connectors, one per system: Jdbc, Kafka, S3File, LocalFile, Doris, Iceberg, Console, Assert, …

16 connectionType values that also serve as a sink: redshift, dynamodb, mongodb, postgresql, snowflake, …

16 data stores usable as copy sink: Azure Blob Storage, Azure Cognitive Search Index, Azure Cosmos DB for NoSQL, …

6 data stores usable as copy sink: Informix, Microsoft Access, Oracle, SAP HANA, …

2 data stores usable as copy sink: Microsoft Fabric Lakehouse, Microsoft Fabric Warehouse

2 data stores usable as copy sink: MongoDB, MongoDB Atlas

Final destination of a data flow stream

Create the table once from the column definitions in the asset, with no query

Load the dataframe, Arrow table or dict rows a Python function returns into a destination table

Insert the query result into the table without touching existing rows

Create the table if absent and overwrite its contents with the query result on every run

27 destination rows in the strategy table: bigquery, snowflake, postgres, duckdb, clickhouse, …

Materialize the asset query result as a table

Truncate the table, keeping its structure, and insert the full query result

Materialize the asset query as a view

Insert selected rows into the target without updating, deleting or checking duplicates

Create and maintain a materialized view that the platform refreshes

Rebuild the model as a table on each run via create table as

Rebuild the model as a view on each run via create view as

Write a whole database to a directory of files, and read it back

write to Azure Synapse through DuckDB mssql extension

write to BigQuery through DuckDB bigquery extension

3 components, one per system, run by Rust drivers and HTTP clients, outside DuckDB: gizmosql, snowflake, databricks

6 components, one per system, run by Rust drivers and HTTP clients, outside DuckDB: oracle, teradata, db2, access, turso, …

2 components, one per system, run by DuckDB mysql extension: mysql, mariadb

2 components, one per system, run by DuckDB postgres extension: postgres, cockroach

write a table into an attached DuckDB file

write to DuckDB Quack through DuckDB quack extension

write a table into an attached DuckLake catalog

write to MotherDuck through DuckDB motherduck extension

8 components, one per system, run by Rust drivers and HTTP clients, outside DuckDB: mongodb, cassandra, scylla, redis, neo4j, …

write to Redshift through DuckDB postgres extension

write to SQL Server through DuckDB mssql extension

write a table into an attached SQLite file

6 components, one per system, run by Rust drivers and HTTP clients, outside DuckDB: pinecone, qdrant, weaviate, milvus, …

write to pgvector (Postgres) through DuckDB postgres extension

Bulk load the table into a database table, on databases that support it (paid editions only)

Delete the rows of a database table that satisfy query conditions

Delete database rows whose keys match, or do not match, keys in an EasyMorph table

Insert the table's rows into a database table

Update rows of a database table with values from the EasyMorph table (paid editions only)

Bulk load a table into an existing database table using the database's native loader

Delete database rows whose key columns match rows of the input table

Delete rows of a database table that match configured filter criteria

Insert input-table rows into a database table

Drop a table from the database

Create a new database table from a manual definition or an input table's spec

Update database rows identified by key columns with values from the input table

Write a table to a database table, creating the table when it does not exist

Materialise the result of a DB query as a new table inside the database

Write rows to a Cassandra column family

Delete rows from a database table

Deprecated Elasticsearch bulk writer, replaced by Elasticsearch REST Bulk Insert

Bulk insert rows into Elasticsearch

Deprecated Greenplum bulk loader, replaced by Greenplum Load

Bulk load rows into Greenplum

Write rows to an HBase column family

Bulk load rows into an Infobright table

Bulk load rows into Ingres VectorWise through its COPY TABLE command

Insert, upsert, update, add or delete LDAP records by distinguished name

Deprecated: load rows into LucidDB through its Remote Rows UDX

Write rows to a table of a Microsoft Access database

Load rows into a MonetDB agile mart; the reference gives the step no description

Bulk load rows into MonetDB in streaming mode

Write rows to a MongoDB collection

Bulk load rows into MySQL over a named pipe

Bulk load rows into Oracle with Oracle Bulk Loader

Deprecated: update cell data in a Palo OLAP cube

Deprecated: create or update dimension elements and consolidations in Palo

Bulk load rows into PostgreSQL

Write data to Splunk

Load rows into an agile mart table; the reference gives the step no description

Write rows to a database table

Bulk load rows into Teradata with Fastload

Bulk load or upsert rows into Teradata through TPT and the tbuild command

Bulk load rows into a Vertica table through COPY

Write a frame to a database table

Index the rows of a table into a Solr collection

Index a collection of text documents into Solr

Create a collection in a Milvus vector database

Create a collection in a Qdrant vector database

Delete rows from a Cassandra or Astra table by the input ID column

Delete a collection from a Milvus vector database

Delete a collection from a Qdrant vector database

Delete documents from a MongoDB collection

Insert rows with embeddings as documents into a Milvus collection

Insert rows with embeddings as documents into a Qdrant collection

Store the result of an in-database chain as a database table

Write a table into a Microsoft Access database file

Write a table to a Cassandra or Astra table

Write a table to a SQL database table

Write a table to a Google BigQuery table

Write documents to a MongoDB collection

Rewrite the whole table on every model evaluation

Run the query on schedule and append whatever it returns to the table

Create a table whose data the database engine itself keeps up to date

Create or replace a non-materialized view; the default kind

VIEW with materialized true, on engines that support materialized views

Write to an external database table: append, create or replace, with SQL before and after

68 components writing bulk files or running bulk loaders: tMysqlOutputBulk, tOracleBulkExec, tTeradataFastLoad

63 components, one per database, inserting, updating or deleting rows: tMysqlOutput, tOracleOutput, tSnowflakeOutput

Delete rows from an HBase table by row key

Rename one or more entries in an LDAP directory

Index a clean, deduplicated data set in Elasticsearch for continuous matching

Create a Neo4j database and bulk import CSV files into it with the Neo4j Import Tool

Create a Neo4j 4.x database and bulk import CSV files into it with the Neo4j Import Tool

Upsert, update or delete records in a Pinecone index namespace, or query and fetch them

Call Sqoop to transfer data from HDFS to a relational database

Create a Lucene index and feed it with entries and their synonyms