From 597e55ab50b27d4bd97689378d121cba87d56791 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Xavier=20L=C3=A9aut=C3=A9?= Date: Fri, 18 Apr 2014 16:26:21 -0700 Subject: [PATCH 1/6] don't override context when not finalizing --- .../io/druid/query/FinalizeResultsQueryRunner.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/processing/src/main/java/io/druid/query/FinalizeResultsQueryRunner.java b/processing/src/main/java/io/druid/query/FinalizeResultsQueryRunner.java index 0eb925f3327..57f76b20966 100644 --- a/processing/src/main/java/io/druid/query/FinalizeResultsQueryRunner.java +++ b/processing/src/main/java/io/druid/query/FinalizeResultsQueryRunner.java @@ -50,8 +50,13 @@ public class FinalizeResultsQueryRunner implements QueryRunner { final boolean isBySegment = query.getContextBySegment(false); final boolean shouldFinalize = query.getContextFinalize(true); - Function finalizerFn; + + final Query queryToRun; + final Function finalizerFn; + if (shouldFinalize) { + queryToRun = query.withOverriddenContext(ImmutableMap.of("finalize", false)); + if (isBySegment) { finalizerFn = new Function() { @@ -99,6 +104,7 @@ public class FinalizeResultsQueryRunner implements QueryRunner } } else { // finalize is false here. + queryToRun = query; finalizerFn = toolChest.makePostComputeManipulatorFn( query, new MetricManipulationFn() @@ -113,7 +119,7 @@ public class FinalizeResultsQueryRunner implements QueryRunner } return Sequences.map( - baseRunner.run(query.withOverriddenContext(ImmutableMap.of("finalize", false))), + baseRunner.run(queryToRun), finalizerFn ); From a0c8d9d413b48aa581fe0bf9f17e5a7f9e667b9a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Xavier=20L=C3=A9aut=C3=A9?= Date: Fri, 18 Apr 2014 16:45:06 -0700 Subject: [PATCH 2/6] restore previous behavior of not optimizing Timeseries post-aggregators --- .../TimeseriesQueryQueryToolChest.java | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) diff --git a/processing/src/main/java/io/druid/query/timeseries/TimeseriesQueryQueryToolChest.java b/processing/src/main/java/io/druid/query/timeseries/TimeseriesQueryQueryToolChest.java index 51a0c0ebbe0..661f83d3a4f 100644 --- a/processing/src/main/java/io/druid/query/timeseries/TimeseriesQueryQueryToolChest.java +++ b/processing/src/main/java/io/druid/query/timeseries/TimeseriesQueryQueryToolChest.java @@ -135,11 +135,11 @@ public class TimeseriesQueryQueryToolChest extends QueryToolChest, Result> makeComputeManipulatorFn( - final TimeseriesQuery query, final MetricManipulationFn fn, final boolean calculatePostAggs + private Function, Result> makeManipulatorFn( + final TimeseriesQuery query, final MetricManipulationFn fn ) { return new Function, Result>() @@ -149,14 +149,12 @@ public class TimeseriesQueryQueryToolChest extends QueryToolChest values = Maps.newHashMap(); final TimeseriesResultValue holder = result.getValue(); - if (calculatePostAggs) { - for (PostAggregator postAgg : query.getPostAggregatorSpecs()) { - values.put(postAgg.getName(), postAgg.compute(holder.getBaseObject())); - } - } for (AggregatorFactory agg : query.getAggregatorSpecs()) { values.put(agg.getName(), fn.manipulate(agg, holder.getMetric(agg.getName()))); } + for (PostAggregator postAgg : query.getPostAggregatorSpecs()) { + values.put(postAgg.getName(), postAgg.compute(values)); + } return new Result( result.getTimestamp(), @@ -278,7 +276,7 @@ public class TimeseriesQueryQueryToolChest extends QueryToolChest Date: Fri, 18 Apr 2014 17:41:47 -0700 Subject: [PATCH 3/6] clean up code --- .../query/FinalizeResultsQueryRunner.java | 32 ++------- .../FinalizeMetricManipulationFn.java | 31 ++++++++ .../IdentityMetricManipulationFn.java | 31 ++++++++ .../TimeseriesQueryQueryToolChest.java | 70 +++++++++---------- .../query/topn/TopNQueryQueryToolChest.java | 15 ++-- .../io/druid/client/DirectDruidClient.java | 22 +++--- 6 files changed, 120 insertions(+), 81 deletions(-) create mode 100644 processing/src/main/java/io/druid/query/aggregation/FinalizeMetricManipulationFn.java create mode 100644 processing/src/main/java/io/druid/query/aggregation/IdentityMetricManipulationFn.java diff --git a/processing/src/main/java/io/druid/query/FinalizeResultsQueryRunner.java b/processing/src/main/java/io/druid/query/FinalizeResultsQueryRunner.java index 57f76b20966..83edcf0a991 100644 --- a/processing/src/main/java/io/druid/query/FinalizeResultsQueryRunner.java +++ b/processing/src/main/java/io/druid/query/FinalizeResultsQueryRunner.java @@ -25,6 +25,8 @@ import com.google.common.collect.Lists; import com.metamx.common.guava.Sequence; import com.metamx.common.guava.Sequences; import io.druid.query.aggregation.AggregatorFactory; +import io.druid.query.aggregation.FinalizeMetricManipulationFn; +import io.druid.query.aggregation.IdentityMetricManipulationFn; import io.druid.query.aggregation.MetricManipulationFn; import javax.annotation.Nullable; @@ -62,14 +64,7 @@ public class FinalizeResultsQueryRunner implements QueryRunner { final Function baseFinalizer = toolChest.makePostComputeManipulatorFn( query, - new MetricManipulationFn() - { - @Override - public Object manipulate(AggregatorFactory factory, Object object) - { - return factory.finalizeComputation(factory.deserialize(object)); - } - } + new FinalizeMetricManipulationFn() ); @Override @@ -90,31 +85,14 @@ public class FinalizeResultsQueryRunner implements QueryRunner } }; } else { - finalizerFn = toolChest.makePostComputeManipulatorFn( - query, - new MetricManipulationFn() - { - @Override - public Object manipulate(AggregatorFactory factory, Object object) - { - return factory.finalizeComputation(object); - } - } - ); + finalizerFn = toolChest.makePostComputeManipulatorFn(query, new FinalizeMetricManipulationFn()); } } else { // finalize is false here. queryToRun = query; finalizerFn = toolChest.makePostComputeManipulatorFn( query, - new MetricManipulationFn() - { - @Override - public Object manipulate(AggregatorFactory factory, Object object) - { - return object; - } - } + new IdentityMetricManipulationFn() ); } diff --git a/processing/src/main/java/io/druid/query/aggregation/FinalizeMetricManipulationFn.java b/processing/src/main/java/io/druid/query/aggregation/FinalizeMetricManipulationFn.java new file mode 100644 index 00000000000..e532421e572 --- /dev/null +++ b/processing/src/main/java/io/druid/query/aggregation/FinalizeMetricManipulationFn.java @@ -0,0 +1,31 @@ +/* + * Druid - a distributed column store. + * Copyright (C) 2012, 2013 Metamarkets Group Inc. + * + * This program is free software; you can redistribute it and/or + * modify it under the terms of the GNU General Public License + * as published by the Free Software Foundation; either version 2 + * of the License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. + */ + +package io.druid.query.aggregation; + +/** + */ +public class FinalizeMetricManipulationFn implements MetricManipulationFn +{ + @Override + public Object manipulate(AggregatorFactory factory, Object object) + { + return factory.finalizeComputation(object); + } +} diff --git a/processing/src/main/java/io/druid/query/aggregation/IdentityMetricManipulationFn.java b/processing/src/main/java/io/druid/query/aggregation/IdentityMetricManipulationFn.java new file mode 100644 index 00000000000..6b99838700a --- /dev/null +++ b/processing/src/main/java/io/druid/query/aggregation/IdentityMetricManipulationFn.java @@ -0,0 +1,31 @@ +/* + * Druid - a distributed column store. + * Copyright (C) 2012, 2013 Metamarkets Group Inc. + * + * This program is free software; you can redistribute it and/or + * modify it under the terms of the GNU General Public License + * as published by the Free Software Foundation; either version 2 + * of the License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. + */ + +package io.druid.query.aggregation; + +/** + */ +public class IdentityMetricManipulationFn implements MetricManipulationFn +{ + @Override + public Object manipulate(AggregatorFactory factory, Object object) + { + return object; + } +} diff --git a/processing/src/main/java/io/druid/query/timeseries/TimeseriesQueryQueryToolChest.java b/processing/src/main/java/io/druid/query/timeseries/TimeseriesQueryQueryToolChest.java index 661f83d3a4f..6fe55153a59 100644 --- a/processing/src/main/java/io/druid/query/timeseries/TimeseriesQueryQueryToolChest.java +++ b/processing/src/main/java/io/druid/query/timeseries/TimeseriesQueryQueryToolChest.java @@ -130,40 +130,6 @@ public class TimeseriesQueryQueryToolChest extends QueryToolChest, Result> makePreComputeManipulatorFn( - final TimeseriesQuery query, final MetricManipulationFn fn - ) - { - return makeManipulatorFn(query, fn); - } - - private Function, Result> makeManipulatorFn( - final TimeseriesQuery query, final MetricManipulationFn fn - ) - { - return new Function, Result>() - { - @Override - public Result apply(Result result) - { - final Map values = Maps.newHashMap(); - final TimeseriesResultValue holder = result.getValue(); - for (AggregatorFactory agg : query.getAggregatorSpecs()) { - values.put(agg.getName(), fn.manipulate(agg, holder.getMetric(agg.getName()))); - } - for (PostAggregator postAgg : query.getPostAggregatorSpecs()) { - values.put(postAgg.getName(), postAgg.compute(values)); - } - - return new Result( - result.getTimestamp(), - new TimeseriesResultValue(values) - ); - } - }; - } - @Override public TypeReference> getResultTypeReference() { @@ -271,13 +237,47 @@ public class TimeseriesQueryQueryToolChest extends QueryToolChest, Result> makePreComputeManipulatorFn( + final TimeseriesQuery query, final MetricManipulationFn fn + ) + { + return makeComputeManipulatorFn(query, fn, false); + } + @Override public Function, Result> makePostComputeManipulatorFn( TimeseriesQuery query, MetricManipulationFn fn ) { - return makeManipulatorFn(query, fn); + return makeComputeManipulatorFn(query, fn, true); } + private Function, Result> makeComputeManipulatorFn( + final TimeseriesQuery query, final MetricManipulationFn fn, final boolean calculatePostAggs + ) + { + return new Function, Result>() + { + @Override + public Result apply(Result result) + { + final Map values = Maps.newHashMap(); + final TimeseriesResultValue holder = result.getValue(); + if (calculatePostAggs) { + for (PostAggregator postAgg : query.getPostAggregatorSpecs()) { + values.put(postAgg.getName(), postAgg.compute(holder.getBaseObject())); + } + } + for (AggregatorFactory agg : query.getAggregatorSpecs()) { + values.put(agg.getName(), fn.manipulate(agg, holder.getMetric(agg.getName()))); + } + return new Result( + result.getTimestamp(), + new TimeseriesResultValue(values) + ); + } + }; + } } diff --git a/processing/src/main/java/io/druid/query/topn/TopNQueryQueryToolChest.java b/processing/src/main/java/io/druid/query/topn/TopNQueryQueryToolChest.java index 376574733c8..f290fc29e8a 100644 --- a/processing/src/main/java/io/druid/query/topn/TopNQueryQueryToolChest.java +++ b/processing/src/main/java/io/druid/query/topn/TopNQueryQueryToolChest.java @@ -149,7 +149,7 @@ public class TopNQueryQueryToolChest extends QueryToolChest apply(@Nullable Result result) + public Result apply(Result result) { List> serializedValues = Lists.newArrayList( Iterables.transform( @@ -157,7 +157,7 @@ public class TopNQueryQueryToolChest extends QueryToolChest>() { @Override - public Map apply(@Nullable DimensionAndMetricValueExtractor input) + public Map apply(DimensionAndMetricValueExtractor input) { final Map values = Maps.newHashMap(); for (AggregatorFactory agg : query.getAggregatorSpecs()) { @@ -197,7 +197,7 @@ public class TopNQueryQueryToolChest extends QueryToolChest apply(@Nullable Result result) + public Result apply(Result result) { List> serializedValues = Lists.newArrayList( Iterables.transform( @@ -205,7 +205,7 @@ public class TopNQueryQueryToolChest extends QueryToolChest>() { @Override - public Map apply(@Nullable DimensionAndMetricValueExtractor input) + public Map apply(DimensionAndMetricValueExtractor input) { final Map values = Maps.newHashMap(); // compute all post aggs @@ -249,7 +249,6 @@ public class TopNQueryQueryToolChest extends QueryToolChest, Object, TopNQuery>() { private final List aggs = query.getAggregatorSpecs(); - private final List postAggs = query.getPostAggregatorSpecs(); @Override public byte[] computeCacheKey(TopNQuery query) @@ -289,7 +288,7 @@ public class TopNQueryQueryToolChest extends QueryToolChest, Object>() { @Override - public Object apply(@Nullable final Result input) + public Object apply(final Result input) { List results = Lists.newArrayList(input.getValue()); final List retVal = Lists.newArrayListWithCapacity(results.size() + 1); @@ -317,7 +316,7 @@ public class TopNQueryQueryToolChest extends QueryToolChest apply(@Nullable Object input) + public Result apply(Object input) { List results = (List) input; List> retVal = Lists.newArrayListWithCapacity(results.size()); @@ -418,7 +417,7 @@ public class TopNQueryQueryToolChest extends QueryToolChest, Result>() { @Override - public Result apply(@Nullable Result input) + public Result apply(Result input) { return new Result( input.getTimestamp(), diff --git a/server/src/main/java/io/druid/client/DirectDruidClient.java b/server/src/main/java/io/druid/client/DirectDruidClient.java index 0e21f5da793..1194acf8ce1 100644 --- a/server/src/main/java/io/druid/client/DirectDruidClient.java +++ b/server/src/main/java/io/druid/client/DirectDruidClient.java @@ -122,8 +122,7 @@ public class DirectDruidClient implements QueryRunner final JavaType typeRef; if (isBySegment) { typeRef = types.rhs; - } - else { + } else { typeRef = types.lhs; } @@ -219,14 +218,15 @@ public class DirectDruidClient implements QueryRunner retVal = Sequences.map( retVal, toolChest.makePreComputeManipulatorFn( - query, new MetricManipulationFn() - { - @Override - public Object manipulate(AggregatorFactory factory, Object object) - { - return factory.deserialize(object); - } - } + query, + new MetricManipulationFn() + { + @Override + public Object manipulate(AggregatorFactory factory, Object object) + { + return factory.deserialize(object); + } + } ) ); } @@ -313,7 +313,7 @@ public class DirectDruidClient implements QueryRunner @Override public void close() throws IOException { - if(jp != null) { + if (jp != null) { jp.close(); } } From 517d3d268222c5bc4cd999cf236ed679b49dce45 Mon Sep 17 00:00:00 2001 From: fjy Date: Fri, 18 Apr 2014 17:42:47 -0700 Subject: [PATCH 4/6] prepare for next release --- docs/content/Examples.md | 4 ++-- docs/content/Indexing-Service-Config.md | 4 ++-- docs/content/Realtime-Config.md | 4 ++-- docs/content/Tutorial:-A-First-Look-at-Druid.md | 4 ++-- docs/content/Tutorial:-The-Druid-Cluster.md | 6 +++--- docs/content/Tutorial:-Webstream.md | 4 ++-- docs/content/Twitter-Tutorial.textile | 2 +- examples/config/historical/runtime.properties | 2 +- examples/config/realtime/runtime.properties | 2 +- pom.xml | 2 +- 10 files changed, 17 insertions(+), 17 deletions(-) diff --git a/docs/content/Examples.md b/docs/content/Examples.md index 9af14b67d87..5bbc1f8ce91 100644 --- a/docs/content/Examples.md +++ b/docs/content/Examples.md @@ -19,13 +19,13 @@ Clone Druid and build it: git clone https://github.com/metamx/druid.git druid cd druid git fetch --tags -git checkout druid-0.6.93 +git checkout druid-0.6.95 ./build.sh ``` ### Downloading the DSK (Druid Standalone Kit) -[Download](http://static.druid.io/artifacts/releases/druid-services-0.6.93-bin.tar.gz) a stand-alone tarball and run it: +[Download](http://static.druid.io/artifacts/releases/druid-services-0.6.95-bin.tar.gz) a stand-alone tarball and run it: ``` bash tar -xzf druid-services-0.X.X-bin.tar.gz diff --git a/docs/content/Indexing-Service-Config.md b/docs/content/Indexing-Service-Config.md index 89d73a2eabb..52e604b2405 100644 --- a/docs/content/Indexing-Service-Config.md +++ b/docs/content/Indexing-Service-Config.md @@ -66,7 +66,7 @@ druid.host=#{IP_ADDR}:8080 druid.port=8080 druid.service=druid/prod/indexer -druid.extensions.coordinates=["io.druid.extensions:druid-s3-extensions:0.6.93"] +druid.extensions.coordinates=["io.druid.extensions:druid-s3-extensions:0.6.95"] druid.zk.service.host=#{ZK_IPs} druid.zk.paths.base=/druid/prod @@ -115,7 +115,7 @@ druid.host=#{IP_ADDR}:8080 druid.port=8080 druid.service=druid/prod/worker -druid.extensions.coordinates=["io.druid.extensions:druid-s3-extensions:0.6.93","io.druid.extensions:druid-kafka-seven:0.6.93"] +druid.extensions.coordinates=["io.druid.extensions:druid-s3-extensions:0.6.95","io.druid.extensions:druid-kafka-seven:0.6.95"] druid.zk.service.host=#{ZK_IPs} druid.zk.paths.base=/druid/prod diff --git a/docs/content/Realtime-Config.md b/docs/content/Realtime-Config.md index 6ef260beea4..55d322f6d00 100644 --- a/docs/content/Realtime-Config.md +++ b/docs/content/Realtime-Config.md @@ -27,7 +27,7 @@ druid.host=localhost druid.service=realtime druid.port=8083 -druid.extensions.coordinates=["io.druid.extensions:druid-kafka-seven:0.6.93"] +druid.extensions.coordinates=["io.druid.extensions:druid-kafka-seven:0.6.95"] druid.zk.service.host=localhost @@ -76,7 +76,7 @@ druid.host=#{IP_ADDR}:8080 druid.port=8080 druid.service=druid/prod/realtime -druid.extensions.coordinates=["io.druid.extensions:druid-s3-extensions:0.6.93","io.druid.extensions:druid-kafka-seven:0.6.93"] +druid.extensions.coordinates=["io.druid.extensions:druid-s3-extensions:0.6.95","io.druid.extensions:druid-kafka-seven:0.6.95"] druid.zk.service.host=#{ZK_IPs} druid.zk.paths.base=/druid/prod diff --git a/docs/content/Tutorial:-A-First-Look-at-Druid.md b/docs/content/Tutorial:-A-First-Look-at-Druid.md index 23b19988bb9..a7458fd78cb 100644 --- a/docs/content/Tutorial:-A-First-Look-at-Druid.md +++ b/docs/content/Tutorial:-A-First-Look-at-Druid.md @@ -49,7 +49,7 @@ There are two ways to setup Druid: download a tarball, or [Build From Source](Bu ### Download a Tarball -We've built a tarball that contains everything you'll need. You'll find it [here](http://static.druid.io/artifacts/releases/druid-services-0.6.93-bin.tar.gz). Download this file to a directory of your choosing. +We've built a tarball that contains everything you'll need. You'll find it [here](http://static.druid.io/artifacts/releases/druid-services-0.6.95-bin.tar.gz). Download this file to a directory of your choosing. You can extract the awesomeness within by issuing: @@ -60,7 +60,7 @@ tar -zxvf druid-services-*-bin.tar.gz Not too lost so far right? That's great! If you cd into the directory: ``` -cd druid-services-0.6.93 +cd druid-services-0.6.95 ``` You should see a bunch of files: diff --git a/docs/content/Tutorial:-The-Druid-Cluster.md b/docs/content/Tutorial:-The-Druid-Cluster.md index 92c056b2a5c..8840013d835 100644 --- a/docs/content/Tutorial:-The-Druid-Cluster.md +++ b/docs/content/Tutorial:-The-Druid-Cluster.md @@ -13,7 +13,7 @@ In this tutorial, we will set up other types of Druid nodes and external depende If you followed the first tutorial, you should already have Druid downloaded. If not, let's go back and do that first. -You can download the latest version of druid [here](http://static.druid.io/artifacts/releases/druid-services-0.6.93-bin.tar.gz) +You can download the latest version of druid [here](http://static.druid.io/artifacts/releases/druid-services-0.6.95-bin.tar.gz) and untar the contents within by issuing: @@ -149,7 +149,7 @@ druid.port=8081 druid.zk.service.host=localhost -druid.extensions.coordinates=["io.druid.extensions:druid-s3-extensions:0.6.93"] +druid.extensions.coordinates=["io.druid.extensions:druid-s3-extensions:0.6.95"] # Dummy read only AWS account (used to download example data) druid.s3.secretKey=QyyfVZ7llSiRg6Qcrql1eEUG7buFpAK6T6engr1b @@ -240,7 +240,7 @@ druid.port=8083 druid.zk.service.host=localhost -druid.extensions.coordinates=["io.druid.extensions:druid-examples:0.6.93","io.druid.extensions:druid-kafka-seven:0.6.93"] +druid.extensions.coordinates=["io.druid.extensions:druid-examples:0.6.95","io.druid.extensions:druid-kafka-seven:0.6.95"] # Change this config to db to hand off to the rest of the Druid cluster druid.publish.type=noop diff --git a/docs/content/Tutorial:-Webstream.md b/docs/content/Tutorial:-Webstream.md index 001257fb83a..1ce49277b9c 100644 --- a/docs/content/Tutorial:-Webstream.md +++ b/docs/content/Tutorial:-Webstream.md @@ -37,7 +37,7 @@ There are two ways to setup Druid: download a tarball, or [Build From Source](Bu h3. Download a Tarball -We've built a tarball that contains everything you'll need. You'll find it [here](http://static.druid.io/artifacts/releases/druid-services-0.6.93-bin.tar.gz) +We've built a tarball that contains everything you'll need. You'll find it [here](http://static.druid.io/artifacts/releases/druid-services-0.6.95-bin.tar.gz) Download this file to a directory of your choosing. You can extract the awesomeness within by issuing: @@ -48,7 +48,7 @@ tar zxvf druid-services-*-bin.tar.gz Not too lost so far right? That's great! If you cd into the directory: ``` -cd druid-services-0.6.93 +cd druid-services-0.6.95 ``` You should see a bunch of files: diff --git a/docs/content/Twitter-Tutorial.textile b/docs/content/Twitter-Tutorial.textile index 0201a30dd85..0497aa7b939 100644 --- a/docs/content/Twitter-Tutorial.textile +++ b/docs/content/Twitter-Tutorial.textile @@ -9,7 +9,7 @@ There are two ways to setup Druid: download a tarball, or build it from source. h3. Download a Tarball -We've built a tarball that contains everything you'll need. You'll find it "here":http://static.druid.io/artifacts/releases/druid-services-0.6.93-bin.tar.gz. +We've built a tarball that contains everything you'll need. You'll find it "here":http://static.druid.io/artifacts/releases/druid-services-0.6.95-bin.tar.gz. Download this bad boy to a directory of your choosing. You can extract the awesomeness within by issuing: diff --git a/examples/config/historical/runtime.properties b/examples/config/historical/runtime.properties index b0ea69bb5cd..e7e69c2a114 100644 --- a/examples/config/historical/runtime.properties +++ b/examples/config/historical/runtime.properties @@ -4,7 +4,7 @@ druid.port=8081 druid.zk.service.host=localhost -druid.extensions.coordinates=["io.druid.extensions:druid-s3-extensions:0.6.93"] +druid.extensions.coordinates=["io.druid.extensions:druid-s3-extensions:0.6.95"] # Dummy read only AWS account (used to download example data) druid.s3.secretKey=QyyfVZ7llSiRg6Qcrql1eEUG7buFpAK6T6engr1b diff --git a/examples/config/realtime/runtime.properties b/examples/config/realtime/runtime.properties index 00f2a644ddc..f0419626af0 100644 --- a/examples/config/realtime/runtime.properties +++ b/examples/config/realtime/runtime.properties @@ -4,7 +4,7 @@ druid.port=8083 druid.zk.service.host=localhost -druid.extensions.coordinates=["io.druid.extensions:druid-examples:0.6.93","io.druid.extensions:druid-kafka-seven:0.6.93","io.druid.extensions:druid-rabbitmq:0.6.93"] +druid.extensions.coordinates=["io.druid.extensions:druid-examples:0.6.95","io.druid.extensions:druid-kafka-seven:0.6.95","io.druid.extensions:druid-rabbitmq:0.6.95"] # Change this config to db to hand off to the rest of the Druid cluster druid.publish.type=noop diff --git a/pom.xml b/pom.xml index 49d3ccf8475..15ff9246e69 100644 --- a/pom.xml +++ b/pom.xml @@ -30,7 +30,7 @@ scm:git:ssh://git@github.com/metamx/druid.git scm:git:ssh://git@github.com/metamx/druid.git http://www.github.com/metamx/druid - druid-0.6.93-SNAPSHOT + druid-0.6.95-SNAPSHOT From 2d3eebe9956a67c28e00a4170fb575f4d6394f6e Mon Sep 17 00:00:00 2001 From: fjy Date: Fri, 18 Apr 2014 17:44:32 -0700 Subject: [PATCH 5/6] [maven-release-plugin] prepare release druid-0.6.95 --- cassandra-storage/pom.xml | 2 +- common/pom.xml | 2 +- examples/pom.xml | 2 +- hdfs-storage/pom.xml | 2 +- hll/pom.xml | 2 +- indexing-hadoop/pom.xml | 2 +- indexing-service/pom.xml | 2 +- kafka-eight/pom.xml | 2 +- kafka-seven/pom.xml | 2 +- pom.xml | 4 ++-- processing/pom.xml | 2 +- rabbitmq/pom.xml | 2 +- s3-extensions/pom.xml | 2 +- server/pom.xml | 2 +- services/pom.xml | 2 +- 15 files changed, 16 insertions(+), 16 deletions(-) diff --git a/cassandra-storage/pom.xml b/cassandra-storage/pom.xml index 8806f981e3a..2b149e22877 100644 --- a/cassandra-storage/pom.xml +++ b/cassandra-storage/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95-SNAPSHOT + 0.6.95 diff --git a/common/pom.xml b/common/pom.xml index 782c040dcd4..5b55086d7ea 100644 --- a/common/pom.xml +++ b/common/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95-SNAPSHOT + 0.6.95 diff --git a/examples/pom.xml b/examples/pom.xml index dae70f132f7..544b15d49a6 100644 --- a/examples/pom.xml +++ b/examples/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95-SNAPSHOT + 0.6.95 diff --git a/hdfs-storage/pom.xml b/hdfs-storage/pom.xml index 42dec8c2186..d7055c5ce2a 100644 --- a/hdfs-storage/pom.xml +++ b/hdfs-storage/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95-SNAPSHOT + 0.6.95 diff --git a/hll/pom.xml b/hll/pom.xml index 28e9f3cf154..b010a42ed99 100644 --- a/hll/pom.xml +++ b/hll/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95-SNAPSHOT + 0.6.95 diff --git a/indexing-hadoop/pom.xml b/indexing-hadoop/pom.xml index 02885b1de00..991cd43079b 100644 --- a/indexing-hadoop/pom.xml +++ b/indexing-hadoop/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95-SNAPSHOT + 0.6.95 diff --git a/indexing-service/pom.xml b/indexing-service/pom.xml index 9529b65bf45..a674bf9e8f6 100644 --- a/indexing-service/pom.xml +++ b/indexing-service/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95-SNAPSHOT + 0.6.95 diff --git a/kafka-eight/pom.xml b/kafka-eight/pom.xml index 84c835bc8cf..9bb28807753 100644 --- a/kafka-eight/pom.xml +++ b/kafka-eight/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95-SNAPSHOT + 0.6.95 diff --git a/kafka-seven/pom.xml b/kafka-seven/pom.xml index f1647297495..786f799adf4 100644 --- a/kafka-seven/pom.xml +++ b/kafka-seven/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95-SNAPSHOT + 0.6.95 diff --git a/pom.xml b/pom.xml index 15ff9246e69..c079d6e2928 100644 --- a/pom.xml +++ b/pom.xml @@ -23,14 +23,14 @@ io.druid druid pom - 0.6.95-SNAPSHOT + 0.6.95 druid druid scm:git:ssh://git@github.com/metamx/druid.git scm:git:ssh://git@github.com/metamx/druid.git http://www.github.com/metamx/druid - druid-0.6.95-SNAPSHOT + druid-0.6.95 diff --git a/processing/pom.xml b/processing/pom.xml index b1a9bcf306c..277d06bbe81 100644 --- a/processing/pom.xml +++ b/processing/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95-SNAPSHOT + 0.6.95 diff --git a/rabbitmq/pom.xml b/rabbitmq/pom.xml index 49d47fe9474..f0666294429 100644 --- a/rabbitmq/pom.xml +++ b/rabbitmq/pom.xml @@ -9,7 +9,7 @@ io.druid druid - 0.6.95-SNAPSHOT + 0.6.95 diff --git a/s3-extensions/pom.xml b/s3-extensions/pom.xml index db3c60ed547..fa735bc2649 100644 --- a/s3-extensions/pom.xml +++ b/s3-extensions/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95-SNAPSHOT + 0.6.95 diff --git a/server/pom.xml b/server/pom.xml index 33fbf4d375d..76e3aa5ad33 100644 --- a/server/pom.xml +++ b/server/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95-SNAPSHOT + 0.6.95 diff --git a/services/pom.xml b/services/pom.xml index 4ad7d412ad1..1cf7510d06c 100644 --- a/services/pom.xml +++ b/services/pom.xml @@ -27,7 +27,7 @@ io.druid druid - 0.6.95-SNAPSHOT + 0.6.95 From 65db875d689b8ff4654977eef081645eccc78d73 Mon Sep 17 00:00:00 2001 From: fjy Date: Fri, 18 Apr 2014 17:44:36 -0700 Subject: [PATCH 6/6] [maven-release-plugin] prepare for next development iteration --- cassandra-storage/pom.xml | 2 +- common/pom.xml | 2 +- examples/pom.xml | 2 +- hdfs-storage/pom.xml | 2 +- hll/pom.xml | 2 +- indexing-hadoop/pom.xml | 2 +- indexing-service/pom.xml | 2 +- kafka-eight/pom.xml | 2 +- kafka-seven/pom.xml | 2 +- pom.xml | 4 ++-- processing/pom.xml | 2 +- rabbitmq/pom.xml | 2 +- s3-extensions/pom.xml | 2 +- server/pom.xml | 2 +- services/pom.xml | 2 +- 15 files changed, 16 insertions(+), 16 deletions(-) diff --git a/cassandra-storage/pom.xml b/cassandra-storage/pom.xml index 2b149e22877..c8dd1b0f255 100644 --- a/cassandra-storage/pom.xml +++ b/cassandra-storage/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95 + 0.6.96-SNAPSHOT diff --git a/common/pom.xml b/common/pom.xml index 5b55086d7ea..a5313b69991 100644 --- a/common/pom.xml +++ b/common/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95 + 0.6.96-SNAPSHOT diff --git a/examples/pom.xml b/examples/pom.xml index 544b15d49a6..bd81db6600a 100644 --- a/examples/pom.xml +++ b/examples/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95 + 0.6.96-SNAPSHOT diff --git a/hdfs-storage/pom.xml b/hdfs-storage/pom.xml index d7055c5ce2a..294cde4f49c 100644 --- a/hdfs-storage/pom.xml +++ b/hdfs-storage/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95 + 0.6.96-SNAPSHOT diff --git a/hll/pom.xml b/hll/pom.xml index b010a42ed99..e1bbfdafd0c 100644 --- a/hll/pom.xml +++ b/hll/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95 + 0.6.96-SNAPSHOT diff --git a/indexing-hadoop/pom.xml b/indexing-hadoop/pom.xml index 991cd43079b..73172974fe8 100644 --- a/indexing-hadoop/pom.xml +++ b/indexing-hadoop/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95 + 0.6.96-SNAPSHOT diff --git a/indexing-service/pom.xml b/indexing-service/pom.xml index a674bf9e8f6..04eeb330c6c 100644 --- a/indexing-service/pom.xml +++ b/indexing-service/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95 + 0.6.96-SNAPSHOT diff --git a/kafka-eight/pom.xml b/kafka-eight/pom.xml index 9bb28807753..bc6f7e1c532 100644 --- a/kafka-eight/pom.xml +++ b/kafka-eight/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95 + 0.6.96-SNAPSHOT diff --git a/kafka-seven/pom.xml b/kafka-seven/pom.xml index 786f799adf4..4a0f4898efc 100644 --- a/kafka-seven/pom.xml +++ b/kafka-seven/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95 + 0.6.96-SNAPSHOT diff --git a/pom.xml b/pom.xml index c079d6e2928..68dc04dd269 100644 --- a/pom.xml +++ b/pom.xml @@ -23,14 +23,14 @@ io.druid druid pom - 0.6.95 + 0.6.96-SNAPSHOT druid druid scm:git:ssh://git@github.com/metamx/druid.git scm:git:ssh://git@github.com/metamx/druid.git http://www.github.com/metamx/druid - druid-0.6.95 + druid-0.6.95-SNAPSHOT diff --git a/processing/pom.xml b/processing/pom.xml index 277d06bbe81..f7559ea68de 100644 --- a/processing/pom.xml +++ b/processing/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95 + 0.6.96-SNAPSHOT diff --git a/rabbitmq/pom.xml b/rabbitmq/pom.xml index f0666294429..b6d2fd6cf7f 100644 --- a/rabbitmq/pom.xml +++ b/rabbitmq/pom.xml @@ -9,7 +9,7 @@ io.druid druid - 0.6.95 + 0.6.96-SNAPSHOT diff --git a/s3-extensions/pom.xml b/s3-extensions/pom.xml index fa735bc2649..7ac7486678b 100644 --- a/s3-extensions/pom.xml +++ b/s3-extensions/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95 + 0.6.96-SNAPSHOT diff --git a/server/pom.xml b/server/pom.xml index 76e3aa5ad33..269595eae58 100644 --- a/server/pom.xml +++ b/server/pom.xml @@ -28,7 +28,7 @@ io.druid druid - 0.6.95 + 0.6.96-SNAPSHOT diff --git a/services/pom.xml b/services/pom.xml index 1cf7510d06c..e7efb10fa6b 100644 --- a/services/pom.xml +++ b/services/pom.xml @@ -27,7 +27,7 @@ io.druid druid - 0.6.95 + 0.6.96-SNAPSHOT