Checkpoint.

clients/bigquery/bigquery.go

@@ -91,6 +91,7 @@ func buildLegacyRows(tableData *optimization.TableData, additionalDateFmts []str
 				return nil, fmt.Errorf("failed to cast col %q: %w", col.Name(), err)
 			}
 
+			fmt.Println("col.Name", col.Name(), "colKind", col.KindDetails, "colVal", colVal, fmt.Sprintf("colVal type: %T", colVal))
 			if colVal != nil {
 				data[col.Name()] = colVal
 			}

clients/bigquery/cast.go

@@ -21,12 +21,17 @@ func castColVal(colVal any, colKind columns.Column, additionalDateFmts []string)
 	}
 
 	switch colKind.KindDetails.Kind {
+<<<<<<< Updated upstream
 	case typing.String.Kind:
 		if val, isOk := colVal.(*decimal.Decimal); isOk {
 			return val.String(), nil
 		}
 
 		return colVal, nil
+=======
+        return fmt.Sprint(colVal), nil
+
+>>>>>>> Stashed changes
 	case typing.Float.Kind, typing.Integer.Kind, typing.Boolean.Kind:
 		return colVal, nil
 	case typing.EDecimal.Kind:

lib/cdc/relational/debezium.go

@@ -15,6 +15,8 @@ import (
 type Debezium string
 
 func (d *Debezium) GetEventFromBytes(_ typing.Settings, bytes []byte) (cdc.Event, error) {
+	fmt.Println("string", string(bytes))
+
 	var event util.SchemaEventPayload
 	if len(bytes) == 0 {
 		return nil, fmt.Errorf("empty message")

lib/destination/types/table_config.go

@@ -1,6 +1,7 @@
 package types
 
 import (
+	"fmt"
 	"log/slog"
 	"maps"
 	"sync"
@@ -26,6 +27,12 @@ func NewDwhTableConfig(columns *columns.Columns, colsToDelete map[string]time.Ti
 		colsToDelete = make(map[string]time.Time)
 	}
 
+	if columns != nil {
+		for _, col := range columns.GetColumns() {
+			fmt.Println("colName", col.Name(), "colKind", col.KindDetails)
+		}
+	}
+
 	return &DwhTableConfig{
 		columns:            columns,
 		columnsToDelete:    colsToDelete,