Flink * 转

at com.typesafe.config.impl.ResolveContext.resolve(ResolveContext.java:142) at com.typesafe.config.impl.SimpleConfigObject at com.typesafe.config.impl.ResolveContext.resolve(ResolveContext.java:142) at com.typesafe.config.impl.SimpleConfigObject at com.typesafe.config.impl.ResolveContext.resolve(ResolveContext.java:142) at com.typesafe.config.impl.ResolveContext.resolve :74) at com.typesafe.config.impl.SimpleConfig.resolve(SimpleConfig.java:64) at com.typesafe.config.impl.SimpleConfig.resolve at com.typesafe.config.impl.ConfigImpl$1.call(ConfigImpl.java:374) at com.typesafe.config.impl.ConfigImpl

JDK 工具类之 Collections 2

collection wrappers /** * Returns a dynamically typesafe view of the specified collection * *

Another use of dynamically typesafe views is debugging. Assuming a queue contains * no incorrectly typed elements prior to the time a dynamically typesafe Assuming a set contains * no incorrectly typed elements prior to the time a dynamically typesafe Assuming a list contains * no incorrectly typed elements prior to the time a dynamically typesafe

sbt网络问题解决方案

oschina: http://maven.oschina.net/content/groups/public/ jcenter: http://jcenter.bintray.com/ typesafe-ivy-releases : http://repo.typesafe.com/typesafe/ivy-releases/, [organization]/[module]/[revision]/[type]s/[artifact

kafka-manager(cmak)安装及使用

:/opt/kafka/cmak-3.0.0.5/lib/org.scalaz.scalaz-core_2.12-7.2.27.jar:/opt/kafka/cmak-3.0.0.5/lib/com.typesafe.play.play _2.12-2.5.19.jar:/opt/kafka/cmak-3.0.0.5/lib/com.typesafe.play.play-json_2.12-2.6.12.jar:/opt/kafka/cmak -1.1.jar:/opt/kafka/cmak-3.0.0.5/lib/com.typesafe.akka.akka-http-core_2.12-10.0.15.jar:/opt/kafka/cmak _2.12-2.5.19.jar:/opt/kafka/cmak-3.0.0.5/lib/com.typesafe.play.twirl-api_2.12-1.3.15.jar:/opt/kafka/cmak 0.5.0.jar:/opt/kafka/cmak-3.0.0.5/lib/org.slf4j.slf4j-api-1.7.28.jar:/opt/kafka/cmak-3.0.0.5/lib/com.typesafe.config

Delta Lake 学习笔记（一）

gcs-maven-central-mirror: https://maven-central.storage-download.googleapis.com/repos/central/data/ maven-central typesafe-ivy-releases : https://repo.typesafe.com/typesafe/ivy-releases/, [organization]/[module]/[revision]/[type]s/[artifact [ext] bintray-spark-packages: https://dl.bintray.com/spark-packages/maven/ typesafe-releases: http ://repo.typesafe.com/typesafe/releases/ 看到了吧，里面有有些仓库如果你不熟悉 sbt，你可能根本没听过，这里我建议加一个阿里云的仓库，这样等下用 IDEA 的 sbt

akka-grpc - 基于akka-http和akka-streams的scala gRPC开发工具

" %% "akka-actor-typed" % AkkaVersion, "com.typesafe.akka" %% "akka-stream" % AkkaVersion, "com.typesafe.akka" %% "akka-discovery" % AkkaVersion, "com.typesafe.akka" %% "akka-cluster-sharding-typed " % AkkaVersion, "com.typesafe.akka" %% "akka-persistence-typed" % AkkaVersion, "com.typesafe.akka " %% "akka-persistence-query" % AkkaVersion, "com.typesafe.akka" %% "akka-serialization-jackson , "com.typesafe.akka" %% "akka-http" % AkkaHttpVersion, "com.typesafe.akka" %% "akka-http-spray-json

spark开发环境详细教程2：window下sbt库的设置

Nexus osc thirdparty : http://maven.oschina.net/content/repositories/thirdparty/ maven-central typesafe-ivy-releases : https://repo.typesafe.com/typesafe/ivy-releases/, [organization]/[module]/[revision]/[type]s/[artifact

Akka（11）： 分布式运算：集群-均衡负载

._ import com.typesafe.config.ConfigFactory object CalcFuctions { def propsFuncs = Props(new CalcFuctions " %% "akka-actor" % akkaVersion, "com.typesafe.akka" %% "akka-cluster" % akkaVersion " %% "akka-actor" % akkaVersion, "com.typesafe.akka" %% "akka-remote" % akkaVersion, "com.typesafe.akka " %% "akka-cluster" % akkaVersion, "com.typesafe.akka" %% "akka-cluster-metrics" % akkaVersion, " com.typesafe.akka" %% "akka-cluster-tools" % akkaVersion, "com.typesafe.akka" %% "akka-multi-node-testkit

centos 安装sbt

repositories vim repositories [repositories]   local   osc: http://maven.oschina.net/content/groups/public/   typesafe : http://repo.typesafe.com/typesafe/ivy-releases/, [organization]/[module]/(scala_[scalaVersion]/)(sbt

kka-typed(5) - cluster：集群节点状态监视

AkkaVersion = "2.6.5" val AkkaPersistenceCassandraVersion = "1.0.0" libraryDependencies ++= Seq( "com.typesafe.akka " %% "akka-cluster-sharding-typed" % AkkaVersion, "com.typesafe.akka" %% "akka-persistence-typed" % AkkaVersion, "com.typesafe.akka" %% "akka-persistence-query" % AkkaVersion, "com.typesafe.akka" %% "akka-serialization-jackson" % AkkaVersion, "com.typesafe.akka" %% "akka-persistence-cassandra" % AkkaPersistenceCassandraVersion, "com.typesafe.akka" %% "akka-slf4j" % AkkaVersion, "ch.qos.logback

Akka（13）： 分布式运算：Cluster-Sharding-运算的集群分片

._ import com.typesafe.config.ConfigFactory import akka.util.Timeout import scala.concurrent.duration at "http://repo.akka.io/snapshots/" val akkaversion = "2.4.8" libraryDependencies ++= Seq( "com.typesafe.akka " %% "akka-actor" % akkaversion, "com.typesafe.akka" %% "akka-remote" % akkaversion, "com.typesafe.akka " %% "akka-cluster" % akkaversion, "com.typesafe.akka" %% "akka-cluster-tools" % akkaversion, "com.typesafe.akka " %% "akka-cluster-sharding" % akkaversion, "com.typesafe.akka" %% "akka-persistence" % "2.4.8",

ScalaPB（1）： using protobuf in akka

in file(".")) .settings(commonSettings) .settings( libraryDependencies ++= Seq( "com.typesafe.akka file("remote")) .settings(commonSettings) .settings( libraryDependencies ++= Seq( "com.typesafe.akka 现在我们先在remote项目里定义一个Calculator actor： package akka.protobuf.calculator import akka.actor._ import com.typesafe.config.ConfigFactory in file(".")) .settings(commonSettings) .settings( libraryDependencies ++= Seq( "com.typesafe.akka file("remote")) .settings(commonSettings) .settings( libraryDependencies ++= Seq( "com.typesafe.akka

Akka（12）： 分布式运算：Cluster-Singleton-让运算在集群节点中自动转移

at "http://repo.akka.io/snapshots/" val akkaversion = "2.4.8" libraryDependencies ++= Seq( "com.typesafe.akka " %% "akka-actor" % akkaversion, "com.typesafe.akka" %% "akka-remote" % akkaversion, "com.typesafe.akka " %% "akka-cluster" % akkaversion, "com.typesafe.akka" %% "akka-cluster-tools" % akkaversion, "com.typesafe.akka " %% "akka-cluster-sharding" % akkaversion, "com.typesafe.akka" %% "akka-persistence" % "2.4.8", "com.typesafe.akka" %% "akka-contrib" % akkaversion, "org.iq80.leveldb" % "leveldb" % "0.7", "org.fusesource.leveldbjni

Akka-CQRS（10）- gRPC on SSL/TLS 安全连接

" % "0.14.9") addSbtPlugin("net.virtual-void" % "sbt-dependency-graph" % "0.9.2") addSbtPlugin("com.typesafe.sbt scalacOptions += "-Ypartial-unification" val akkaversion = "2.5.23" libraryDependencies := Seq( "com.typesafe.akka " %% "akka-cluster-metrics" % akkaversion, "com.typesafe.akka" %% "akka-cluster-sharding" % akkaversion , "com.typesafe.akka" %% "akka-persistence" % akkaversion, "com.lightbend.akka" %% "akka-stream-alpakka-cassandra " %% "akka-persistence-query" % akkaversion, "com.typesafe.akka" %% "akka-persistence-cassandra" %

Scala Akka通信实现：模拟相声《你要折腾》

org.scala-lang scala-library 2.11.12 com.typesafe.akka akka-actor_2.11 2.4.17 com.typesafe.akka

各种OOM代码样例及解决方法

/akka/akka-actor_2.11/2.4.20/akka-actor_2.11-2.4.20.jar:/Users/huangqingshi/.m2/repository/com/typesafe /akka/akka-actor_2.11/2.4.20/akka-actor_2.11-2.4.20.jar:/Users/huangqingshi/.m2/repository/com/typesafe /akka/akka-actor_2.11/2.4.20/akka-actor_2.11-2.4.20.jar:/Users/huangqingshi/.m2/repository/com/typesafe /akka/akka-actor_2.11/2.4.20/akka-actor_2.11-2.4.20.jar:/Users/huangqingshi/.m2/repository/com/typesafe /akka/akka-actor_2.11/2.4.20/akka-actor_2.11-2.4.20.jar:/Users/huangqingshi/.m2/repository/com/typesafe

Akka 指南 之「第 2 部分: 创建第一个 Actor」

-- Maven --> <dependency> <groupId>com.typesafe.akka</groupId> <artifactId>akka-actor_2.11</artifactId -- Gradle --> dependencies { compile group: 'com.typesafe.akka', name: 'akka-actor_2.11', version: -- sbt --> libraryDependencies += "com.typesafe.akka" %% "akka-actor" % "2.5.19" 简介 随着对 Actor 层次结构和行为的理解

突破性能瓶颈：Scala爬虫的大规模数据处理方案

akkaVersion = "2.6.19"val akkaHttpVersion = "10.2.9"​libraryDependencies ++= Seq( // Akka Actor "com.typesafe.akka " %% "akka-actor-typed" % akkaVersion, "com.typesafe.akka" %% "akka-stream" % akkaVersion, // Akka HTTP "com.typesafe.akka" %% "akka-http" % akkaHttpVersion, "com.typesafe.akka" %% "akka-http-spray-json logback-classic" % "1.2.11", // 数据库存储 (SQLite) "org.xerial" % "sqlite-jdbc" % "3.36.0.3", "com.typesafe.slick " %% "slick" % "3.3.3", "com.typesafe.slick" %% "slick-hikaricp" % "3.3.3")实现代码1.

akka-typed(3) - PersistentActor has EventSourcedBehavior

AkkaVersion = "2.6.5" val AkkaPersistenceCassandraVersion = "1.0.0" libraryDependencies ++= Seq( "com.typesafe.akka " %% "akka-cluster-sharding-typed" % AkkaVersion, "com.typesafe.akka" %% "akka-persistence-typed" % AkkaVersion, "com.typesafe.akka" %% "akka-persistence-query" % AkkaVersion, "com.typesafe.akka" %% "akka-serialization-jackson" % AkkaVersion, "com.typesafe.akka" %% "akka-persistence-cassandra" % AkkaPersistenceCassandraVersion, "com.typesafe.akka" %% "akka-slf4j" % AkkaVersion, "ch.qos.logback

【Dr.Elephant中文文档-3】快速安装说明

下载activatorzip 包https://downloads.typesafe.com/typesafe-activator/1.3.12/typesafe-activator-1.3.12.zip