Спасибо за видео выше, оно, в отличии от строчки кода для проверки моих предположений кас-но F[_] в Stream, не помогло, но принесло эстетическое удовольствие. Вопрос ближе к теме — правильно ли я понимаю, что F[_] в fs.Stream — абсолютно произвольная обертка вида: trait Ex[O] {} к которой никаких требований не предъявляется, и которая служит только для определения формата передаваемых данных по стриму? Если так — то в чем глубинный смысл делать разделение на F[_] и O, если можно было, кхм, сделать передачу чего угодно?

я fs не знаю, но смею предположить что это дырка нужна, чтобы потом указать на чем ты будешь исполнять этот стрим

например на Future или IO

все, нашел из ошибки откуда это брать : [error] found : List[String] [error] required: org.apache.kafka.streams.KeyValue[_ <: String, _ <: String]

Спасибо за видео выше, оно, в отличии от строчки кода для проверки моих предположений кас-но F[_] в Stream, не помогло, но принесло эстетическое удовольствие. Вопрос ближе к теме — правильно ли я понимаю, что F[_] в fs.Stream — абсолютно произвольная обертка вида: trait Ex[O] {} к которой никаких требований не предъявляется, и которая служит только для определения формата передаваемых данных по стриму? Если так — то в чем глубинный смысл делать разделение на F[_] и O, если можно было, кхм, сделать передачу чего угодно?

Пример из доки намекает import cats.effect.{IO, Sync} import fs2.{io, text} import java.nio.file.Paths def fahrenheitToCelsius(f: Double): Double = (f - 32.0) * (5.0/9.0) def converter[F[_]](implicit F: Sync[F]): F[Unit] = io.file.readAll[F](Paths.get("testdata/fahrenheit.txt"), 4096) .through(text.utf8Decode) .through(text.lines) .filter(s => !s.trim.isEmpty && !s.startsWith("//")) .map(line => fahrenheitToCelsius(line.toDouble).toString) .intersperse("\n") .through(text.utf8Encode) .through(io.file.writeAll(Paths.get("testdata/celsius.txt"))) .run // at the end of the universe... val u: Unit = converter[IO].unsafeRunSync()

а как запускать приложения (которые я запускаю с помощью команды sbt run) чтобы их можно было обнаружить 'ps aux' (нужно замерить потребление) А то по имени приложения оно ничего не находи, зато висят безымянные процессы sbt: vlad 70854 70.3 9.1 6848816 762388 s009 R+ 5:11PM 1:46.10 /usr/bin/java -Xms1024m -Xmx1024m -XX:ReservedCodeCacheSize=128m -XX:MaxMetaspaceSize=256m -jar /usr/local/Cellar/sbt/1.0.4/libexec/bin/sbt-launch.jar run vlad 62596 8.8 8.9 6839076 742636 s007 S+ 2:12PM 5:27.13 /usr/bin/java -Xms1024m -Xmx1024m -XX:ReservedCodeCacheSize=128m -XX:MaxMetaspaceSize=256m -jar /usr/local/Cellar/sbt/1.0.4/libexec/bin/sbt-launch.jar vlad 62559 0.0 0.0 4279596 752 s007 S+ 2:12PM 0:00.02 bash /usr/local/Cellar/sbt/1.0.4/libexec/bin/sbt vlad 71733 0.0 0.0 4267752 356 s006 R+ 5:20PM 0:00.00 grep —color=auto —exclude-dir=.bzr —exclude-dir=CVS —exclude-dir=.git —exclude-dir=.hg —exclude-dir=.svn sbt vlad 70817 0.0 0.0 4279596 752 s009 S+ 5:11PM 0:00.02 bash /usr/local/Cellar/sbt/1.0.4/libexec/bin/sbt run и я не могу опознать нужный

не запускать так

попробуй fork := true

в build.sbt

спс, момент

Ну по хорошему конечно надо собрать и запустить отдельно

да человеку вон замерять нужно - срочно же

@vlad1777d https://github.com/sbt/sbt-assembly можешь попробовать собрать jar-ку этим

@rockjam , спасибо большое, но все равно не пишется название процесса =)

хм, там classpath пишется?

покажи вывод ps aux сейчас

спасибо, сейчас попробую собрать jar-ky

момент

просто я не совсем понимаю что именно ты хочешь увидеть

vlad 72055 182.2 5.8 6818344 485900 s007 R+ 5:25PM 0:51.21 /usr/bin/java -Xms1024m -Xmx1024m -XX:ReservedCodeCacheSize=128m -XX:MaxMetaspaceSize=256m -jar /usr/local/Cellar/sbt/1.0.4/libexec/bin/sbt-launch.jar vlad 70854 50.1 11.6 6850880 976104 s009 S+ 5:11PM 2:17.21 /usr/bin/java -Xms1024m -Xmx1024m -XX:ReservedCodeCacheSize=128m -XX:MaxMetaspaceSize=256m -jar /usr/local/Cellar/sbt/1.0.4/libexec/bin/sbt-launch.jar run vlad 72359 0.0 0.0 4267752 420 s006 R+ 5:27PM 0:00.00 grep —color=auto —exclude-dir=.bzr —exclude-dir=CVS —exclude-dir=.git —exclude-dir=.hg —exclude-dir=.svn sbt vlad 72018 0.0 0.0 4287788 752 s007 S+ 5:25PM 0:00.02 bash /usr/local/Cellar/sbt/1.0.4/libexec/bin/sbt vlad 70817 0.0 0.0 4279596 752 s009 S+ 5:11PM 0:00.02 bash /usr/local/Cellar/sbt/1.0.4/libexec/bin/sbt run

я вижу эти процессы

но у меня два разных: продюсер и стримс

2-ой вроде твой

я не могу определить где кто )

у меня 2 сразу запущены

а, ясно. ну тогда лучше sbt assembly сделай

и я меряю как они на одной машине работают

понял, спасибо большое

тогда у тебя будут разные имена у jar-ок

благодарю )

Или переименовать мейн в осмысленное, тогда jps процессы покажет

а что за мейн ?

имеется ввиду мейн класс ? если да, тоу меня они названы Streams, Producer

Да, они

Если запускать не в сбт, то jps покажет их имена и пиды

не помогает, видимо )

а да, кстати можешь через sbt запустить как sbt runMain Producer и sbt runMain Streams

тогда наверное в ps aux так и будет

Это же только выбор мейн класса

короче, нужно собирать jar, как я понял )

Да

ок

rockjam 27261 268 3.2 8134296 533244 pts/2 Sl+ 18:36 0:21 java -Xms4096m -Xmx4096m -XX:ReservedCodeCacheSize=512m -XX:MaxMetaspaceSize=1024m -jar /usr/share/sbt/bin/sbt-launch.jar runMain foo

Да

вообще нет)

стоп, момент, попробую

вообще нет)

Ну ты прям Юджин)

Ну в замере же еще будут ресурсы от sbt

ща лайфкодинг sbt в твиттер выложу

Ну в замере же еще будут ресурсы от sbt

Насколько понимаю, если в стдаут логи не плевать излишне, то это пофиг в данном случае.

[error] Expected whitespace character [error] runMain

это после sbt runMain Producer

ты эт просто сделай ран

и выбери что те запускать при наличии множества мейнов то

sbt "runMain Producer"

спасибо

теперь все видно )

так, ребята, мы же еще не советовали sbt native packager и запуск в докере

И грааль

@gurinderu видимо все проглядел

ась?

Последний глупый вопрос по fs2 на сегодня — сколько не искал — не нашел ничего о возможности/невозможности создания бесконечных потоков, в которых эмиссии происходят каким-то "третьим" компонентом. Можете прояснить пожалуйста?

Последний глупый вопрос по fs2 на сегодня — сколько не искал — не нашел ничего о возможности/невозможности создания бесконечных потоков, в которых эмиссии происходят каким-то "третьим" компонентом. Можете прояснить пожалуйста?

fs2 это не про реактивный стримы жи

fs2 это не про реактивный стримы жи

Понял. Спасибо.

ERROR: S client not available

Вообще есть реализация и реактивщины

https://github.com/zainab-ali/fs2-reactive-streams

https://www.iravid.com/posts/fp-and-spark.html

https://www.kaggle.com/c/jigsaw-toxic-comment-classification-challenge

Господи, вот это вин

999 members

1000!!!

главное не убыть теперь

Будут розыгрыши бетховенов в честь знаменательного события?

Будут розыгрыши бетховенов в честь знаменательного события?

прочитал как "розыгрыши батхертов", я болен?

а вот и 1001 участник конфы! ЮХУ! Aleksey

а вот и 1001 участник конфы! ЮХУ! Aleksey

Жаль не вышло юбилейным стать)

ну 1001 тоже отличный вариант, но если считать с нуля то индекс у тебя будет как раз таки 1000

до юбилея еще 23 участника

Жаль не вышло юбилейным стать)

можешь кого--то турнуть токсичностью и стать 1000ым

Котоны, кто в курсе, как заставить scalapb юзать ByteBuffer вместо гугловского ByteString?

Или акковский байтстринг к примеру.

Котоны, кто в курсе, как заставить scalapb юзать ByteBuffer вместо гугловского ByteString?

asReadOnlyByteBuffer

или ты имеешь ввиду прям генерировать тебе ByteBuffer?

ага

не, генерировать он точно будет ByteString, можешь только вызвать asReadOnlyByteBuffer

плохо. не хочется туда-сюда конвертить.

можешь сделать implicit conversion )

можешь сделать implicit conversion )

не хочется туда-сюда конвертить.