Вопросы с тегом «stream-processing»

39
Почему я должен использовать «функциональные операции» вместо цикла for?

for (Canvas canvas : list) { } NetBeans предлагает мне использовать «функциональные операции»: list.stream().forEach((canvas) -> { }); Но почему это предпочтительнее ? Во всяком случае, труднее читать и понимать. Вы звоните stream(), затем forEach()используете лямбда-выражение с параметром...

37
Это антипаттерн, чтобы использовать peek () для изменения элемента потока?

Предположим, у меня есть поток вещей, и я хочу «обогатить» их серединой потока, я могу использовать peek()это, например: streamOfThings.peek(this::thingMutator).forEach(this::someConsumer); Предположим, что изменение объектов в этой точке в коде является правильным поведением - например,...

34
Что такое поток байтов на самом деле?

Может кто-нибудь объяснить мне, что поток байтов на самом деле содержит? Содержит ли он байты (шестнадцатеричные данные) или двоичные данные или только английские буквы? Меня также смущает термин «необработанные данные». Если кто-то попросил меня «перевернуть 4-байтовые данные», то что я должен...

19
Разумно ли возвращать потоки везде, где мы обычно возвращаем коллекции?

Разрабатывая мой API, который не привязан к какому-либо устаревшему коду, я часто нахожу себя пишущим методы, которые являются чисто конвейерными потоками и заканчиваются сбором результатов. Как этот: ImmutableSet<T> deriveSomethingMeaningfulFromPrivateState() { return...

13
Традиционные брокеры сообщений и потоковые данные

По данным сайта Кафки : « Kakfa используется для создания конвейеров данных в реальном времени и потоковых приложений ». Просматривая Интернет повсеместно, я нашел следующее общепринятое определение понятия « потоковые данные »: Потоковые данные - это данные, которые непрерывно перемещаются из...