You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ch...@apache.org on 2015/09/10 00:32:38 UTC
[50/50] [abbrv] incubator-apex-malhar git commit: Bring to parity
with v3.1.0.
Bring to parity with v3.1.0.
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/0690700b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/0690700b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/0690700b
Branch: refs/heads/master
Commit: 0690700b3d52f539882b01b2350c7b6e8834b3ca
Parents: ff31e3c b812652
Author: Chetan Narsude <ch...@datatorrent.com>
Authored: Wed Sep 9 15:30:01 2015 -0700
Committer: Chetan Narsude <ch...@datatorrent.com>
Committed: Wed Sep 9 15:30:01 2015 -0700
----------------------------------------------------------------------
apps/logstream/pom.xml | 5 +-
apps/pom.xml | 4 +-
benchmark/pom.xml | 6 +-
.../UniqueValueCountBenchmarkApplication.java | 9 +-
.../RubyOperatorBenchmarkApplication.java | 2 +-
.../memsql/MemsqlInputBenchmarkTest.java | 2 +-
.../benchmark/memsql/MemsqlOutputBenchmark.java | 6 +-
contrib/pom.xml | 10 +-
.../contrib/hbase/HBaseFieldInfo.java | 4 +
.../contrib/hbase/HBasePOJOInputOperator.java | 1 +
.../rabbitmq/AbstractRabbitMQInputOperator.java | 142 +++++++++++-
.../AbstractRabbitMQOutputOperator.java | 65 +++++-
...bstractSinglePortRabbitMQOutputOperator.java | 5 +-
.../redis/AbstractRedisInputOperator.java | 226 +++++++++++++++++-
.../redis/RedisKeyValueInputOperator.java | 66 ++++++
.../redis/RedisMapAsValueInputOperator.java | 54 +++++
.../contrib/redis/RedisPOJOInputOperator.java | 211 +++++++++++++++++
.../contrib/redis/RedisPOJOOutputOperator.java | 156 +++++++++++++
.../datatorrent/contrib/redis/RedisStore.java | 27 +++
.../contrib/twitter/TwitterSampleInput.java | 32 +++
.../rabbitmq/RabbitMQInputOperatorTest.java | 86 +++++--
.../rabbitmq/RabbitMQOutputOperatorTest.java | 28 +--
.../contrib/redis/RedisInputOperatorTest.java | 193 ++++++++++++++++
.../contrib/redis/RedisPOJOOperatorTest.java | 230 +++++++++++++++++++
demos/distributedistinct/pom.xml | 4 +-
demos/echoserver/pom.xml | 4 +-
demos/frauddetect/pom.xml | 4 +-
demos/machinedata/pom.xml | 6 +-
demos/mobile/pom.xml | 4 +-
.../demos/mobile/ApplicationTest.java | 2 -
demos/mrmonitor/pom.xml | 4 +-
demos/mroperator/pom.xml | 4 +-
demos/pi/pom.xml | 4 +-
demos/pom.xml | 9 +-
demos/r/pom.xml | 4 +-
demos/twitter/pom.xml | 6 +-
.../demos/twitter/WindowedTopCounter.java | 5 +
demos/uniquecount/pom.xml | 4 +-
demos/wordcount/pom.xml | 4 +-
demos/yahoofinance/pom.xml | 4 +-
library/pom.xml | 2 +-
.../lib/appdata/gpo/SerdeFieldsDescriptor.java | 4 +
.../lib/appdata/gpo/SerdeListGPOMutable.java | 4 +
.../lib/appdata/gpo/SerdeListPrimitive.java | 4 +
.../lib/appdata/gpo/SerdeListString.java | 4 +
.../lib/appdata/gpo/SerdeObjectPayloadFix.java | 4 +
.../appdata/query/QueryManagerAsynchronous.java | 4 +
.../query/serde/SchemaQueryDeserializer.java | 5 +
.../lib/io/PubSubWebSocketAppDataQuery.java | 48 +++-
.../lib/io/PubSubWebSocketAppDataResult.java | 27 ++-
.../lib/io/SimpleSinglePortInputOperator.java | 3 +-
.../lib/io/WebSocketInputOperator.java | 5 +-
.../lib/io/WebSocketOutputOperator.java | 7 +-
.../datatorrent/lib/metric/AvgAggregator.java | 4 +
.../lib/metric/max/DoubleMaxAggregator.java | 4 +
.../lib/metric/max/FloatMaxAggregator.java | 4 +
.../lib/metric/max/IntMaxAggregator.java | 4 +
.../lib/metric/max/LongMaxAggregator.java | 4 +
.../lib/metric/min/DoubleMinAggregator.java | 4 +
.../lib/metric/min/FloatMinAggregator.java | 4 +
.../lib/metric/min/IntMinAggregator.java | 4 +
.../lib/metric/min/LongMinAggregator.java | 4 +
.../lib/multiwindow/SortedMovingWindow.java | 3 +-
.../com/datatorrent/lib/util/FieldInfo.java | 1 +
.../lib/io/HttpJsonChunksInputOperatorTest.java | 1 -
.../lib/io/HttpLinesInputOperatorTest.java | 1 -
.../io/PubSubWebSocketAppDataOperatorTest.java | 74 ++++++
.../lib/io/PubSubWebSocketAppDataQueryTest.java | 66 +++++-
.../io/PubSubWebSocketAppDataResultTest.java | 20 +-
.../lib/io/PubSubWebSocketOperatorTest.java | 2 -
pom.xml | 60 ++++-
samples/pom.xml | 2 +-
72 files changed, 1881 insertions(+), 148 deletions(-)
----------------------------------------------------------------------