Method materializeCondensedDelta

delta/controller.go:404–440

Materialize the condensed delta view as a temporary table.

(
	ctx *sql.Context,
	conn *stdsql.Conn,
	tx *stdsql.Tx,
	table tableIdentifier,
	appender *DeltaAppender,
	stats *FlushStats,
)

// Materialize the condensed delta view as a temporary table.
func (c *DeltaController) materializeCondensedDelta(
	ctx *sql.Context,
	conn *stdsql.Conn,
	tx *stdsql.Tx,
	table tableIdentifier,
	appender *DeltaAppender,
	stats *FlushStats,
) error {
	viewName, release, err := c.prepareArrowView(ctx, conn, table, appender, 0, nil)
	if err != nil {
		return err
	}
	defer release()

	condenseDeltaSQL := buildCondenseDeltaSQL(viewName, appender)

	// Create a temporary table to store the latest delta view
	result, err := tx.ExecContext(ctx, "CREATE OR REPLACE TEMP TABLE delta AS "+condenseDeltaSQL)
	if err != nil {
		return err
	}
	affected, err := result.RowsAffected()
	if err != nil {
		return err
	}

	if log := ctx.GetLogger(); log.Logger.IsLevelEnabled(logrus.DebugLevel) {
		log.WithFields(logrus.Fields{
			"db":    table.dbName,
			"table": table.tableName,
			"rows":  affected,
		}).Debug("Delta created")
	}

	stats.DeltaSize += affected
	return nil
}

func (c *DeltaController) handleGeneralCase(
	ctx *sql.Context,