From 522feb65d575de51bfee540653c372377a12831e Mon Sep 17 00:00:00 2001 From: daggerrz Date: Sun, 20 Oct 2013 22:39:13 -0400 Subject: [PATCH] Use druid-api 0.1.2-SNAPSHOT which provides Row.getRaw() --- pom.xml | 2 +- .../segment/incremental/SpatialDimensionRowFormatter.java | 5 +++++ .../segment/realtime/firehose/WikipediaIrcDecoder.java | 6 ++++++ 3 files changed, 12 insertions(+), 1 deletion(-) diff --git a/pom.xml b/pom.xml index c96335c63a3..a0a090e2f05 100644 --- a/pom.xml +++ b/pom.xml @@ -60,7 +60,7 @@ io.druid druid-api - 0.1.1 + 0.1.2-SNAPSHOT diff --git a/processing/src/main/java/io/druid/segment/incremental/SpatialDimensionRowFormatter.java b/processing/src/main/java/io/druid/segment/incremental/SpatialDimensionRowFormatter.java index 01c1ba505fc..ca98d740dc3 100644 --- a/processing/src/main/java/io/druid/segment/incremental/SpatialDimensionRowFormatter.java +++ b/processing/src/main/java/io/druid/segment/incremental/SpatialDimensionRowFormatter.java @@ -133,6 +133,11 @@ public class SpatialDimensionRowFormatter return (retVal == null) ? row.getDimension(dimension) : retVal; } + @Override + public Object getRaw(String dimension) { + return row.getRaw(dimension); + } + @Override public float getFloatMetric(String metric) { diff --git a/server/src/main/java/io/druid/segment/realtime/firehose/WikipediaIrcDecoder.java b/server/src/main/java/io/druid/segment/realtime/firehose/WikipediaIrcDecoder.java index f216b54ffac..69dc7376887 100644 --- a/server/src/main/java/io/druid/segment/realtime/firehose/WikipediaIrcDecoder.java +++ b/server/src/main/java/io/druid/segment/realtime/firehose/WikipediaIrcDecoder.java @@ -209,6 +209,12 @@ class WikipediaIrcDecoder implements IrcDecoder } } + @Override + public Object getRaw(String dimension) { + return dimensions.get(dimension); + } + + @Override public float getFloatMetric(String metric) {