Значит shapeless... спасибо

так честно говоря, контекста не очень много ты добавил, давай примером псевдо кода что есть и что хочется сделать

Конфиг { "inputFiles" : "/home/ilnur/Загрузки/csvToDataset/src/main/resources", "outputFile" : "/home/ilnur/Загрузки/csvToDataset/src/main/resources/result/", "transformationType" : { "where" : [0, 1], "equalTo" : [0, 1] }, "columns" : [ "String", "Int" ] } в массиве columns - схема

далее

парсим

case class Config(inputFiles: List[Path], outputFile: String, where: Where, equalTo: EqualTo, columns: List[String])

далее читаем файлы private val inputFiles = config.inputFiles.map { path => env.readCsvFile[(String, Int)](path.toString) }

только типы я тут указал "вручную" [(String, Int)]

не знаю как список туда передать в конце концов columns: List[String]

Значит shapeless... спасибо

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

ок

только типы я тут указал "вручную" [(String, Int)]

но идея такая. "Динамическим" мы называем то, что может изменяться с течением времени, "Статическим" - то, что сохраняет своё состояние, известное априори. Если ты желаешь, чтобы информация, которую ты получишь, управляла твоим процессом, описанным на скалке, где типизация, напомню, статическая, у тебя два выхода 1 - компилить программу после того, как список типов станет тебе известным. Возможно, каждый раз при запуске потока. 2. смириться с динамической природой твоей структуры и использовать библиотеки не требующие явного полного определения типа строки. Можно только убедиться при чтении, что в источнике есть столбцы нужных тебе типов, и использовать этот факт уже статически в дальнейшем коде.

В 1-м случае тебе могут помочь и шейплес, и макросы, и компайлер/билд плагины

Но я рекомендую второй

спасибо за развернутый ответ

?

Прямо совсем в общем случае вряд ли какое-то разумное решение можно придумать. Если первая строчка csv файла - это лист хедеров, то я бы сделал case class со всеми возможными хедерами. Ну и кастомный ридер, что, основываясь на первой строчке. их заполняет. А уж дальше с кейс-классами просто работать

@tailrec def sliceEqual[A](s: Seq[A], acc: Seq[Seq[A]] = Seq()): Seq[Seq[A]] = { s match { case fst :: rest => val (l, r) = s.span(fst==) sliceEqual(r, acc :+ l) case Nil => acc } }

Делюсь решением одной задачки) В обще делает из "ваау, ух ты крууутоо!" => "вау, ух ты круто!"

@tailrec def sliceEqual[A](s: Seq[A], acc: Seq[Seq[A]] = Seq()): Seq[Seq[A]] = { s match { case fst :: rest => val (l, r) = s.span(fst==) sliceEqual(r, acc :+ l) case Nil => acc } }

отлично теперь запусти это для sliceEqual(Vector("a"))

когда поправишь, переделай на foldLeft

propertybased test InputSeq == OutputSeq.flatten

моя непонимать смысла функции)

моя непонимать смысла функции)

о, нас двое

я думал я дурак, полез тестить

моя непонимать смысла функции)

groupConsecutiveOccurences

groupConsecutiveOccurences

ничего не поменялось)

groupConsecutiveOccurences

дошло, спасибо

ничего не поменялось)

группирует одинаковые обекты подряд

ничего не поменялось)

не совсем точно, но близко https://ru.wikipedia.org/wiki/%D0%9A%D0%BE%D0%B4%D0%B8%D1%80%D0%BE%D0%B2%D0%B0%D0%BD%D0%B8%D0%B5_%D0%B4%D0%BB%D0%B8%D0%BD_%D1%81%D0%B5%D1%80%D0%B8%D0%B9

группирует одинаковые обекты подряд

ну даже если такова задумка - то оно так не работает)

а вкурил - пасиб олег)

Объясните пожалуйста, знатоки. Чем именно отличается потоковый вывод типов в скала от механизма вывода типов в стиле Хиндли - Милнера? И что значат слова Одерски: В сравнении со стилем Хиндли - Милнера имеющийся в Scala механизм вывода типов обходится с объектно-ориентированной системой подтипов намного изящнее?

Объясните пожалуйста, знатоки. Чем именно отличается потоковый вывод типов в скала от механизма вывода типов в стиле Хиндли - Милнера? И что значат слова Одерски: В сравнении со стилем Хиндли - Милнера имеющийся в Scala механизм вывода типов обходится с объектно-ориентированной системой подтипов намного изящнее?

Если очень просто, в хиндли-милнере, имея функцию f: A => B и видя выражение f(x) ты можешь заключить, что x: A, в системе с субтайпингом x : A1 <: A, что тебе обычно нихрена не даёт

классический пример рекурсивная функция - в хиндли милнере ты можешь полагать, что все ветки условного выражения или матчинга одного типа. С субтайпингом, ты ищешь наиконкретнейший общий тип, что в случае с рекурсией приводит к уравнению с твоей функцией в обеих частях

ну и т.д. и т.п.

Если очень просто, в хиндли-милнере, имея функцию f: A => B и видя выражение f(x) ты можешь заключить, что x: A, в системе с субтайпингом x : A1 <: A, что тебе обычно нихрена не даёт

Это немного проясняет, спасибо

Но в скалке всё ещё сложнее. Там есть path dependent types, что ещё не завтипы, но ставит те же ограничения на направление вывода типов

Но лучше пойти а чатик завтипов и спросить у пацанов в теме

Scalalaz #38 - Haskell Yeaah с Алексеем Пироговым http://scalalaz.ru/series-38.html Кто еще не видел, ну а кто не видел то без пина и не было наброса сюда ибо всякие митапы и тому подобное.

Юрий Спойлер: фомкин слился и поэтому твой вопрос до сих пор без ответов

спился =)

Юрий Спойлер: фомкин слился и поэтому твой вопрос до сих пор без ответов

*мои вопросы ;)

*мои вопросы ;)

да, но вообще да - я посмотрел нет в завимиостях ничего

кто-то приврал просто или перебрал

Scalalaz #38 - Haskell Yeaah с Алексеем Пироговым http://scalalaz.ru/series-38.html Кто еще не видел, ну а кто не видел то без пина и не было наброса сюда ибо всякие митапы и тому подобное.

можно подписаться на github и получать новости о новом выпуске за сутки до анонса в чате - смекалочка !

можно подписаться на github и получать новости о новом выпуске за сутки до анонса в чате - смекалочка !

еще твиттер есть

https://softwaremill.com/comparing-scala-relational-database-access-libraries/

старьё, даже в ништяках есть

В kamon (akka) можно как-то поменьше метрик слать? По акторам очевидно как фильтрануть, а метрик все равно 100500. В datadog все приходит, остальные жалуются. В доках ничего, как бы я ничего не упускаю(?).

ой профунктор тоже старьё кидает, про зеленоградского стива джобса

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

старье про либы для баз варски обновил, вот все и кидают

В kamon (akka) можно как-то поменьше метрик слать? По акторам очевидно как фильтрануть, а метрик все равно 100500. В datadog все приходит, остальные жалуются. В доках ничего, как бы я ничего не упускаю(?).

вроде в доке было про фильрацию

старье про либы для баз варски обновил, вот все и кидают

спасибо, не заметил

Там в твитторе новая волна разборок на тему харассмента и лямбда конфа, кто-нибудь вникал от чего полыхнуло вновь?

Там в твитторе новая волна разборок на тему харассмента и лямбда конфа, кто-нибудь вникал от чего полыхнуло вновь?

похоже это в качестве анонса у них практикуется

господа,есть вопрос

предположим что фьюча есть, в akka routing, которая в зависимости от результата должна возвращать одну из версий rest модели. Есть ли какой то способ выполнить метод complete(akka routing dsl) из фьючи ?

по хорошему тебе надо написать директиву, которая вернёт тебе ToReponseMarshaller в зависимости от результата

@IceTFoer https://markatta.com/codemonkey/blog/2016/08/03/actor-per-request-with-akka-http/

глянь может подойдет

предположим что фьюча есть, в akka routing, которая в зависимости от результата должна возвращать одну из версий rest модели. Есть ли какой то способ выполнить метод complete(akka routing dsl) из фьючи ?

но зачем здесь роутинг? может быть просто map?

момент

ему нужен маршаллер как я понимаю разный

а я подумал что он хочет передавать реквест контекст в сервис и там внутри во фьюче его комплитить

кто прав?

да, условие целиком нужно )

есть директива`onSuccess`

логично

а есть onComplete

=) короче нужно больше вводных

вот примерно что я хочу

map

выдели функцию Request => Future[Response] и используй ее в роутинге. потом реализуй. ну и стримы тебе в этом примере не нужны от слова совсем. просто сделай отправку в очередь: Data => Future[Unit]

ща подумаем,спасибо =)

вот такое тебе нужно: def sendToQueue(x: String): Future[Unit] = ??? def handleRequest(x: String): Future[Response] = { sendToQueue(x).map(_ => successResponse).recover { case th => failureResponse } } entity { e => complete(handleRequest(...)) }

синтаксис сам поправишь )

чет ты не то советуешь - а как мандить с http кодом?

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

для этого даже специальный маршаллер есть. для тапла

фигаж

ну ))

ога

Ok -> Result =)

Я идею понял,это главное.Спасибо :)

можно написать 2 маршаллера и в complete передавать Future implicit val marshaller: Marshaller[Model0, HttpResponse] = Marshaller.withFixedContentType(ContentTypes.`application/json`)(model0 => HttpResponse(StatusCodes.OK, model0)) implicit val customThrowableMarshaller: Marshaller[Throwable, HttpResponse] = Marshaller.withFixedContentType(ContentTypes.`application/json`) { case MyException(model1) => HttpResponse(StatusCodes.OK, model1) case _ => HttpResponse(StatusCodes.InternalServerError) } complete(future)

Moscow Beer Party завтра 7 февраля в Grill Pab Kontora (http://kontora.club/) начинается в 19:30. Присоединяйтесь все желающие провести отличный вечер за вкусным пивом и увлекательными програмисткими байками

Скаланы, ну так что кто сегодня идет?

среда - неудачный день для пивной вечеринки (

я пасс,до дома ехать далеко.Оставаться в баре в среду не ок

по голосовалке было человек 5, не считая инициаторов

может кто-то еще так придет

забавно будет если никто не придет =)