apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [3/3] apex-malhar git commit: Merge commit 'refs/pull/539/head' of https://github.com/apache/apex-malhar
Date Sun, 22 Jan 2017 19:24:07 GMT
Merge commit 'refs/pull/539/head' of https://github.com/apache/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/e22ea0de
Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/e22ea0de
Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/e22ea0de

Branch: refs/heads/master
Commit: e22ea0de192967e2006071dd191cb25d4173cf31
Parents: 623b803 5528a4c
Author: Thomas Weise <thw@apache.org>
Authored: Sun Jan 22 11:22:32 2017 -0800
Committer: Thomas Weise <thw@apache.org>
Committed: Sun Jan 22 11:22:32 2017 -0800

----------------------------------------------------------------------
 benchmark/pom.xml                               |  8 ----
 .../datatorrent/benchmark/ApplicationFixed.java | 15 +++---
 .../com/datatorrent/benchmark/Benchmark.java    | 17 +++----
 .../benchmark/CouchBaseAppInput.java            |  6 +--
 .../benchmark/CouchBaseAppOutput.java           |  8 ++--
 .../benchmark/CouchBaseInputOperator.java       | 17 ++++---
 .../benchmark/FixedTuplesInputOperator.java     | 11 +++--
 .../datatorrent/benchmark/RandomMapOutput.java  | 40 +++++++++-------
 .../benchmark/RandomWordInputModule.java        | 11 +++--
 .../benchmark/WordCountOperator.java            | 10 ++--
 .../AerospikeOutputBenchmarkApplication.java    | 17 ++++---
 .../aerospike/AerospikeOutputOperator.java      | 13 ++++--
 .../UniqueValueCountBenchmarkApplication.java   | 21 +++++----
 .../CassandraOutputBenchmarkApplication.java    | 17 ++++---
 .../cassandra/CassandraOutputOperator.java      | 14 +++---
 .../benchmark/fs/FSByteOutputOperator.java      |  9 ++--
 .../benchmark/fs/FSOutputOperatorBenchmark.java | 26 +++++++----
 .../hive/HiveInsertBenchmarkingApp.java         | 28 ++++++-----
 .../hive/HiveMapInsertBenchmarkingApp.java      | 31 +++++++------
 .../kafka/BenchmarkKafkaInputOperator.java      |  6 +--
 ...nchmarkPartitionableKafkaOutputOperator.java | 44 +++++++++---------
 .../benchmark/kafka/KafkaInputBenchmark.java    | 23 ++++-----
 .../benchmark/kafka/KafkaOutputBenchmark.java   |  5 +-
 .../benchmark/kafka/KafkaTestPartitioner.java   |  7 +--
 .../RubyOperatorBenchmarkApplication.java       | 11 +++--
 .../spillable/SpillableTestOperator.java        |  3 +-
 .../state/ManagedStateBenchmarkApp.java         |  3 +-
 .../benchmark/state/StoreOperator.java          |  9 ++--
 .../stream/DevNullCounterBenchmark.java         | 13 +++---
 .../benchmark/stream/IntegerOperator.java       | 17 ++++---
 .../benchmark/stream/StreamDuplicaterApp.java   | 21 +++++----
 .../benchmark/stream/StreamMergeApp.java        |  5 +-
 .../benchmark/testbench/EventClassifierApp.java | 11 +++--
 .../EventClassifierNumberToHashDoubleApp.java   | 18 ++++---
 .../benchmark/testbench/EventGeneratorApp.java  |  9 ++--
 .../testbench/EventIncrementerApp.java          | 22 +++++----
 .../testbench/FilterClassifierApp.java          | 15 +++---
 .../testbench/FilteredEventClassifierApp.java   |  8 ++--
 .../benchmark/testbench/HashMapOperator.java    | 37 +++++++++------
 .../testbench/RandomEventGeneratorApp.java      |  8 ++--
 .../testbench/SeedEventGeneratorApp.java        | 14 ++++--
 .../testbench/ThroughputCounterApp.java         | 13 ++++--
 .../AbstractWindowedOperatorBenchmarkApp.java   | 10 ++--
 .../KeyedWindowedOperatorBenchmarkApp.java      |  9 ++--
 .../window/WindowedOperatorBenchmarkApp.java    |  6 ++-
 .../benchmark/ApplicationFixedTest.java         | 17 ++++---
 .../datatorrent/benchmark/BenchmarkTest.java    |  3 +-
 .../benchmark/CouchBaseBenchmarkTest.java       | 13 +++---
 .../benchmark/accumulo/AccumuloApp.java         | 17 ++++---
 .../benchmark/accumulo/AccumuloAppTest.java     |  8 ++--
 .../aerospike/AerospikeBenchmarkAppTest.java    |  7 +--
 .../algo/UniqueValueCountBenchmarkTest.java     |  6 ++-
 .../cassandra/CassandraApplicatonTest.java      |  8 ++--
 .../benchmark/hbase/HBaseApplicationTest.java   |  9 ++--
 .../hbase/HBaseCsvMappingApplication.java       |  7 +--
 .../benchmark/hive/HiveInsertBenchmarkTest.java | 37 +++++++++------
 .../benchmark/hive/HiveMapBenchmarkTest.java    | 38 ++++++++-------
 .../kafka/KafkaInputBenchmarkTest.java          |  3 +-
 .../kafka/KafkaOutputBenchmarkTest.java         |  4 +-
 .../benchmark/memsql/MemsqlInputBenchmark.java  | 21 +++++----
 .../memsql/MemsqlInputBenchmarkTest.java        | 49 ++++++++++++--------
 .../benchmark/memsql/MemsqlOutputBenchmark.java | 26 ++++++-----
 .../memsql/MemsqlOutputBenchmarkTest.java       | 21 +++++----
 .../script/RubyOperatorBenchmarkAppTest.java    |  7 ++-
 .../spillable/SpillableDSBenchmarkTest.java     |  6 +--
 .../state/ManagedStateBenchmarkAppTest.java     |  3 --
 .../testbench/EventClassifierAppTest.java       | 12 +++--
 ...ventClassifierNumberToHashDoubleAppTest.java | 12 +++--
 .../testbench/EventGeneratorAppTest.java        | 12 +++--
 .../testbench/EventIncrementerAppTest.java      | 12 +++--
 .../testbench/FilterClassifierAppTest.java      | 10 ++--
 .../FilteredEventClassifierAppTest.java         | 12 +++--
 .../testbench/ThroughputCounterAppTest.java     | 12 +++--
 .../util/serde/GenericSerdePerformanceTest.java |  7 +--
 74 files changed, 608 insertions(+), 457 deletions(-)
----------------------------------------------------------------------



Mime
View raw message