From bc6951ac0f44d331c98dc42295710e677c160f36 Mon Sep 17 00:00:00 2001
From: Rance4396 <2437708352@qq.com>
Date: Thu, 19 May 2022 17:26:32 +0800
Subject: [PATCH] =?UTF-8?q?Changes:=E5=A2=9E=E5=8A=A0=E4=BA=86=E8=87=AA?=
 =?UTF-8?q?=E5=8A=A8=E7=94=9F=E6=88=90=E4=BF=AE=E6=94=B9=E6=95=B0=E6=8D=AE?=
 =?UTF-8?q?=E5=8F=98csv=E7=9A=84=E6=A0=BC=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 average.py           | 22 ++++++++++++++++++++++
 average_func_test.py |  3 +++
 2 files changed, 25 insertions(+)
 create mode 100644 average.py
 create mode 100644 average_func_test.py

diff --git a/average.py b/average.py
new file mode 100644
index 0000000..a7bb3fc
--- /dev/null
+++ b/average.py
@@ -0,0 +1,22 @@
+from algorithm import algorithm
+import json
+import ray
+
+@ray.remote
+class step(algorithm):
+    def __init__(self):
+        self.config_dict_ = None
+        self.config_ = None
+        self.average_number_ = 10
+        self.window_1_ = None
+
+    def set_config(self, config):
+        self.config_ = config
+        self.config_dict_ = json.loads(self.config_)
+        self.average_number_ = self.config_dict_["AVERAGE_NUMBER"]
+
+    def config(self):
+        return self.config_
+
+    def eval(self, value):
+        return value * self.amplitude_base_
diff --git a/average_func_test.py b/average_func_test.py
new file mode 100644
index 0000000..cace41e
--- /dev/null
+++ b/average_func_test.py
@@ -0,0 +1,3 @@
+from algorithm import algorithm
+import json
+import ray
\ No newline at end of file