apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hsy...@apache.org
Subject [3/5] apex-malhar git commit: Merge branch 'master' of github.com:apache/incubator-apex-malhar
Date Thu, 07 Jul 2016 17:01:41 GMT
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 <hsy541@apache.org>
Authored: Wed Jul 6 15:40:09 2016 -0700
Committer: Siyuan Hua <hsy541@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(-)
----------------------------------------------------------------------



Mime
View raw message