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 <[email protected]> Authored: Wed Jul 6 15:40:09 2016 -0700 Committer: Siyuan Hua <[email protected]> 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(-) ----------------------------------------------------------------------
