Prosta ruchoma średnia java

Prosta przeprowadzka Średnia implementacja w Javie Kilka razy chciałem obliczyć proste dane w moich aplikacjach Java, na przykład liczbę uderzeń na godzinę lub błędy w danym okresie czasu. Podczas gdy obliczanie prostych metryk nie jest strasznie trudne, to tylko dodatkowa praca i Id raczej spędzają ten czas w domenie problemowej. Byłem zaskoczony, że nie znalazłem powszechnie akceptowanych rozwiązań dla danych w Javie. Znalazłem Metrics, ale wydawało mi się to zbyt skomplikowane i niezbyt dobrze udokumentowane - chciałem tylko obliczyć średnią ruchomą. Myślałem o tym problemie i uznałem, że nie jest to trudny problem. To jest moje rozwiązanie To działa przez utworzenie tablicy rozmiaru częstotliwości aktualizacji okna, a następnie wątek ustawia liczbę do następnego indeksu w tablicy na częstotliwości aktualizacji. Liczbą interwału jest po prostu tablica - tablica1, która jest najnowszą liczbą minus najstarsza liczba. Dla przedziału 10-minutowego najstarszy licznik (i1) ma dokładnie 10 minut. Aby dodać średnią ruchomą do naszego kodu, najpierw potrzebujemy licznika, używając AtomicLong. Ten licznik powinien być inkrementowany na podstawie wydarzeń, które są zainteresowane przetwarzaniem (np. Żądania POST dotyczące usługi REST). Musimy zapewnić implementację z dostępem do licznika i jest to realizowane za pomocą interfejsu GetCount. Tutaj Ill tworzy średnią ruchomą za pomocą 5-minutowego okna, które aktualizuje się co sekundę. Aby uzyskać aktualną średnią, po prostu wywołujemy metodę getAverage: Kluczowym szczegółem implementacji jest określenie rozmiaru tablicy: podzielenie okna przez częstotliwość aktualizacji. Tak duże okno z częstą częstotliwością aktualizacji może pochłonąć znaczną ilość pamięci. W tym przykładzie rozmiar tablicy wynosi rozsądnie 300. Jednakże, jeśli stworzylibyśmy 24-godzinną średnią ruchomą z interwałem 1-sekundowym, wielkość wynosiłaby 86400. Mądrzejsza częstotliwość aktualizacji dla okresu 24-godzinnego może wynosić co 5 minut (rozmiar tablicy 288 ). Kolejną kwestią wyboru okna i częstotliwości aktualizacji jest podzielenie okna na częstotliwość. Na przykład okno 2-minutowe z 6-sekundową częstotliwością aktualizacji jest w porządku, ale 7-sekundowa częstotliwość aktualizacji nie jest, ponieważ nie jest podzielna przez 120. Wyjątek IllegalArgumentException jest generowany, jeśli częstotliwość aktualizacji modułu okna nie wynosi zero. Ta implementacja wymaga jednego wątku na średnią ruchomą, co nie jest zbyt wydajne. Lepszym rozwiązaniem byłoby podzielenie wątku na wiele średnich. Aktualizacja . Ive zaktualizował kod, aby udostępnić tutaj wątek. Na koniec jest problem z początkowym stanem: nie mamy danych jeszcze dla całego okna. Na przykład, jeśli masz 5-minutowe okno i tylko 15 sekund danych. Ta implementacja zwraca wartość null, dopóki nie mamy 5 minut danych. Innym podejściem jest oszacowanie średniej. Załóżmy, że mamy liczbę 10 w 30 sekund, wtedy możemy oszacować średnią jako 40 w ciągu 2 minut. Istnieje jednak ryzyko znacznego błędu poprzez ekstrapolację niekompletnych danych. Na przykład, jeśli mamy wybuch 20 trafień w ciągu 2 sekund, weź oszacuj 1200 na 2 minuty, co według wszelkiego prawdopodobieństwa jest daleko. Twój wewnętrzny to iteracja całej tablicy, więc dlaczego zawsze dostajesz taką samą średnią ( jeden dla całej tablicy), powinieneś zamiast tego iterować od 0 do bieżącego numeru zewnętrznego. Twoja średnia ruchoma jest aktualizowana w oparciu o j wewnętrznego, co oznacza, że ​​będzie przesłonić poprzednie wartości każdej nowej pętli, to powinno być wewnątrz zewnętrznej zamiast wewnętrznej, używając i jako indeksu. Sumujesz sumj, aby obliczyć średnie, każda nowa wewnętrzna pętla j podzielisz przez 0 pierwszą sumę. Wierzę, że miałeś zamiar używać j1, indeks nie jest taki sam jak bieżąca długość. Wskazówki dotyczące rozwiązywania problemów: Unikaj używania zmiennych do tablic pętlowych, zamiast tego użyj array. length. Aby odtworzyć problem, możesz podać nam wyizolowany problem zamiast obecnego kodu. czyli: Wyobraź sobie, czy błąd znajduje się w Twoich danych wejściowych, jak możemy uwierzyć, że naprawdę ich używałeś. 4 października w 20:54 Czytasz za każdym razem dane. Powinieneś dysponować (najmniejszą średnią) (int j (igtaverageLengthi-averageLength2: 0) jlt iaverageLength2 ampamp jltnumDataPoints j) (lub coś podobnego). Ponadto, moveAverageisumj powinno zostać zmodyfikowane, aby obsłużyć przypadek, gdy j jest równe 0. W szczególności prawdopodobnie powinno się poruszać AverageisumaverageLength i powinno być stosowane do gniazda movingAveragei poza pętlą uśredniającą. odpowiedziało 4 października 13 o 20:42 Następnym razem, zanim opublikujesz, odrzuć komentarze na temat zadania. Ale ponieważ wydajesz się całkiem nowy w tym, pomyśl o tym, jak przeglądasz dane i spraw, żeby to robił. Powinieneś starać się upewnić, że każda pętla zatrzymuje się w odpowiednim punkcie, i pamiętaj, że jeśli chcesz przestać, gdy nie ma więcej liczb, (jak podczas robienia pętli wewnętrznej i możesz uzyskać tylko 3 kolejne cyfry zamiast 4) program również musi się zatrzymać. Upewnij się, że Twój kod sprawdza to. odpowiedziało Oct 4 13 w 20:56 Bez dodatkowych informacji, prawdopodobnie potrzebujesz nieważonej średniej ruchomej. W dowolnym punkcie Ai w macierzy wejściowej A o długości N (z 0ltiltN), to po prostu średnia z poprzednich wpisów K tablicy, do Ai włącznie. Jeśli nie ma takich wartości K, wówczas średnie wartości (i1) od A0 do Ai. włącznie. Trochę myśli pokaże ci, że nie musisz dodawać wszystkich wartości K za każdym razem. Po prostu zachowaj sumę, a gdy przejdziesz do następnego punktu (jest to średnia ruchoma), odejmij tę wartość, która zostanie zastąpiona i dodaj nową wartość, która ją zastąpi. (Podczas pierwszych punktów K-1, po prostu dodasz nową wartość do sumy i zwiększysz swój licznik o 1.) W dowolnym punkcie tego procesu średnia ruchoma jest bieżącą sumą podzieloną przez bieżącą wartość zliczania. odpowiedziała Oct 4 13 w 21:05 W średniej ruchomej musisz mieć jakiś rozmiar okna. Twój rozmiar okna wynosi średniej długości, więc będzie wyglądał mniej więcej tak: Pętla for zaczyna się od bieżących danych i przechodzi przez punkty danych averageLength i dodaje je. Średnia krocząca będzie mieć tylko wtedy, gdy masz wystarczającą ilość punktów danych, a średnia będzie sumą podzieloną przez średnią długość. Uwaga: Nie testowałem tylko kodu sudo, ale taki jest pomysł. odpowiedz Oct 4 13 o 21:05 Twoja wymiana stosu odpowiedzi 2017, metoda średniej ruchomej IncJava Jeśli szukasz EMA zoptymalizowanego pod kątem przesyłania strumieniowego danych, pochodzącego z pliku lub usługi cytowania, poniższa przykładowa klasa sprawi, że dobrze, jak przeciwieństwie do obliczeń brutalnej siły. Takie podejście jest szczególnie przydatne, jeśli przetwarzasz dane w czasie rzeczywistym. EMA, specjalny przypadek ważonych średnich kroczących, mają tę zaletę, że względna waga dla każdego kolejnego okresu zmniejsza się o stały współczynnik f 2 (N1), gdzie N jest liczbą okresów, przez które EMA ma być stosowana. Biorąc to pod uwagę, można obliczyć aktualną EMA (tj. Dla bieżącego okresu) przy użyciu następującej iteracyjnej formuły: eman fprice (1-f) eman-1 Poniższa przykładowa klasa implementuje iteracyjny charakter EMA i minimalizuje wymagania obliczeniowe wymuszać metody lub metody przetwarzania końcowego. private int numPeriods 0 private int totalPeriods 0 private double runningEMA 0.0 prywatny double factor 0.0 publiczny EMA (int numPeriods) this. numPeriods numPeriods factor 2.0 (numPeriods 1.0) Resetuj obliczenia, aby wygenerować EMA dla danego okresu. public void reset (int numPeriods) Zwraca EMA dla okresu definiowanego podczas konstruktora. Jeśli przetwarzane okresy są mniejsze od zakresu EMA, zwracane jest zero. public double calculate (double price) runningEMA factorprice (1-factor) runningEMA if (totalPeriods lt numPeriods) Od kiedy otrzymujesz dane o cenie, a co robisz z wynikami EMA zależy od Ciebie. Na przykład, jeśli masz dane dotyczące ceny w tablicy i chcesz obliczyć EMA w innej tablicy, działa następujący fragment: podwójne ceny. pochodzą z obliczeń, plików lub ofert usług podwójne ema nowe doubleprices. length EMA ema nowe EMA (50) 50 okres EMA dla (int idx0 iltprices. length idx) emaidx ema (pricesidx) Powodzenia i najlepsze życzenia dla twojego projektu. AveragesSimple średnia krocząca Średnia średnia krocząca Średnie Prosta Zachęcasz do rozwiązania tego zadania zgodnie z opisem zadania, używając dowolnego języka, który możesz znać. Obliczanie prostej średniej kroczącej z serii liczb. Utwórz stateful functionclassinstance, która pobiera kropkę i zwraca procedurę, która przyjmuje liczbę jako argument i zwraca prostą średnią ruchomych argumentów. Prosta średnia ruchoma to metoda obliczania średniej strumienia liczb przez uśrednienie tylko ostatnich 160 liczb P 160 ze strumienia, 160 gdzie 160 P 160 jest znane jako okres. Można go wdrożyć, wywołując procedurę inicjującą z 160 P 160 jako argumentem 160 I (P), 160, który powinien następnie zwrócić procedurę, która po wywołaniu z indywidualnymi, kolejnymi członkami strumienia liczb, oblicza średnią (w górę). do), ostatnie 160 P 160 z nich, pozwala wywołać to 160 SMA (). Słowo 160 160 w opisie zadania odnosi się do potrzeby 160 SMA () 160, aby zapamiętać pewne informacje między połączeniami do niego: 160 Okres, 160 P 160 Zleceniodawca co najmniej ostatnich 160 P 160 z każdego z indywidualnych rozmów. Stateful 160 oznacza również, że kolejne wywołania do 160 I (), 160 inicjalizatora, 160 powinny zwracać oddzielne podprogramy, które mają 160 zapisany stan 160 akcji, aby mogły być użyte na dwóch niezależnych strumieniach danych. Pseudo-kod dla implementacji 160 SMA 160 to: Ta wersja używa trwałej kolejki do przechowywania najnowszych wartości p. Każda funkcja zwrócona przez init-moving-average ma swój stan w atomie utrzymującym wartość kolejki. Ta implementacja używa okrągłej listy do przechowywania liczb w oknie na początku każdego wskaźnika iteracji odnosi się do komórki listy, która przechowuje wartość właśnie wyprowadzającą się poza okno i do zastąpienia przez wartość dodaną. Korzystanie z zamykania edytuj Obecnie to nie może być nogc, ponieważ przydzieli zamknięcie na stercie. Niektóre analizy ucieczki mogą usunąć przydział sterty. Korzystanie z edytowania struktury Struktura ta pozwala uniknąć alokacji stosu zamknięcia, przechowując dane w ramce stosu głównej funkcji. Ten sam wynik: aby uniknąć przybliżania się liczb zmiennoprzecinkowych i rosnąć, kod mógłby wykonywać okresową sumę na całej okrągłej tablicy kolejki. Ta implementacja generuje dwa (funkcjonalne) obiekty udostępniające stan. W E jest idiomatyczne oddzielanie danych wejściowych od danych wyjściowych (odczyt z zapisu) zamiast łączenia ich w jeden obiekt. Struktura jest taka sama jak implementacja Standard DeviationE. Poniższy program eliksiru generuje anonimową funkcję z osadzonym okresem p, który jest używany jako okres prostej średniej kroczącej. Funkcja run odczytuje dane numeryczne i przekazuje je do nowo utworzonej funkcji anonimowej, a następnie sprawdza wynik do STDOUT. Dane wyjściowe przedstawiono poniżej, przy średniej, a następnie w ujęciu grupowym, stanowiącym podstawę dla każdej średniej ruchomej. Erlang ma zamknięcia, ale zmienne niezmienne. Rozwiązaniem jest wówczas wykorzystanie procesów i prostego API opartego na przekazywaniu komunikatów. Języki macierzy mają rutyny do obliczania szybujących średnich dla danej sekwencji przedmiotów. Pętla jest mniej wydajna niż w poniższych poleceniach. Ciągle monituje o wejście I. który jest dodawany na końcu listy L1. L1 można znaleźć naciskając 2ND1, a średnie można znaleźć w ListOPS Naciśnij ON, aby zakończyć program. Funkcja, która zwraca listę zawierającą uśrednione dane dostarczonego argumentu Program, który zwraca prostą wartość przy każdym wywołaniu: lista jest uśredniana dla listy: p jest okresem: 5 zwraca uśrednioną listę: Przykład 2: Używanie programu movinav2 (i , 5) - Inicjalizacja obliczeń średniej ruchomej i zdefiniowanie okresu 5 movinav2 (3, x): x - nowe dane na liście (wartość 3), a wynik zostanie zapisany na zmiennej x i wyświetlony movinav2 (4, x) : x - nowe dane (wartość 4), a nowy wynik zostanie zapisany na zmiennej x i wyświetlony (43) 2. Opis funkcji movinavg: zmienna r - jest wynikiem (uśredniona lista), która będzie zwracaną zmienną i - jest zmienną indeksową, i wskazuje na koniec listy podrzędnej, której lista jest uśredniana. zmienna z - zmienna pomocnicza Funkcja wykorzystuje zmienną i do ustalenia, które wartości z listy będą brane pod uwagę przy następnych obliczeniach średnich. Przy każdej iteracji zmienna i wskazuje na ostatnią wartość na liście, która będzie używana w obliczeniach średnich. Musimy tylko ustalić, która będzie pierwszą wartością na liście. Zwykle trzeba wziąć pod uwagę elementy p, więc pierwszym elementem będzie ten indeksowany przez (i-p1). Jednak w pierwszych iteracjach obliczenia będą zazwyczaj ujemne, więc poniższe równanie pozwoli uniknąć indeksów ujemnych: max (i-p1,1) lub, ustawiając równanie, max (i-p, 0) 1. Ale liczba elementów na pierwszych iteracjach będzie mniejsza, poprawna wartość będzie (indeks końca - początek indeksu 1) lub, układając równanie, (i - (max (ip, 0) 1) 1), a następnie , (i-max (ip, 0)). Zmienna z zawiera wspólną wartość (max (ip), 0), więc beginindex będzie (z1), a liczbafelementów będzie (iz) mid (lista, z1, iz) zwróci listę wartości, która będzie uśrednioną sumą ( .) zsumuje ich sumę (.) (iz) ri je uśredni i zapisze wynik w odpowiednim miejscu na liście wyników fp1 tworzy częściową aplikację ustalającą (w tym przypadku) drugi i trzeci parametr