Route incoming records to a single Iceberg table
If you want Firehose to insert data to a single Iceberg table, simply configure a single database and table in your stream configuration as shown in the following example JSON. For single table, you do not require JQ expression and Lambda function for providing the routing information to Firehose. If you provide these fields along with JQ or Lambda, then Firehose will take input from JQ or Lambda.
[ { "DestinationDatabaseName": "UserEvents", "DestinationTableName": "customer_id", "UniqueKeys": [ "COLUMN_PLACEHOLDER" ], "S3ErrorOutputPrefix": "OPTIONAL_PREFIX_PLACEHOLDER" } ]
In this example, Firehose routes all input records to customer_id
table in
UserEvents
database. If you want to perform update or delete operations
on a single table, then you need to provide the operation for each incoming record to
Firehose using either the JSONQuery
method or Lambda
method.