This module takes the processed Flipper data and converts it into database change operations. It prepares INSERT, UPDATE, and DELETE statements for SQL database persistence. The module handles: - Creation of appropriate tables based on protobuf schema - Efficient batching of database operations - Conflict resolution and idempotent operations This module is designed to work with the SQL sink to populate your database with Flipper data.
Output
sf.substreams.sink.database.v1.DatabaseChanges
Inputs