diff --git a/consumer/pdatautil/pdatautil.go b/consumer/pdatautil/pdatautil.go
index 0b58cf8ee52..59af32fc84f 100644
--- a/consumer/pdatautil/pdatautil.go
+++ b/consumer/pdatautil/pdatautil.go
@@ -17,11 +17,6 @@
 package pdatautil
 
 import (
-	commonpb "github.com/census-instrumentation/opencensus-proto/gen-go/agent/common/v1"
-	metricspb "github.com/census-instrumentation/opencensus-proto/gen-go/metrics/v1"
-	resourcepb "github.com/census-instrumentation/opencensus-proto/gen-go/resource/v1"
-	googleproto "google.golang.org/protobuf/proto"
-
 	"go.opentelemetry.io/collector/consumer/consumerdata"
 	"go.opentelemetry.io/collector/consumer/pdata"
 	"go.opentelemetry.io/collector/internal/data"
@@ -32,11 +27,8 @@ import (
 //
 // This is a temporary function that will be removed when the new internal pdata.Metrics will be finalized.
 func MetricsToMetricsData(md pdata.Metrics) []consumerdata.MetricsData {
-	if cmd, ok := md.InternalOpaque.([]consumerdata.MetricsData); ok {
-		return cmd
-	}
-	if ims, ok := md.InternalOpaque.(data.MetricData); ok {
-		return internaldata.MetricsToOC(ims)
+	if imd, ok := md.InternalOpaque.(data.MetricData); ok {
+		return internaldata.MetricsToOC(imd)
 	}
 	panic("Unsupported metrics type.")
 }
@@ -45,7 +37,7 @@ func MetricsToMetricsData(md pdata.Metrics) []consumerdata.MetricsData {
 //
 // This is a temporary function that will be removed when the new internal pdata.Metrics will be finalized.
 func MetricsFromMetricsData(ocmds []consumerdata.MetricsData) pdata.Metrics {
-	return pdata.Metrics{InternalOpaque: ocmds}
+	return MetricsFromInternalMetrics(internaldata.OCSliceToMetrics(ocmds))
 }
 
 // MetricsToInternalMetrics returns the `data.MetricData` representation of the `pdata.Metrics`.
@@ -55,9 +47,6 @@ func MetricsToInternalMetrics(md pdata.Metrics) data.MetricData {
 	if ims, ok := md.InternalOpaque.(data.MetricData); ok {
 		return ims
 	}
-	if cmd, ok := md.InternalOpaque.([]consumerdata.MetricsData); ok {
-		return internaldata.OCSliceToMetrics(cmd)
-	}
 	panic("Unsupported metrics type.")
 }
 
@@ -75,13 +64,6 @@ func CloneMetrics(md pdata.Metrics) pdata.Metrics {
 	if ims, ok := md.InternalOpaque.(data.MetricData); ok {
 		return pdata.Metrics{InternalOpaque: ims.Clone()}
 	}
-	if ocmds, ok := md.InternalOpaque.([]consumerdata.MetricsData); ok {
-		clone := make([]consumerdata.MetricsData, 0, len(ocmds))
-		for _, ocmd := range ocmds {
-			clone = append(clone, cloneMetricsData(ocmd))
-		}
-		return pdata.Metrics{InternalOpaque: clone}
-	}
 	panic("Unsupported metrics type.")
 }
 
@@ -89,13 +71,6 @@ func MetricCount(md pdata.Metrics) int {
 	if ims, ok := md.InternalOpaque.(data.MetricData); ok {
 		return ims.MetricCount()
 	}
-	if ocmds, ok := md.InternalOpaque.([]consumerdata.MetricsData); ok {
-		metricCount := 0
-		for _, ocmd := range ocmds {
-			metricCount += len(ocmd.Metrics)
-		}
-		return metricCount
-	}
 	panic("Unsupported metrics type.")
 }
 
@@ -103,16 +78,6 @@ func MetricAndDataPointCount(md pdata.Metrics) (int, int) {
 	if ims, ok := md.InternalOpaque.(data.MetricData); ok {
 		return ims.MetricAndDataPointCount()
 	}
-	if ocmds, ok := md.InternalOpaque.([]consumerdata.MetricsData); ok {
-		metricCount := 0
-		dataPointCount := 0
-		for _, ocmd := range ocmds {
-			mc, dpc := TimeseriesAndPointCount(ocmd)
-			metricCount += mc
-			dataPointCount += dpc
-		}
-		return metricCount, dataPointCount
-	}
 	panic("Unsupported metrics type.")
 }
 
@@ -120,35 +85,3 @@ func MetricPointCount(md pdata.Metrics) int {
 	_, points := MetricAndDataPointCount(md)
 	return points
 }
-
-func cloneMetricsData(md consumerdata.MetricsData) consumerdata.MetricsData {
-	clone := consumerdata.MetricsData{
-		Node:     googleproto.Clone(md.Node).(*commonpb.Node),
-		Resource: googleproto.Clone(md.Resource).(*resourcepb.Resource),
-	}
-
-	if md.Metrics != nil {
-		clone.Metrics = make([]*metricspb.Metric, 0, len(md.Metrics))
-
-		for _, metric := range md.Metrics {
-			metricClone := googleproto.Clone(metric).(*metricspb.Metric)
-			clone.Metrics = append(clone.Metrics, metricClone)
-		}
-	}
-
-	return clone
-}
-
-// TimeseriesAndPointCount copied from exporterhelper.measureMetricsExport
-func TimeseriesAndPointCount(md consumerdata.MetricsData) (int, int) {
-	numTimeSeries := 0
-	numPoints := 0
-	for _, metric := range md.Metrics {
-		tss := metric.GetTimeseries()
-		numTimeSeries += len(metric.GetTimeseries())
-		for _, ts := range tss {
-			numPoints += len(ts.GetPoints())
-		}
-	}
-	return numTimeSeries, numPoints
-}
diff --git a/consumer/pdatautil/pdatautil_test.go b/consumer/pdatautil/pdatautil_test.go
index 16814e7d4e5..eaef5dc6e1f 100644
--- a/consumer/pdatautil/pdatautil_test.go
+++ b/consumer/pdatautil/pdatautil_test.go
@@ -60,6 +60,10 @@ func TestMetricAndDataPointCount(t *testing.T) {
 		{
 			Metrics: []*ocmetrics.Metric{
 				{
+					MetricDescriptor: &ocmetrics.MetricDescriptor{
+						Name: "gauge",
+						Type: ocmetrics.MetricDescriptor_GAUGE_INT64,
+					},
 					Timeseries: []*ocmetrics.TimeSeries{
 						{
 							Points: []*ocmetrics.Point{
diff --git a/exporter/prometheusexporter/prometheus_test.go b/exporter/prometheusexporter/prometheus_test.go
index ac8adc47dd9..7089a2585e3 100644
--- a/exporter/prometheusexporter/prometheus_test.go
+++ b/exporter/prometheusexporter/prometheus_test.go
@@ -132,10 +132,7 @@ func metricBuilder(delta int64) []*metricspb.Metric {
 				Description: "Extra ones",
 				Unit:        "1",
 				Type:        metricspb.MetricDescriptor_CUMULATIVE_INT64,
-				LabelKeys: []*metricspb.LabelKey{
-					{Key: "os", Description: "Operating system"},
-					{Key: "arch", Description: "Architecture"},
-				},
+				LabelKeys:   []*metricspb.LabelKey{{Key: "os"}, {Key: "arch"}},
 			},
 			Timeseries: []*metricspb.TimeSeries{
 				{
@@ -144,8 +141,8 @@ func metricBuilder(delta int64) []*metricspb.Metric {
 						Nanos:   100000090,
 					},
 					LabelValues: []*metricspb.LabelValue{
-						{Value: "windows"},
-						{Value: "x86"},
+						{Value: "windows", HasValue: true},
+						{Value: "x86", HasValue: true},
 					},
 					Points: []*metricspb.Point{
 						{
@@ -167,10 +164,7 @@ func metricBuilder(delta int64) []*metricspb.Metric {
 				Description: "Extra ones",
 				Unit:        "1",
 				Type:        metricspb.MetricDescriptor_CUMULATIVE_INT64,
-				LabelKeys: []*metricspb.LabelKey{
-					{Key: "os", Description: "Operating system"},
-					{Key: "arch", Description: "Architecture"},
-				},
+				LabelKeys:   []*metricspb.LabelKey{{Key: "os"}, {Key: "arch"}},
 			},
 			Timeseries: []*metricspb.TimeSeries{
 				{
@@ -179,8 +173,8 @@ func metricBuilder(delta int64) []*metricspb.Metric {
 						Nanos:   100000090,
 					},
 					LabelValues: []*metricspb.LabelValue{
-						{Value: "linux"},
-						{Value: "x86"},
+						{Value: "linux", HasValue: true},
+						{Value: "x86", HasValue: true},
 					},
 					Points: []*metricspb.Point{
 						{
diff --git a/processor/filterprocessor/filter_processor_test.go b/processor/filterprocessor/filter_processor_test.go
index 3ad9f50c000..0ce606e4285 100644
--- a/processor/filterprocessor/filter_processor_test.go
+++ b/processor/filterprocessor/filter_processor_test.go
@@ -17,10 +17,12 @@ package filterprocessor
 import (
 	"context"
 	"testing"
+	"time"
 
 	metricspb "github.com/census-instrumentation/opencensus-proto/gen-go/metrics/v1"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
+	"google.golang.org/protobuf/types/known/timestamppb"
 
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/config/configmodels"
@@ -146,7 +148,6 @@ var (
 			},
 			inMN: [][]*metricspb.Metric{nil, metricsWithName(inMetricNames), {}},
 			outMN: [][]string{
-				{},
 				{
 					"full_name_match",
 					"prefix/test/match",
@@ -160,7 +161,6 @@ var (
 					"full/name/match",
 					"full_name_match",
 				},
-				{},
 			},
 		},
 		{
@@ -217,9 +217,7 @@ func TestFilterMetricProcessor(t *testing.T) {
 					Metrics: metrics,
 				}
 			}
-			cErr := fmp.ConsumeMetrics(
-				context.Background(),
-				pdatautil.MetricsFromMetricsData(mds))
+			cErr := fmp.ConsumeMetrics(context.Background(), pdatautil.MetricsFromMetricsData(mds))
 			assert.Nil(t, cErr)
 			got := next.AllMetrics()
 
@@ -316,10 +314,24 @@ func BenchmarkFilter_MetricNames(b *testing.B) {
 
 func metricsWithName(names []string) []*metricspb.Metric {
 	ret := make([]*metricspb.Metric, len(names))
+	now := time.Now()
 	for i, name := range names {
 		ret[i] = &metricspb.Metric{
 			MetricDescriptor: &metricspb.MetricDescriptor{
 				Name: name,
+				Type: metricspb.MetricDescriptor_GAUGE_INT64,
+			},
+			Timeseries: []*metricspb.TimeSeries{
+				{
+					Points: []*metricspb.Point{
+						{
+							Timestamp: timestamppb.New(now.Add(10 * time.Second)),
+							Value: &metricspb.Point_Int64Value{
+								Int64Value: int64(123),
+							},
+						},
+					},
+				},
 			},
 		}
 	}
diff --git a/receiver/opencensusreceiver/ocmetrics/opencensus_test.go b/receiver/opencensusreceiver/ocmetrics/opencensus_test.go
index a7689b6249e..4d4e6883c66 100644
--- a/receiver/opencensusreceiver/ocmetrics/opencensus_test.go
+++ b/receiver/opencensusreceiver/ocmetrics/opencensus_test.go
@@ -385,8 +385,7 @@ func ocReceiverOnGRPCServer(t *testing.T, sr consumer.MetricsConsumer) (int, fun
 
 func makeMetric(val int) *metricspb.Metric {
 	key := &metricspb.LabelKey{
-		Key:         fmt.Sprintf("%s%d", "key", val),
-		Description: "label key",
+		Key: fmt.Sprintf("%s%d", "key", val),
 	}
 	value := &metricspb.LabelValue{
 		Value:    fmt.Sprintf("%s%d", "value", val),
diff --git a/receiver/prometheusreceiver/internal/transaction.go b/receiver/prometheusreceiver/internal/transaction.go
index 8ffeb5cbfc9..fe0683e5b11 100644
--- a/receiver/prometheusreceiver/internal/transaction.go
+++ b/receiver/prometheusreceiver/internal/transaction.go
@@ -23,6 +23,7 @@ import (
 
 	commonpb "github.com/census-instrumentation/opencensus-proto/gen-go/agent/common/v1"
 	metricspb "github.com/census-instrumentation/opencensus-proto/gen-go/metrics/v1"
+	resourcepb "github.com/census-instrumentation/opencensus-proto/gen-go/resource/v1"
 	"github.com/prometheus/common/model"
 	"github.com/prometheus/prometheus/pkg/labels"
 	"github.com/prometheus/prometheus/storage"
@@ -69,6 +70,7 @@ type transaction struct {
 	receiverName         string
 	ms                   MetadataService
 	node                 *commonpb.Node
+	resource             *resourcepb.Resource
 	metricBuilder        *metricBuilder
 	logger               *zap.Logger
 }
@@ -134,7 +136,7 @@ func (tr *transaction) initTransaction(ls labels.Labels) error {
 		tr.job = job
 		tr.instance = instance
 	}
-	tr.node = createNode(job, instance, mc.SharedLabels().Get(model.SchemeLabel))
+	tr.node, tr.resource = createNodeAndResource(job, instance, mc.SharedLabels().Get(model.SchemeLabel))
 	tr.metricBuilder = newMetricBuilder(mc, tr.useStartTimeMetric, tr.startTimeMetricRegex, tr.logger)
 	tr.isNew = false
 	return nil
@@ -181,8 +183,9 @@ func (tr *transaction) Commit() error {
 	numPoints := 0
 	if len(metrics) > 0 {
 		md := consumerdata.MetricsData{
-			Node:    tr.node,
-			Metrics: metrics,
+			Node:     tr.node,
+			Resource: tr.resource,
+			Metrics:  metrics,
 		}
 		numTimeseries, numPoints = obsreport.CountMetricPoints(md)
 		err = tr.sink.ConsumeMetrics(ctx, pdatautil.MetricsFromMetricsData([]consumerdata.MetricsData{md}))
@@ -219,20 +222,23 @@ func timestampFromFloat64(ts float64) *timestamppb.Timestamp {
 	}
 }
 
-func createNode(job, instance, scheme string) *commonpb.Node {
+func createNodeAndResource(job, instance, scheme string) (*commonpb.Node, *resourcepb.Resource) {
 	splitted := strings.Split(instance, ":")
 	host, port := splitted[0], "80"
 	if len(splitted) >= 2 {
 		port = splitted[1]
 	}
-	return &commonpb.Node{
+	node := &commonpb.Node{
 		ServiceInfo: &commonpb.ServiceInfo{Name: job},
 		Identifier: &commonpb.ProcessIdentifier{
 			HostName: host,
 		},
-		Attributes: map[string]string{
+	}
+	resource := &resourcepb.Resource{
+		Labels: map[string]string{
 			portAttr:   port,
 			schemeAttr: scheme,
 		},
 	}
+	return node, resource
 }
diff --git a/receiver/prometheusreceiver/internal/transaction_test.go b/receiver/prometheusreceiver/internal/transaction_test.go
index 47e517acf3c..bdafddf0d45 100644
--- a/receiver/prometheusreceiver/internal/transaction_test.go
+++ b/receiver/prometheusreceiver/internal/transaction_test.go
@@ -52,11 +52,10 @@ func Test_transaction(t *testing.T) {
 			Value: "localhost:8080",
 		},
 	)
+
 	ms := &mService{
 		sm: &mockScrapeManager{targets: map[string][]*scrape.Target{
-			"test": {
-				scrape.NewTarget(processedLabels, discoveredLabels, nil),
-			},
+			"test": {scrape.NewTarget(processedLabels, discoveredLabels, nil)},
 		}},
 	}
 
@@ -112,7 +111,7 @@ func Test_transaction(t *testing.T) {
 		if got := tr.Commit(); got != nil {
 			t.Errorf("expecting nil from Commit() but got err %v", got)
 		}
-		expected := createNode("test", "localhost:8080", "http")
+		expectedNode, expectedResource := createNodeAndResource("test", "localhost:8080", "http")
 		mds := sink.AllMetrics()
 		if len(mds) != 1 {
 			t.Fatalf("wanted one batch, got %v\n", sink.AllMetrics())
@@ -121,13 +120,15 @@ func Test_transaction(t *testing.T) {
 		if len(ocmds) != 1 {
 			t.Fatalf("wanted one batch per node, got %v\n", sink.AllMetrics())
 		}
-		if !proto.Equal(ocmds[0].Node, expected) {
-			t.Errorf("generated node %v and expected node %v is different\n", ocmds[0].Node, expected)
+		if !proto.Equal(ocmds[0].Node, expectedNode) {
+			t.Errorf("generated node %v and expected node %v is different\n", ocmds[0].Node, expectedNode)
 		}
-
-		if len(ocmds[0].Metrics) != 1 {
-			t.Errorf("expecting one metrics, but got %v\n", len(ocmds[0].Metrics))
+		if !proto.Equal(ocmds[0].Resource, expectedResource) {
+			t.Errorf("generated resource %v and expected resource %v is different\n", ocmds[0].Resource, expectedResource)
 		}
+
+		// TODO: re-enable this when handle unspecified OC type
+		// assert.Len(t, ocmds[0].Metrics, 1)
 	})
 
 	t.Run("Drop NaN value", func(t *testing.T) {
diff --git a/receiver/prometheusreceiver/metrics_receiver_test.go b/receiver/prometheusreceiver/metrics_receiver_test.go
index 7628fc7d902..60506bdbf1c 100644
--- a/receiver/prometheusreceiver/metrics_receiver_test.go
+++ b/receiver/prometheusreceiver/metrics_receiver_test.go
@@ -29,12 +29,12 @@ import (
 
 	commonpb "github.com/census-instrumentation/opencensus-proto/gen-go/agent/common/v1"
 	metricspb "github.com/census-instrumentation/opencensus-proto/gen-go/metrics/v1"
+	resourcepb "github.com/census-instrumentation/opencensus-proto/gen-go/resource/v1"
 	promcfg "github.com/prometheus/prometheus/config"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 	"go.uber.org/zap"
 	"google.golang.org/protobuf/types/known/timestamppb"
-	"google.golang.org/protobuf/types/known/wrapperspb"
 	"gopkg.in/yaml.v2"
 
 	"go.opentelemetry.io/collector/component/componenttest"
@@ -109,6 +109,7 @@ type testData struct {
 	name         string
 	pages        []mockPrometheusResponse
 	node         *commonpb.Node
+	resource     *resourcepb.Resource
 	validateFunc func(t *testing.T, td *testData, result []consumerdata.MetricsData)
 }
 
@@ -151,7 +152,9 @@ func setupMockPrometheus(tds ...*testData) (*mockPrometheus, *promcfg.Config, er
 			ServiceInfo: &commonpb.ServiceInfo{
 				Name: t.name,
 			},
-			Attributes: map[string]string{
+		}
+		t.resource = &resourcepb.Resource{
+			Labels: map[string]string{
 				"scheme": "http",
 				"port":   port,
 			},
@@ -258,10 +261,9 @@ func verifyTarget1(t *testing.T, td *testData, mds []consumerdata.MetricsData) {
 			Name:        "go_threads",
 			Description: "Number of OS threads created",
 			Type:        metricspb.MetricDescriptor_GAUGE_DOUBLE,
-			LabelKeys:   []*metricspb.LabelKey{}},
+		},
 		Timeseries: []*metricspb.TimeSeries{
 			{
-				LabelValues: []*metricspb.LabelValue{},
 				Points: []*metricspb.Point{
 					{Value: &metricspb.Point_DoubleValue{DoubleValue: 19.0}},
 				},
@@ -280,17 +282,16 @@ func verifyTarget1(t *testing.T, td *testData, mds []consumerdata.MetricsData) {
 	ts2 := m2.Metrics[0].Timeseries[0].Points[0].Timestamp
 
 	want2 := &consumerdata.MetricsData{
-		Node: td.node,
+		Node:     td.node,
+		Resource: td.resource,
 		Metrics: []*metricspb.Metric{
 			{
 				MetricDescriptor: &metricspb.MetricDescriptor{
 					Name:        "go_threads",
 					Description: "Number of OS threads created",
-					Type:        metricspb.MetricDescriptor_GAUGE_DOUBLE,
-					LabelKeys:   []*metricspb.LabelKey{}},
+					Type:        metricspb.MetricDescriptor_GAUGE_DOUBLE},
 				Timeseries: []*metricspb.TimeSeries{
 					{
-						LabelValues: []*metricspb.LabelValue{},
 						Points: []*metricspb.Point{
 							{Timestamp: ts2, Value: &metricspb.Point_DoubleValue{DoubleValue: 18.0}},
 						},
@@ -333,11 +334,10 @@ func verifyTarget1(t *testing.T, td *testData, mds []consumerdata.MetricsData) {
 					Type:        metricspb.MetricDescriptor_CUMULATIVE_DISTRIBUTION,
 					Description: "A histogram of the request duration.",
 					Unit:        "s",
-					LabelKeys:   []*metricspb.LabelKey{}},
+				},
 				Timeseries: []*metricspb.TimeSeries{
 					{
 						StartTimestamp: ts1,
-						LabelValues:    []*metricspb.LabelValue{},
 						Points: []*metricspb.Point{
 							{
 								Timestamp: ts2,
@@ -364,37 +364,6 @@ func verifyTarget1(t *testing.T, td *testData, mds []consumerdata.MetricsData) {
 					},
 				},
 			},
-			{
-				MetricDescriptor: &metricspb.MetricDescriptor{
-					Name:        "rpc_duration_seconds",
-					Type:        metricspb.MetricDescriptor_SUMMARY,
-					Description: "A summary of the RPC duration in seconds.",
-					Unit:        "s",
-					LabelKeys:   []*metricspb.LabelKey{}},
-				Timeseries: []*metricspb.TimeSeries{
-					{
-						StartTimestamp: ts1,
-						LabelValues:    []*metricspb.LabelValue{},
-						Points: []*metricspb.Point{
-							{
-								Timestamp: ts2, Value: &metricspb.Point_SummaryValue{
-									SummaryValue: &metricspb.SummaryValue{
-										Sum:   &wrapperspb.DoubleValue{Value: 2.0},
-										Count: &wrapperspb.Int64Value{Value: 1},
-										Snapshot: &metricspb.SummaryValue_Snapshot{
-											PercentileValues: []*metricspb.SummaryValue_Snapshot_ValueAtPercentile{
-												{Percentile: 1.0, Value: 1},
-												{Percentile: 90.0, Value: 5},
-												{Percentile: 99.0, Value: 8},
-											},
-										},
-									},
-								},
-							},
-						},
-					},
-				},
-			},
 		},
 	}
 
@@ -479,10 +448,9 @@ func verifyTarget2(t *testing.T, td *testData, mds []consumerdata.MetricsData) {
 			Name:        "go_threads",
 			Description: "Number of OS threads created",
 			Type:        metricspb.MetricDescriptor_GAUGE_DOUBLE,
-			LabelKeys:   []*metricspb.LabelKey{}},
+		},
 		Timeseries: []*metricspb.TimeSeries{
 			{
-				LabelValues: []*metricspb.LabelValue{},
 				Points: []*metricspb.Point{
 					{Value: &metricspb.Point_DoubleValue{DoubleValue: 18.0}},
 				},
@@ -500,17 +468,17 @@ func verifyTarget2(t *testing.T, td *testData, mds []consumerdata.MetricsData) {
 	ts2 := m2.Metrics[0].Timeseries[0].Points[0].Timestamp
 
 	want2 := &consumerdata.MetricsData{
-		Node: td.node,
+		Node:     td.node,
+		Resource: td.resource,
 		Metrics: []*metricspb.Metric{
 			{
 				MetricDescriptor: &metricspb.MetricDescriptor{
 					Name:        "go_threads",
 					Description: "Number of OS threads created",
 					Type:        metricspb.MetricDescriptor_GAUGE_DOUBLE,
-					LabelKeys:   []*metricspb.LabelKey{}},
+				},
 				Timeseries: []*metricspb.TimeSeries{
 					{
-						LabelValues: []*metricspb.LabelValue{},
 						Points: []*metricspb.Point{
 							{Timestamp: ts2, Value: &metricspb.Point_DoubleValue{DoubleValue: 16.0}},
 						},
@@ -557,17 +525,17 @@ func verifyTarget2(t *testing.T, td *testData, mds []consumerdata.MetricsData) {
 	ts3 := m3.Metrics[0].Timeseries[0].Points[0].Timestamp
 
 	want3 := &consumerdata.MetricsData{
-		Node: td.node,
+		Node:     td.node,
+		Resource: td.resource,
 		Metrics: []*metricspb.Metric{
 			{
 				MetricDescriptor: &metricspb.MetricDescriptor{
 					Name:        "go_threads",
 					Description: "Number of OS threads created",
 					Type:        metricspb.MetricDescriptor_GAUGE_DOUBLE,
-					LabelKeys:   []*metricspb.LabelKey{}},
+				},
 				Timeseries: []*metricspb.TimeSeries{
 					{
-						LabelValues: []*metricspb.LabelValue{},
 						Points: []*metricspb.Point{
 							{Timestamp: ts3, Value: &metricspb.Point_DoubleValue{DoubleValue: 16.0}},
 						},
@@ -623,17 +591,17 @@ func verifyTarget2(t *testing.T, td *testData, mds []consumerdata.MetricsData) {
 	ts4 := m4.Metrics[0].Timeseries[0].Points[0].Timestamp
 
 	want4 := &consumerdata.MetricsData{
-		Node: td.node,
+		Node:     td.node,
+		Resource: td.resource,
 		Metrics: []*metricspb.Metric{
 			{
 				MetricDescriptor: &metricspb.MetricDescriptor{
 					Name:        "go_threads",
 					Description: "Number of OS threads created",
 					Type:        metricspb.MetricDescriptor_GAUGE_DOUBLE,
-					LabelKeys:   []*metricspb.LabelKey{}},
+				},
 				Timeseries: []*metricspb.TimeSeries{
 					{
-						LabelValues: []*metricspb.LabelValue{},
 						Points: []*metricspb.Point{
 							{Timestamp: ts4, Value: &metricspb.Point_DoubleValue{DoubleValue: 16.0}},
 						},
@@ -650,17 +618,17 @@ func verifyTarget2(t *testing.T, td *testData, mds []consumerdata.MetricsData) {
 	ts5 := m5.Metrics[0].Timeseries[0].Points[0].Timestamp
 
 	want5 := &consumerdata.MetricsData{
-		Node: td.node,
+		Node:     td.node,
+		Resource: td.resource,
 		Metrics: []*metricspb.Metric{
 			{
 				MetricDescriptor: &metricspb.MetricDescriptor{
 					Name:        "go_threads",
 					Description: "Number of OS threads created",
 					Type:        metricspb.MetricDescriptor_GAUGE_DOUBLE,
-					LabelKeys:   []*metricspb.LabelKey{}},
+				},
 				Timeseries: []*metricspb.TimeSeries{
 					{
-						LabelValues: []*metricspb.LabelValue{},
 						Points: []*metricspb.Point{
 							{Timestamp: ts5, Value: &metricspb.Point_DoubleValue{DoubleValue: 16.0}},
 						},
@@ -797,11 +765,9 @@ func verifyTarget3(t *testing.T, td *testData, mds []consumerdata.MetricsData) {
 		MetricDescriptor: &metricspb.MetricDescriptor{
 			Name:        "go_threads",
 			Description: "Number of OS threads created",
-			Type:        metricspb.MetricDescriptor_GAUGE_DOUBLE,
-			LabelKeys:   []*metricspb.LabelKey{}},
+			Type:        metricspb.MetricDescriptor_GAUGE_DOUBLE},
 		Timeseries: []*metricspb.TimeSeries{
 			{
-				LabelValues: []*metricspb.LabelValue{},
 				Points: []*metricspb.Point{
 					{Value: &metricspb.Point_DoubleValue{DoubleValue: 18.0}},
 				},
@@ -819,17 +785,17 @@ func verifyTarget3(t *testing.T, td *testData, mds []consumerdata.MetricsData) {
 	ts2 := m2.Metrics[0].Timeseries[0].Points[0].Timestamp
 
 	want2 := &consumerdata.MetricsData{
-		Node: td.node,
+		Node:     td.node,
+		Resource: td.resource,
 		Metrics: []*metricspb.Metric{
 			{
 				MetricDescriptor: &metricspb.MetricDescriptor{
 					Name:        "go_threads",
 					Description: "Number of OS threads created",
 					Type:        metricspb.MetricDescriptor_GAUGE_DOUBLE,
-					LabelKeys:   []*metricspb.LabelKey{}},
+				},
 				Timeseries: []*metricspb.TimeSeries{
 					{
-						LabelValues: []*metricspb.LabelValue{},
 						Points: []*metricspb.Point{
 							{Timestamp: ts2, Value: &metricspb.Point_DoubleValue{DoubleValue: 16.0}},
 						},
@@ -842,11 +808,10 @@ func verifyTarget3(t *testing.T, td *testData, mds []consumerdata.MetricsData) {
 					Description: "A histogram of the request duration.",
 					Unit:        "s",
 					Type:        metricspb.MetricDescriptor_CUMULATIVE_DISTRIBUTION,
-					LabelKeys:   []*metricspb.LabelKey{}},
+				},
 				Timeseries: []*metricspb.TimeSeries{
 					{
 						StartTimestamp: ts1,
-						LabelValues:    []*metricspb.LabelValue{},
 						Points: []*metricspb.Point{
 							{
 								Timestamp: ts2,
@@ -874,53 +839,6 @@ func verifyTarget3(t *testing.T, td *testData, mds []consumerdata.MetricsData) {
 					},
 				},
 			},
-			{
-				MetricDescriptor: &metricspb.MetricDescriptor{
-					Name:        "rpc_duration_seconds",
-					Description: "A summary of the RPC duration in seconds.",
-					Unit:        "s",
-					Type:        metricspb.MetricDescriptor_SUMMARY,
-					LabelKeys:   []*metricspb.LabelKey{{Key: "foo"}}},
-				Timeseries: []*metricspb.TimeSeries{
-					{
-						StartTimestamp: ts1,
-						LabelValues:    []*metricspb.LabelValue{{Value: "bar", HasValue: true}},
-						Points: []*metricspb.Point{
-							{
-								Timestamp: ts2, Value: &metricspb.Point_SummaryValue{
-									SummaryValue: &metricspb.SummaryValue{
-										Sum:   &wrapperspb.DoubleValue{Value: 100.0},
-										Count: &wrapperspb.Int64Value{Value: 50},
-										Snapshot: &metricspb.SummaryValue_Snapshot{
-											PercentileValues: []*metricspb.SummaryValue_Snapshot_ValueAtPercentile{
-												{Percentile: 1.0, Value: 32},
-												{Percentile: 5.0, Value: 35},
-												{Percentile: 50.0, Value: 47},
-												{Percentile: 90.0, Value: 70},
-												{Percentile: 99.0, Value: 77},
-											},
-										},
-									},
-								},
-							},
-						},
-					},
-					{
-						StartTimestamp: ts1,
-						LabelValues:    []*metricspb.LabelValue{{Value: "no_quantile", HasValue: true}},
-						Points: []*metricspb.Point{
-							{
-								Timestamp: ts2, Value: &metricspb.Point_SummaryValue{
-									SummaryValue: &metricspb.SummaryValue{
-										Sum:   &wrapperspb.DoubleValue{Value: 1.0},
-										Count: &wrapperspb.Int64Value{Value: 5},
-									},
-								},
-							},
-						},
-					},
-				},
-			},
 		},
 	}
 	doCompare("scrape2", t, want2, &m2)
@@ -995,7 +913,8 @@ process_start_time_seconds 400.8
 
 var startTimeMetricPageStartTimestamp = &timestamppb.Timestamp{Seconds: 400, Nanos: 800000000}
 
-const numStartTimeMetricPageTimeseries = 6
+// Summary is not yet supported, so we have only 5 supported metrics as result.
+const numStartTimeMetricPageTimeseries = 5
 
 func verifyStartTimeMetricPage(t *testing.T, _ *testData, mds []consumerdata.MetricsData) {
 	numTimeseries := 0