This is an automated email from the ASF dual-hosted git repository.
altay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 6f7f5fd4dc2a16624a73300398ebe575db6b1f94
Author: Matthias Feys <matth...@ml6.eu>
AuthorDate: Mon May 14 14:53:10 2018 +0200
Remove old_div
---
.../apache_beam/tools/distribution_counter_microbenchmark.py | 6 ++----
sdks/python/apache_beam/tools/map_fn_microbenchmark.py | 4 +---
sdks/python/apache_beam/tools/sideinput_microbenchmark.py | 8 +++-----
3 files changed, 6 insertions(+), 12 deletions(-)
diff --git
a/sdks/python/apache_beam/tools/distribution_counter_microbenchmark.py
b/sdks/python/apache_beam/tools/distribution_counter_microbenchmark.py
index 4f48782..1e0809f 100644
--- a/sdks/python/apache_beam/tools/distribution_counter_microbenchmark.py
+++ b/sdks/python/apache_beam/tools/distribution_counter_microbenchmark.py
@@ -32,8 +32,6 @@ import sys
import time
from builtins import range
-from past.utils import old_div
-
from apache_beam.tools import utils
@@ -62,8 +60,8 @@ def run_benchmark(num_runs=100, num_input=10000,
seed=time.time()):
counter.add_inputs_for_test(inputs)
time_cost = time.time() - start
print("Run %d: Total time cost %g sec" % (i+1, time_cost))
- total_time += old_div(time_cost, num_input)
- print("Per element update time cost:", old_div(total_time, num_runs))
+ total_time += time_cost // num_input
+ print("Per element update time cost:", total_time // num_runs)
if __name__ == '__main__':
diff --git a/sdks/python/apache_beam/tools/map_fn_microbenchmark.py
b/sdks/python/apache_beam/tools/map_fn_microbenchmark.py
index 6bfd701..e640c2b 100644
--- a/sdks/python/apache_beam/tools/map_fn_microbenchmark.py
+++ b/sdks/python/apache_beam/tools/map_fn_microbenchmark.py
@@ -38,8 +38,6 @@ import time
from builtins import range
from builtins import zip
-from past.utils import old_div
-
import apache_beam as beam
from apache_beam.tools import utils
from scipy import stats
@@ -63,7 +61,7 @@ def run_benchmark(num_maps=100, num_runs=10,
num_elements_step=1000):
gradient, intercept, r_value, p_value, std_err = stats.linregress(
*list(zip(*list(timings.items()))))
print("Fixed cost ", intercept)
- print("Per-element ", old_div(gradient, num_maps))
+ print("Per-element ", gradient // num_maps)
print("R^2 ", r_value**2)
diff --git a/sdks/python/apache_beam/tools/sideinput_microbenchmark.py
b/sdks/python/apache_beam/tools/sideinput_microbenchmark.py
index df36174..7cfdb29 100644
--- a/sdks/python/apache_beam/tools/sideinput_microbenchmark.py
+++ b/sdks/python/apache_beam/tools/sideinput_microbenchmark.py
@@ -29,8 +29,6 @@ from __future__ import print_function
import time
from builtins import range
-from past.utils import old_div
-
from apache_beam.runners.worker import opcounters
from apache_beam.runners.worker import sideinputs
from apache_beam.runners.worker import statesampler
@@ -69,10 +67,10 @@ def run_benchmark(num_runs=50, input_per_source=4000,
num_sources=4):
print("Runtimes:", times)
- avg_runtime = old_div(sum(times), len(times))
+ avg_runtime = sum(times) // len(times)
print("Average runtime:", avg_runtime)
- print("Time per element:", old_div(avg_runtime, (input_per_source *
- num_sources)))
+ print("Time per element:", avg_runtime // (input_per_source *
+ num_sources))
if __name__ == '__main__':
--
To stop receiving notification emails like this one, please contact
al...@apache.org.
