scala

Я видел много примеров ARM (автоматическое управление ресурсами) в интернете для Scala. Кажется, это обряд посвящения, чтобы написать один, хотя большинство из них очень похожи друг на друга. Я сделал см. довольно крутой пример использования продолжений. во всяком случае, многие из этого кода имеют недостатк...

Я начал использовать Spark SQL и DataFrames в Spark 1.4.0. Я хочу определить пользовательский разделитель на фреймах данных, в Scala, но не вижу, как это сделать. одна из таблиц данных, с которыми я работаю, содержит список транзакций, по счету, silimar в следующем примере. Account Date Type ...

я выхожу из шкафа на этом! Я не понимаю SBT. - Ну вот, - сказал я, - теперь помоги мне, пожалуйста. все дороги ведут в Рим, и это то же самое для SBT: чтобы начать работу с SBT здесь SBT,SBT Launcher,SBT-extras и т. д., а затем существуют различные способы включения и принятия решения о репозиториях. есть ли...

в чем разница между РДД этоmap и mapPartitions способ? И делает flatMap ведут себя как map или как mapPartitions? Спасибо. (редактировать) т. е. в чем разница (семантически или с точки зрения исполнения) между def map[A, B](rdd: RDD[A], fn: (A => B)) (implicit a: Manifest[A], b: Manifest...

У меня есть несколько больших (более 3 полей) объектов, которые могут и должны быть неизменными. Каждый раз, когда я сталкиваюсь с этим случаем, я склонен создавать конструкторские мерзости с длинными списками параметров. Это не кажется правильным, трудно использовать и читаемость страдает. это еще хуже, есл...

возьмите следующую функцию: def fMatch(s: String) = { s match { case "a" => println("It was a") case _ => println("It was something else") } } этот шаблон хорошо сочетается: scala> fMatch("a") It was a scala> fMatch("b") It was something else то, что я хотел бы сдел...

как я могу конвертировать RDD (org.apache.spark.rdd.RDD[org.apache.spark.sql.Row]) к фрейму данных org.apache.spark.sql.DataFrame. Я преобразовал фрейм данных в rdd с помощью .rdd. После обработки я хочу, чтобы он вернулся в dataframe. Как я могу это сделать ?...

У меня есть удобная функция, которую я использовал в Java для преобразования InputStream в строку. Вот прямой перевод на Scala: def inputStreamToString(is: InputStream) = { val rd: BufferedReader = new BufferedReader(new InputStreamReader(is, "UTF-8")) val builder = new StringBuilder() tr...

я раньше так думал private val и private final val такие же, пока я не увидел раздел 4.1 в Scala ссылка: определение постоянного значения имеет вид final val x = e где e-постоянное выражение (§6.24). Окончательный модификатор должен присутствовать, и никакая аннотация типа не может быть дана. Ссылк...

Я обычно заканчиваю тем, что пробую каждую комбинацию, пока она не компилируется. Может кто-нибудь объяснить, что я должен использовать где?...