streaming

0зной

3ответ

Существует много примеров кода, когда вы используете следующую конструкцию операций ввода-вывода для реализации с классом Stream. Как это: void ReadFileBro() { using(var fs = File.Open("file.txt

3зной

1ответ

Как слить файлы в ZIP из AWS S3

Я использую пакет the PHP Flysystem для передачи содержимого из моего AWS S3. В частности, я использую $filesystem->readStream. Мой вопрос Когда поток файла, он заканчивается в myzip.zip и размер прав

1зной

1ответ

Spark streaming уменьшить на несколько ключевых Java

Я довольно новичок в Spark Streaming, и я застреваю, пытаясь понять, как справиться с этой проблемой, так как я нашел много примеров для одиночных (K, V) пар, но что-то еще. Я был бы признателен за не

3зной

3ответ

Spark streaming. Чтение параллельно с Kafka вызывает повторяющиеся данные

Я предваряю следующий код, который создает 6 входных DStreams, которые читают из раздела 6 разделов из Kafka, используя прямой aproach. Я обнаружил, что даже указание того же идентификатора группы для

0зной

1ответ

HttpWebResponse Чтение потока в неровных фрагментах

Я использую поток от HttpWebRequest.GetResponse().GetResponseStream() для чтения данных из API потокового Интернета. Я использую Begin/EndRead в потоке с буфером в 65 Кбайт. Я могу видеть, что данные

0зной

1ответ

Прочитайте огромные данные от java до угловых js

Я пытаюсь прочитать 100000 записей из java в основном из cassandra в угловой js и загрузить в файл в GUI. Но страница получает повесить момент, когда он получает огромные данные. Что может быть оптима

3зной

1ответ

Интернет-радиопоток с использованием ExoPlayer v2

Я использовал EXOPlayer v1.5.6 для воспроизведения Mp3/AAC AudioStream, но в этой версии есть много недостатков. Я решил обновить до v 2.0.2, но я не могу найти документацию для воспроизведения только

0зной

1ответ

RDD и SPARK Streaming Microbatches

Можно ли ожидать 1 RDD на микробачту всегда? Или это зависит от количества приемников? Как мы можем гарантировать сортировку?