parca-dev
diff --git a/‎pkg/normalizer/arrow.go‎
Lines changed: 3 additions & 0 deletions b/‎pkg/normalizer/arrow.go‎
Lines changed: 3 additions & 0 deletions
@@ -39,6 +39,7 @@ const (
 
 const (
 	MetadataSchemaVersionV1 = "v1"
+	MetadataSchemaVersionV2 = "v2"
 )
 
 func NewMetrics(reg prometheus.Registerer) *Metrics {
@@ -145,6 +146,8 @@ func (c *arrowToInternalConverter) AddSampleRecord(
 	switch value {
 	case MetadataSchemaVersionV1:
 		return c.AddSampleRecordV1(ctx, rec)
+	case MetadataSchemaVersionV2:
+		return c.AddSampleRecordV2(ctx, rec)
 	default:
 		return fmt.Errorf("unsupported schema version %q", value)
 	}
Original file line number	Diff line number	Diff line change
`@@ -39,6 +39,7 @@ const (`
`39`	`39`
`40`	`40`	`const (`
`41`	`41`	`MetadataSchemaVersionV1 = "v1"`
	`42`	`+ MetadataSchemaVersionV2 = "v2"`
`42`	`43`	`)`
`43`	`44`
`44`	`45`	`func NewMetrics(reg prometheus.Registerer) *Metrics {`
`@@ -145,6 +146,8 @@ func (c *arrowToInternalConverter) AddSampleRecord(`
`145`	`146`	`switch value {`
`146`	`147`	`case MetadataSchemaVersionV1:`
`147`	`148`	`return c.AddSampleRecordV1(ctx, rec)`
	`149`	`+ case MetadataSchemaVersionV2:`
	`150`	`+ return c.AddSampleRecordV2(ctx, rec)`
`148`	`151`	`default:`
`149`	`152`	`return fmt.Errorf("unsupported schema version %q", value)`
`150`	`153`	`}`