• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

标签:scala

scala

如何在部分函数中使用一个常量整数作为输入?

如何在部分函数中使用一个常量整数作为输入?
我新的阶,我其中我要定义一个局部函数来添加三个数字,其中一个数量是恒定的和两个 数字可以作为输入被传递,并定义可采取局部 的另一种方法的使用情况作为输入并给出其立方体作为结果。如何在部分函数中使用一个常量整数作为输入? ===========解决方案如下: 下面的部分功能将12345对每个号码传递给它 scala> val addConstantT……继续阅读 »

scala

使用Flink和基于事件时间的流计算平均值

使用Flink和基于事件时间的流计算平均值
我想在基于历史事件的流中计算Flink中基于窗口的平均值(或由我定义的任何其他函数),因此流必须是事件时间(不处理基于时间):使用Flink和基于事件时间的流计算平均值 val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment env.s……继续阅读 »

scala

akka +使用sbt程序集播放依赖项问题

akka +使用sbt程序集播放依赖项问题
我正在使用sbt程序集尝试使用我们的应用程序并创建“一个大罐子”来部署它。akka +使用sbt程序集播放依赖项问题 我有一个问题,其中Play 2.1.2取决于scala-stm 0.6和akka-transactor 2.1.4取决于scala-stm 0.7。 我能够在SBT运行的应用程序没有问题(以及Eclipse的和IntelliJ) 我不清楚如何……继续阅读 »

scala

用sbt和IntelliJ IDEA管理依赖关系

用sbt和IntelliJ IDEA管理依赖关系
我正在开发一个后端项目,第一次使用IntelliJ IDEA的Scala和Play Framework。用sbt和IntelliJ IDEA管理依赖关系 我已经读了很多文件和主题: SBT Library dependencies doc IntelliJ support post Another post从计算器 我不明白如何导入依赖关系。 当我尝试附……继续阅读 »

scala

通过SBT进行Docker化Scala应用程序的Marathon Healthcheck

通过SBT进行Docker化Scala应用程序的Marathon Healthcheck
我正在使用Marathon和Mesos。我的应用程序基于Scala,我正在使用SBT docker插件来dockerize应用程序并部署到Marathon。应用程序是异步的(基于队列),并且不通过HTTP调用。如何为异步应用程序执行健康检查,并且可以在此处利用SBT Scalatest。该应用程序是dockerized的,所以我们如何在dockerized应……继续阅读 »

scala

什么时候合并发生在用户定义的聚合函数中Spark中的UDAF

什么时候合并发生在用户定义的聚合函数中Spark中的UDAF
我想知道Spark将在哪些情况下作为UDAF函数的一部分执行合并。什么时候合并发生在用户定义的聚合函数中Spark中的UDAF 动机: 我在Spark项目的窗口中使用了很多UDAF函数。我经常想回答这样一个问题: 信用卡交易在同一个国家与30天窗口中的当前交易进行了多少次? 该窗口将从当前事务开始,但不会将其包括在计数中。它需要通过当前交易的价值来了解过去3……继续阅读 »