Описание тега streaming-algorithm

Алгоритм потоковой передачи - это алгоритм, который получает входные данные по одному элементу за раз.
1 ответ

Вычисление процентилей с использованием фиксированного объема памяти

У меня есть поток значений int, поступающих с определенной скоростью. Каждые 5 минут я хотел бы вычислить некоторые процентили из значений и начать все сначала. Проблема: я не хочу тратить слишком много памяти, поэтому я хотел бы оставить только нес…
1 ответ

O(n) Тяжеловесы с O(1/ эпсилон) пробелом?

Я знаю о следующем алгоритме для тяжеловесов: Algorithm findHeavyHitters(epsilon, inputStream) integer k = ceiling(1 / epsilon) - 1 initialize hashmap H of size k while an item i from the input stream arrives: if H[i] exists increment the value asso…
16 июн '16 в 06:26
1 ответ

Раздвижные окна

Я ищу способ эффективно поддерживать набор значений из 1-минутного скользящего окна из заданного потока данных (~100 тыс. Значений в секунду). Я ищу решение с максимальным логарифмическим временем вставки (так как основной упорядоченный по времени в…
1 ответ

Найти наиболее посещаемый URL за последний день, или последний час, или последнюю минуту?

Исходный вопрос - файл, содержащий URL-адрес 5 ГБ, который был посещен в последний день. Эта проблема может быть решена с помощью хэш-карты для подсчета вхождений различных URL-адресов и определения top k с помощью min heap, что занимает время O (n …
1 ответ

Сиддхи КЭП - события, которые не были объединены в скользящем окне

У меня есть два потока, streamA а также streamB, Каждый из streamA имеет идентификатор и соответствующее событие в streamB будет иметь тот же идентификатор. Я хочу знать от streamA какие идентификаторы не пришли streamB после скользящего окна, скаже…
27 май '16 в 12:51
0 ответов

Вычисление энтропии потоковой передачи данных

Я ищу способ вычислить оценку информационной энтропии Шеннона H'(X) для потоковых данных. Пространство состояний случайной величины X велико, и несколько тысяч этих вычислений будут выполняться параллельно, поэтому невозможно сохранить каждое наблюд…
0 ответов

Удалить приложение из недавних приложений. Как сделать вызов API для обновления сервера

мне нужна помощь. Я работаю над потоковым приложением и столкнулся с проблемой. когда вещатель выйдет в эфир. его значение на сервере становится онлайн. Когда вещатель завершает работу, нажав кнопку с крестиком, затем значение обновляется в автономн…