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 <[email protected]> Authored: Wed Sep 9 15:30:01 2015 -0700 Committer: Chetan Narsude <[email protected]> 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(-) ----------------------------------------------------------------------
