You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by hs...@apache.org on 2016/07/07 17:01:41 UTC
[3/5] apex-malhar git commit: Merge branch 'master' of
github.com:apache/incubator-apex-malhar
Merge branch 'master' of github.com:apache/incubator-apex-malhar
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/09465e43
Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/09465e43
Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/09465e43
Branch: refs/heads/master
Commit: 09465e43cffc149d434d4e35a1e2d72dbc8e89ed
Parents: c887d88 c4a1129
Author: Siyuan Hua <hs...@apache.org>
Authored: Wed Jul 6 15:40:09 2016 -0700
Committer: Siyuan Hua <hs...@apache.org>
Committed: Wed Jul 6 15:40:09 2016 -0700
----------------------------------------------------------------------
.../cassandra/CassandraOutputOperator.java | 4 +-
...tCassandraTransactionableOutputOperator.java | 35 +-
...assandraTransactionableOutputOperatorPS.java | 84 -----
.../cassandra/CassandraPOJOOutputOperator.java | 150 ++++++--
.../cassandra/CassandraOperatorTest.java | 134 +++++--
library/pom.xml | 7 +-
.../bandwidth/BandwidthLimitingOperator.java | 29 ++
.../lib/bandwidth/BandwidthManager.java | 131 +++++++
.../lib/bandwidth/BandwidthPartitioner.java | 78 ++++
.../db/jdbc/AbstractJdbcPOJOOutputOperator.java | 286 +++++++++++++++
...stractJdbcTransactionableOutputOperator.java | 90 ++++-
.../datatorrent/lib/db/jdbc/JdbcFieldInfo.java | 58 +++
.../db/jdbc/JdbcPOJOInsertOutputOperator.java | 183 ++++++++++
.../jdbc/JdbcPOJONonInsertOutputOperator.java | 76 ++++
.../lib/db/jdbc/JdbcPOJOOutputOperator.java | 352 -------------------
.../lib/io/fs/FileSplitterInput.java | 31 +-
.../lib/bandwidth/BandwidthManagerTest.java | 268 ++++++++++++++
.../lib/bandwidth/BandwidthPartitionerTest.java | 106 ++++++
.../com/datatorrent/lib/db/jdbc/JdbcIOApp.java | 15 +-
.../lib/db/jdbc/JdbcOperatorTest.java | 286 ++++++++++++++-
.../lib/io/fs/FileSplitterInputTest.java | 10 +-
21 files changed, 1881 insertions(+), 532 deletions(-)
----------------------------------------------------------------------