Публикации по теме 'scala'
Как работают Akka Actors
Akka Actors - очень популярный и широко используемый фреймворк, который реализует акторов (или, для простоты, облегченные потоки) на JVM. Чтобы понять, как работают Актеры и как они сопоставляются с потоками JVM, мы создали нашу собственную крошечную структуру Акторов, похожую на Akka Actors. Основное внимание уделяется изучению и пониманию планирования Актеров, поэтому многие другие функции, включая реализацию супервизора и т. Д., Опускаются.
Пример кода доступен по адресу..
Вопросы по теме 'scala'
Что именно этот фрагмент делает в scala?
Я пытаюсь понять пример twitter gizzard rowz, и я не могу понять, что этот маленький фрагмент делает в scala:
package com.twitter.rowz
import com.twitter.gizzard.nameserver.{Forwarding, NameServer}
import com.twitter.gizzard.shards.ShardException...
232 просмотров
schedule
04.10.2023
Scala: требуется ли временная переменная для обработки возвращаемого значения кортежа?
Рассмотрим следующий скетч для использования цикла для очистки очереди в Scala:
var queue = immutable.Queue[T]( /* .. some content ..*/ )
while( !queue.isEmpty ) {
val (record, tempQueue) = queue.dequeue
queue = tempQueue...
930 просмотров
schedule
31.10.2023
Сгладить произвольно вложенный список в Scala
def flatten(l: List[_]): List[_] = {
def iflatten(l: List[_], ret: List[_]): List[_] = l match {
case Nil => ret
case h :: Nil =>
if( h.isInstanceOf[List[_]]) { iflatten(h, ret) }
else {
l.head ::...
1344 просмотров
schedule
17.12.2023
Воспроизведение нескольких файлов маршрутов Framework 2.2.x
Я прочитал Play! Для раздела книги Scala о модулях, и я не могу понять, как импортировать маршруты из ссылочного модуля. Я настроил свой модуль как библиотечную зависимость в файле build.sbt и попытался импортировать маршрут в файл маршрутов...
3633 просмотров
schedule
26.10.2023
Перебрать два списка (разной длины) в обратном порядке в Scala
Каков наиболее эффективный способ перебора двух списков (разной длины) в обратном направлении в Scala.
Итак, для двух списков
List(a,b,c) and List(1,2)
пары были бы
(c,2) and (b,1)
Примечание. Я бы предпочел не делать реверс...
2828 просмотров
schedule
02.10.2023
Почему сопоставление ValueSet перечисления Scala не меняет тип значений?
Я обнаружил некоторое загадочное поведение в Scala ValueSet. С таким перечислением
object MyEnum extends Enumeration{
val V1 = new MyEnum
val V2 = new MyEnum
class MyEnum extends Val
implicit def convertValue(v: Value): MyEnum =...
920 просмотров
schedule
20.10.2023
Код выхода для проекта sbt
У меня есть проект, построенный с помощью sbt и актеров akka. Я запускаю его с помощью команды «sbt 'run $args'» и хочу, чтобы эта программа возвращала разные коды выхода в зависимости от некоторых условий. Для этих целей я использую...
4718 просмотров
schedule
18.12.2023
Разница между Actorref.tell и inbox.send в Akka
Итак, я начал изучать Akka и пробовать примеры в typesafe. Итак, приложение Hello Akka имеет следующий код:
import akka.actor.{ ActorRef, ActorSystem, Props, Actor, Inbox }
import scala.concurrent.duration._
case object Greet
case class...
3342 просмотров
schedule
18.10.2023
Поддерживают ли Play WebSockets обратное давление?
Мне нужно добавить прокси-сервер WebSocket-to-TCP в мое приложение Play 2.3, но, хотя исходящее TCP-соединение с использованием Akka I/O поддерживает обратное давление, я ничего не вижу для WebSocket. API на основе акторов явно не поддерживается, но...
564 просмотров
schedule
19.10.2023
Где находятся журналы Spark в EMR?
Я не могу найти журналы ошибок или сообщения от println вызовов в Scala при выполнении заданий на Spark в EMR .
Где я могу получить к ним доступ?
Я отправляю Spark job , написанный в Scala , в EMR , используя script-runner.jar с...
18210 просмотров
schedule
29.11.2023
Spark: разделить CSV с новыми строками в поле потока октетов
Я использую Scala для анализа файлов CSV. Некоторые из этих файлов имеют поля, которые не являются текстовыми данными, такими как изображения или потоки октетов. Я хотел бы использовать метод Apache Spark textFile() для разделения CSV на строки и...
560 просмотров
schedule
02.11.2023
Инкрементная компиляция SBT-web с файловыми зависимостями
Я пытаюсь написать плагин set-web, который компилирует файлы sass. Я придерживаюсь соглашения о том, что файлы с именами, начинающимися с «_», не компилируются напрямую, но их можно включать в другие файлы. Я попытался сделать это, используя...
97 просмотров
schedule
11.12.2023
Сохранение каждой операции складывания в списке
Подводя итог, используя складку, я использую:
val l = List(1, 2, 3)
val sum = l.fold(0) { (a, b) => a + b }
Как я могу записать результат каждой операции добавления в список? Итак, для вышеуказанного сохраняется следующее:...
47 просмотров
schedule
05.10.2023
Scala: проецирование отрицательных элементов в DenseMatrix на 0
В python, если я хочу установить отрицательные значения из матрицы A, я мог бы сделать:
A = np.max(A, 0)
Есть ли подобный метод в Scala? У меня есть матрица типа Breeze DenseMatrix.
39 просмотров
schedule
09.11.2023
Spark SQL: объем памяти кеш-памяти улучшается с помощью «упорядочить по»
У меня есть два сценария, в которых я 23 GB разделил parquet данные и читаю несколько columns & caching их заранее, чтобы впоследствии запустить серию последующих запросов.
Настройка :
Кластер: 12 узлов ЭМИ
Версия Spark: 1.6...
1154 просмотров
schedule
20.11.2023
Spark sql (1.4): получить текущую метку времени
Я знаю, что в Spark 1.5 и выше есть функция current_timestamp, но мы все еще на 1.4. Как добавить столбец в DataFrame, для которого задана «текущая временная метка»?
df.withColumn("date_inserted", ????)
1244 просмотров
schedule
20.11.2023
Как расширить сигнатуру типа Scala на подклассы?
Я определил трейт Super[A] с одним абстрактным методом и несколькими конкретными методами, многие из которых просто создают новый экземпляр объекта с некоторыми изменениями. Вот пример:
trait Super[A] { self =>
def abstractMethod: A...
141 просмотров
schedule
29.11.2023
Наследование одноименного метода от отличительных признаков
У меня есть трейт, который расширяет два других трейта с одинаковым именем для функции, но немного отличается внутри. Я хочу знать, как узнать, какая функция будет вызвана?
У меня есть черта B , у которой есть print() , и черта C , у которой...
317 просмотров
schedule
07.12.2023
Валидация Scala - Либо с правым уклоном
Наконец-то в Scala 2.12 появился параметр Either с правым смещением. Я слышал, что это можно использовать для проверки, но я не могу себе этого представить. Я не могу найти хороший пример. Может кто-нибудь объяснить мне, как эта монада может помочь...
987 просмотров
schedule
22.11.2023
Рассчитать максимальное количество наблюдений на группу
Я использую Spark 1.6.2 .
Мне нужно найти максимальное количество для каждой группы.
val myData = Seq(("aa1", "GROUP_A", "10"),("aa1","GROUP_A", "12"),("aa2","GROUP_A", "12"),("aa3", "GROUP_B", "14"),("aa3","GROUP_B",...
1248 просмотров
schedule
06.10.2023
