You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2017/01/22 19:24:07 UTC
[3/3] apex-malhar git commit: Merge commit 'refs/pull/539/head' of
https://github.com/apache/apex-malhar
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 <th...@apache.org>
Authored: Sun Jan 22 11:22:32 2017 -0800
Committer: Thomas Weise <th...@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(-)
----------------------------------------------------------------------