apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From csi...@apache.org
Subject [2/3] incubator-apex-malhar git commit: Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/incubator-apex-malhar into APEXMALHAR-2065
Date Tue, 17 May 2016 18:55:15 GMT
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/incubator-apex-malhar into
APEXMALHAR-2065


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/543fc07e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/543fc07e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/543fc07e

Branch: refs/heads/master
Commit: 543fc07e9dae3c32fe08cf86541b9b67c9412628
Parents: 2a6e1a6 1d3e20c
Author: Chandni Singh <csingh@apache.org>
Authored: Tue May 17 11:44:06 2016 -0700
Committer: Chandni Singh <csingh@apache.org>
Committed: Tue May 17 11:44:06 2016 -0700

----------------------------------------------------------------------
 DISCLAIMER                                      |  11 -
 NOTICE                                          |   2 +-
 README.md                                       |  10 +-
 apps/filecopy/pom.xml                           |   6 +-
 .../datatorrent/apps/copy/HDFSFileCopyApp.java  |   4 +-
 apps/logstream/pom.xml                          |   4 +-
 apps/pom.xml                                    |   4 +-
 benchmark/pom.xml                               |   4 +-
 .../com/datatorrent/benchmark/package-info.java |  44 +-
 contrib/pom.xml                                 |   4 +-
 .../contrib/enrich/AbstractEnricher.java        | 321 +++++++++
 .../contrib/enrich/BackendLoader.java           |  42 ++
 .../datatorrent/contrib/enrich/FSLoader.java    | 184 +++++
 .../datatorrent/contrib/enrich/JDBCLoader.java  | 201 ++++++
 .../datatorrent/contrib/enrich/MapEnricher.java | 138 ++++
 .../contrib/enrich/NullValuesCacheManager.java  |  60 ++
 .../contrib/enrich/POJOEnricher.java            | 287 ++++++++
 .../contrib/enrich/ReadOnlyBackup.java          |  61 ++
 .../datatorrent/contrib/hbase/package-info.java |  46 +-
 .../datatorrent/contrib/kafka/package-info.java |  44 +-
 .../contrib/memcache/package-info.java          |  46 +-
 .../contrib/memcache_whalin/package-info.java   |  46 +-
 .../contrib/mongodb/package-info.java           |  46 +-
 .../contrib/rabbitmq/package-info.java          |  46 +-
 .../contrib/romesyndication/package-info.java   |  46 +-
 .../contrib/sqlite/package-info.java            |  46 +-
 .../datatorrent/contrib/zmq/package-info.java   |  46 +-
 .../contrib/enrich/EmployeeOrder.java           | 114 +++
 .../contrib/enrich/FileEnrichmentTest.java      | 103 +++
 .../contrib/enrich/JDBCLoaderTest.java          | 209 ++++++
 .../contrib/enrich/MapEnricherTest.java         | 251 +++++++
 .../com/datatorrent/contrib/enrich/Order.java   |  71 ++
 .../contrib/enrich/POJOEnricherTest.java        | 232 +++++++
 .../HBaseTransactionalPutOperatorTest.java      |  18 +
 .../datatorrent_feed_updated.rss                | 688 +++++++++----------
 contrib/src/test/resources/productmapping.txt   | 100 +++
 demos/distributedistinct/pom.xml                |   4 +-
 demos/echoserver/pom.xml                        |   4 +-
 demos/frauddetect/pom.xml                       |   4 +-
 demos/iteration/pom.xml                         |   4 +-
 .../demos/iteration/package-info.java           |  38 +-
 demos/machinedata/pom.xml                       |   4 +-
 demos/mobile/pom.xml                            |   4 +-
 .../datatorrent/demos/mobile/package-info.java  |  38 +-
 demos/mrmonitor/pom.xml                         |   4 +-
 demos/mroperator/pom.xml                        |   4 +-
 demos/pi/pom.xml                                |   4 +-
 .../com/datatorrent/demos/pi/package-info.java  |  38 +-
 demos/pom.xml                                   |   6 +-
 demos/r/pom.xml                                 |   4 +-
 demos/twitter/pom.xml                           |   4 +-
 .../datatorrent/demos/twitter/package-info.java |  38 +-
 demos/uniquecount/pom.xml                       |   4 +-
 demos/wordcount/pom.xml                         |   4 +-
 .../demos/wordcount/package-info.java           |  38 +-
 demos/yahoofinance/pom.xml                      |   4 +-
 .../demos/yahoofinance/package-info.java        |  38 +-
 docs/README.md                                  |   2 +-
 docs/operators/block_reader.md                  |   2 +-
 docs/operators/file_output.md                   |   2 +-
 kafka/pom.xml                                   |   4 +-
 library/pom.xml                                 |  14 +-
 .../com/datatorrent/lib/db/jdbc/JdbcStore.java  |   2 +
 .../lib/io/PubSubWebSocketInputOperator.java    |   3 +-
 .../lib/io/PubSubWebSocketOutputOperator.java   |   3 +-
 .../lib/io/WebSocketInputOperator.java          |  16 +-
 .../lib/io/WebSocketOutputOperator.java         |  38 +-
 .../lib/io/WidgetOutputOperator.java            |  71 +-
 .../lib/io/block/AbstractBlockReader.java       |   6 +
 .../lib/io/block/AbstractFSBlockReader.java     |  26 +-
 .../datatorrent/lib/io/block/BlockMetadata.java |  28 -
 .../datatorrent/lib/io/block/BlockReader.java   |  66 --
 .../lib/io/fs/AbstractFileOutputOperator.java   |  15 +-
 .../io/fs/AbstractSingleFileOutputOperator.java |  65 +-
 .../datatorrent/lib/io/fs/FSInputModule.java    | 262 +++++++
 .../lib/io/fs/FileSplitterInput.java            |  39 +-
 .../datatorrent/lib/io/fs/HDFSFileSplitter.java | 120 ----
 .../datatorrent/lib/io/fs/HDFSInputModule.java  | 244 -------
 .../lib/transform/TransformOperator.java        |  85 +--
 .../com/datatorrent/lib/util/FieldInfo.java     |  15 +-
 .../com/datatorrent/lib/util/package-info.java  |  46 +-
 .../malhar/lib/fs/BytesFileOutputOperator.java  | 295 ++++++++
 .../apex/malhar/lib/spillable/Spillable.java    | 100 ---
 .../spillable/SpillableComplexComponent.java    | 126 ----
 .../apex/malhar/lib/spillable/package-info.java |  20 -
 .../malhar/lib/state/spillable/Spillable.java   | 100 +++
 .../spillable/SpillableComplexComponent.java    | 126 ++++
 .../lib/state/spillable/package-info.java       |  20 +
 .../org/apache/apex/malhar/lib/utils/Serde.java |  61 --
 .../lib/utils/serde/PassThruByteArraySerde.java |  47 ++
 .../apex/malhar/lib/utils/serde/Serde.java      |  61 ++
 .../malhar/lib/utils/serde/package-info.java    |  20 +
 .../lib/helper/OperatorContextTestHelper.java   |   5 +
 .../AbstractSingleFileOutputOperatorTest.java   |   4 +-
 .../lib/io/fs/FSInputModuleAppTest.java         | 221 ++++++
 .../lib/io/fs/FileSplitterInputTest.java        |   1 -
 .../lib/io/fs/HDFSInputModuleAppTest.java       | 221 ------
 .../lib/fs/BytesFileOutputOperatorTest.java     | 151 ++++
 .../utils/serde/PassThruByteArraySerdeTest.java |  72 ++
 pom.xml                                         |  12 +-
 samples/pom.xml                                 |   4 +-
 101 files changed, 4788 insertions(+), 1928 deletions(-)
----------------------------------------------------------------------



Mime
View raw message