我的目标是在一个数据集上运行多个spark ml回归模型(1000次)，我想使用zio而不是future来实现这一点，因为它运行得太慢了。下面是使用Future的工作示例。import scala.concurrent.{Executors, TimeUnit}import org.apache.spark.sql.SaveMode
import zio.
浏览 13提问于2020-04-28得票数 1
回答已采纳
1回答
我使用ZIO的第一步是尝试将这个readfile函数转换为兼容的ZIO版本。 _ <- putStrLn(s"Hello, ${name}, welcome to ZIO!")} yield ()
val source = scala</
浏览 0提问于2021-03-19得票数 1
我刚刚开始研究ZIO，试图改进我的Scala。首先，我尝试更新我的一些旧代码。我已经包装了一些遗留代码，这些代码返回一个以选项包装的配置，并将其转换为ZIO，然后用于理解。Id(1612612180323,1) was supposed to continue to: a future continuation at zio.ZIO.exitCo
浏览 2提问于2021-02-06得票数 1
回答已采纳
有没有人有一个基本的zio-grpc服务器，在这个项目中也有codegen，与Scala 3一起工作？Scala 3可以使用2.13库，所以这就是我要做的。(在三个与zio-grpc相关的库中，一个是zio-grpc-codegen，它没有Scala 3版本，因此必须至少在该版本中使用2.13。)(gens.scala:11)错误模块在ProjectRef(uri("file:&
浏览 6提问于2022-01-10得票数 0
回答已采纳
我正在用zio在scala.js上试用示例应用程序[error] Referring to non-existent$anonfun$fixed$2(scala.Option,java.time.OffsetDateTime,long,java.time.Duration,long,scala.runtime.LazyRef,java.lang.Object)zio.ZIO
[erro
浏览 4提问于2020-11-29得票数 2
回答已采纳
我在Scala2.13/ Mill项目中使用。AccountObserver.Service[Any] trait Service[R] {
def processEvent(event: String): ZIO
浏览 6提问于2019-10-29得票数 0
1回答
import zio.console._import scala.util.Tryimport zio.clock._
myAppLogic.exitCode
sequential = Schedule.recurs(1
浏览 2提问于2021-04-04得票数 0
回答已采纳
2回答
.) : zio.IO[SomeException, SomeResult]run(someEither, data.getOrElse("empty如何将EitherT转换为zio.IO
浏览 4提问于2021-04-23得票数 0
我将Scala zio版本设置为1.0.12 in build.sbt但是，当我使用sbt运行应用程序时，它在2.x (屏幕)版本中下载了zio：
我不知道为什么其他zio与我使用的lib版本有关：val zio = "1.0.12"
val zioIntero
浏览 3提问于2022-05-31得票数 0
现在我想把它转换成ZIO。我创造了： ZIO.fromFuture {implicit ec =>
futureEitherMethod因此，在我将Trace作为隐式添加之后，它仍然不能正常工作。还有其他方法将Future[Either[,]]转换为ZIO吗？文档在本主题中不清楚。
浏览 7提问于2022-09-16得票数 1
这可能是一个愚蠢的问题，但从ZIO开始，我无法将Seq[ZIO]转换为ZIO[Seq]。keys: Seq[String], locales: Seq[Locale]):RIO[Translator, Seq[Translation]] = { service <- ZIO.environment[Translator] // service.translate produce a zio
浏览 2提问于2021-04-28得票数 3
回答已采纳
我有一个返回一些ZIO的方法：调用此返回Task[Unit]的方法 ZIO.effect(method(...))问题是，当我用ZIO.effect调用它时，我没有得到结果。如何将ZIO转换为Task以获得结果？
浏览 2提问于2021-05-13得票数 3
回答已采纳
1回答
我必须创建Scala库，它应该被划分为核心模块和包含其他特性的模块(比如zio核心和zio流)。我的想法是把他们放在单独的github回购，但在不同的子项目。我该怎么做？我必须单独发布这些模块吗？另外，我还不清楚库用户是否应该只包括“功能模块”，后者将临时包含核心模块。同样，这意味着在ZIO情况下，我只能包含zio流，并且我可以使用zio核心。
浏览 1提问于2022-01-19得票数 0
1回答
我正在读关于ZIO的文章，整个画面开始在我的脑海中浮现。编辑b) I应该为每个目标创建一个下载器，请求将被分配给他们。但是，我应该如何在代码中实现这一点呢？我想利用这个项目来推广ZIO内部。所以我想使用最好的选择和最干净的方
浏览 0提问于2019-12-02得票数 1
回答已采纳
我不是一个猫效果程序员，我刚刚开始学习ZIO。因此，我希望使用zio.ZStream来操作fs2流的数据。如何将StreamIO，Int转换为ZStream与猫互操作？import zio.stream.ZStream import cats.implicits._ import zio.interop.cat
浏览 7提问于2021-12-19得票数 0
2回答
我在IDEA (scala研讨会)中有下一个代码，import zio.(st)
f => {st: Seq[zio.Task[Int]] = List(zio.ZIO$EffectPartial@263c8b
浏览 14提问于2019-11-07得票数 2
1回答
从ZIO开始，我尝试将一个退出的应用程序转换为一个纯功能的应用程序。此应用程序依赖于Http和Frp客户端。它们都是通过配置文件和可选命令行参数配置的。val flow = for { configs <- ZIO.succeed(s"Config
浏览 0提问于2019-12-03得票数 1
回答已采纳
1回答
我有下面的代码： import zio._
_ <- IO.fail(AppError("app error")).when(result)} 但是这段代码不能编译，因为编译器说结果类型是： ZIO[Any, Throwable, Int] 如何从任务(我调用method)转换为IO
浏览 19提问于2020-07-12得票数 2
回答已采纳
采用来自的代码并将其更改为我想要实现的.import zio.duration._import zio.clock._ })import API._
object ScheduleApp extends scala.App我尝试将Schedule.recurUntil
浏览 5提问于2020-11-20得票数 1
回答已采纳
第一个使用Futures，另一个使用ZIO作为特效。Future作为结果效果：我还有其他一些使用ZIO[SomeEnv, SomeError, Data]的版本现在，我需要创建某种类型的适配器，它将从一个或另一个版本返回数据我不知道如何将ZIO转
浏览 0提问于2020-07-01得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
