《scala》专题
-
使用Scala创建一个简单的Kafka消费者
我目前正在学习Scala 消费者应能够处理以下任务： 跟踪偏移量 找出哪个代理是主题和分区的主代理。 必须能够处理代理领导变更 我找到了一个非常好的文档，用Java创建这个消费者(https://cwiki.apache.org/confluence/display/KAFKA/0.8.0SimpleConsumer示例）。 有没有人有一个创建这个simpleconsumer的示例Scala代码，
-
Scala与Spring：构造函数自组织
-
scalamock newexpectationexception-[scala,scalamock,Akka-HTTP]
我在和斯卡拉莫克玩。当我试图使用ScalaMock来模拟一个测试用例中的对象时，我编写了一个KISS版本的错误。 应为：inAnyOrder{inAnyOrder{MetricsRegistry.RecordValue(*)两次（从未调用-未满足）}} 实际：ScalatestFailureLocation：ScalaMockError01Spec在（ScalaMockError01Spec.Sc
-
Scala单元测试中的ExceptionInInitializerError（Scalacheck,Scalatest）
我参考DataframeGenerator示例编写了单元测试，该示例允许您动态生成模拟dataframes 在成功执行以下命令后 在运行以下命令之一时，我会得到输出中显示的错误 输出 null null EDIT-1 My unit-test类包含以下几个方法 而如下所示
-
Scala中DSE Cassandra的Spark SQL查询
我想在Scala IDE中测试DSE Cassandra表上的Spark-SQL查询。当在dse spark-submit中执行jar文件时，查询将完美无缺地运行。但在Scala IDE中运行时会出现错误。错误是, 我想是spark主机配置错误，因为我在本地模式下运行主机。 这是我发起的星火会议。 但我不知道该把什么地址设为主人。我尝试将主地址设置为“spark://127.0.0.1:7077”
-
无法构建scala程序“SBT Package”失败，线程“main”java.sql.sqlexeption：没有合适的驱动程序
我使用IntelliJ（sbt项目）创建了以下测试Scala程序。 但是，出现以下错误。我已经从微软网站下载了MS Sql server驱动程序()。如何在sbt项目中设置jar引用？
-
ClassNotFoundException火花-提交scala
嗨，我正在尝试生成Salt示例的输出，但没有使用文档中提到的docker。我找到了帮助生成输出的scala代码，这是main.scala。我将main.scala修改为一个方便的main.scala, 我为这个scala创建了一个单独的文件夹, calac-cp“lib/salt.jar：lib/spark.jar”main.scala 这已成功运行并在文件夹BinexTest下生成类。 现在,项
-
使用scala将转换后的列追加到spark数据帧
我正在尝试访问配置单元表，并从表/数据帧中提取和转换某些列，然后将这些新列放入新的数据帧中。我试着用这种方式- 它使用SBT构建时没有任何错误。但当我尝试运行它时，我收到以下错误- 我想了解是什么导致了这个错误，如果有任何其他的方法来完成我正在尝试做的事情。
-
关于Java和Scala中的泛型
我被泛型子类型搞糊涂了。 在Java中，如果类型是的子类型，则泛型类型和是不变的。例如，不是的子类型。 但是，在Scala中，如果类型是的子类型，则泛型类型和是协变的。那么Scala中泛型类的属性是什么而Java中没有呢？
-
Scala：创建迫使类重新实现某些方法的特性
我试图实现一个特性，强制每个扩展它的类（不是抽象的）实现某些方法（即使它们已经存在于超类中）。具体来说，它应该是这样的： 这就是它的特点，也是它的实现： 上述代码在理想情况下不应编译（因为可调试类不实现所需的方法）。实际上，这不仅会编译，而且不会抛出运行时异常（它只接受对象类的默认实现）。 到目前为止，没有任何东西能够产生预期的行为。我认为宏可能会有所帮助，但我不确定宏是否可以表达以下内容： 我知
-
Scala自定义不适用于泛型
我想通过一个自定义的泛型unapply函数压缩我的计算器，该函数计算参数并在成功时返回值。 但是这失败了，错误 有什么方法可以实现这一点吗？我已经研究了类型标签，不适用方法的隐式转换，但我不知道如何将它们集成到这个问题中。如何正确定义Eval？
-
Guice可以注入Scala对象吗
在Scala中，我可以使用Guice注入Scalas吗？ 例如，我可以在以下对象中注入？
-
将json提取到案例类SCALA FLINK时出错
问题在于在进行案例类提取时映射函数中。case类不可序列化。我隐式地定义了格式。 错误是： INFO[main]（TypeExtractor.java:1804）-未检测到类组织的字段。json4s。JsonAST$JValue。不能用作PojoType。将作为线程“main”组织中的GenericType异常处理。阿帕奇。Flink。应用程序编程接口。常见的InvalidProgrameExce
-
Pig：无法打开别名AliasName的迭代器。Scalar在输出中有多行
我对猪是个新手，正在尝试自己学习。 我已经编写了一个脚本，用一个从words.txt文件中读取的单词获取纪元时间。 这是剧本。 但问题是，如果words.txt文件只有一个单词，它就会给出正确的输出。 如果它有多个单词，如 则会给出以下错误 谢谢你。
-
IntelliJIDEA中的Scala控制台既不存取输入也不打印输出，comand从temrinal工作
我在IntelliJIDEA中有一个“Scala/Simple module with attached Scala SDK”类型的项目，通过它我可以轻松地构建和设置几个应用程序配置。Scala工作区也可以正常工作，但是当我尝试创建和运行Scala控制台配置时，终端出现了，Scala Repl似乎运行得很好，因为它给我提供了欢迎使用Scala消息，并打印一个初始的“Scala>”。然而，尽管自动完