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 <[email protected]> Authored: Sun Jan 22 11:22:32 2017 -0800 Committer: Thomas Weise <[email protected]> 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(-) ----------------------------------------------------------------------
