Iterate batch points for OpenTelemetry output (#244)

spotify · Feb 18, 2021 · e62faa2 · e62faa2
1 parent 431cbfb
commit e62faa2
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...s/opentelemetry/src/main/java/com/spotify/ffwd/opentelemetry/OpenTelemetryPluginSink.java b/...s/opentelemetry/src/main/java/com/spotify/ffwd/opentelemetry/OpenTelemetryPluginSink.java
@@ -24,6 +24,7 @@
 import com.spotify.ffwd.model.v2.Batch;
 import com.spotify.ffwd.model.v2.Metric;
 import com.spotify.ffwd.output.PluginSink;
+import com.spotify.ffwd.util.BatchMetricConverter;
 import eu.toolchain.async.AsyncFramework;
 import eu.toolchain.async.AsyncFuture;
 import io.grpc.ManagedChannel;
@@ -106,7 +107,10 @@ public void sendMetric(Metric metric) {
 
   @Override
   public void sendBatch(Batch batch) {
-    throw new RuntimeException("Batches are unsupported");
+    // TODO(hexedpackets): The batch point iteration is temporary.
+    //  Multiple metrics can be more efficiently sent in a single protobuf
+    batch.getPoints().forEach(point ->
+        sendMetric(BatchMetricConverter.convertBatchMetric(batch, point)));
   }
 
   @Override