diff --git a/ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform/PubsubMessageToObjectNode.java b/ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform/PubsubMessageToObjectNode.java index 2bbfb484a..c687a9325 100644 --- a/ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform/PubsubMessageToObjectNode.java +++ b/ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform/PubsubMessageToObjectNode.java @@ -345,6 +345,15 @@ public ObjectNode apply(TableId tableId, Map attributes, byte[] if (additionalProperties != null) { contents.put(FieldName.ADDITIONAL_PROPERTIES, Json.asString(additionalProperties)); } + + // TODO: REMOVE! This exists only for testing as described in Bug 1672992 + if ("telemetry".equals(attributes.get(Attribute.DOCUMENT_NAMESPACE)) + && "main".equals(attributes.get(Attribute.DOCUMENT_TYPE))) { + ObjectNode payload = (ObjectNode) contents.path("payload"); + JsonNode histograms = payload.path("histograms"); + payload.set("histograms2", histograms); + } + return contents; }