akka-typed - EventSourcedBehavior in action

As mentioned earlier, the more important change in akka typed is the addition of EventSourcedBehavior. That is to say, an actor dedicated to EventSource mode is added, and eventually CQRS can be perfectly implemented together with other kinds of actors. The new actor, which I still call persistent actor, is a kind of actor that can maintain and ...

Posted on Fri, 05 Jun 2020 22:01:29 -0700 by candy2126

The problem of Kafka service unavailable (down)

background An online log collection service alarms and opens the domain name to report the 502 error code. The collection service consists of two netty HA servers. The netty server parses the protobuf logs delivered by the client and sends them to kafka, opens the logs of one of the applications, and finds the following errors: org.apache.kaf ...

Posted on Thu, 07 May 2020 00:08:26 -0700 by JonathanS

Alink ramble: different realization of KMeans algorithm and alink design idea

Talk about Alink (1): look at Alink design ideas from the different implementation of KMeans algorithm Catalog Talk about Alink (1): look at Alink design ideas from the different implementation of KMeans algorithm 0x00 summary 0x01 what is Flink 0x02 what is alink 0x03 Alink design idea 1. Starting f ...

Posted on Wed, 06 May 2020 01:33:44 -0700 by geo115fr

ubuntu installation configuration sbt

Environmental Science: ubuntu 16.04 lts sbt 0.13.15 sbt-0.13.X Download Official website address: http://www.scala-sbt.org/download.html  Baidu online: link: https://pan.baidu.com/s/1o886Uls Password: kqh7 Extract the compressed package to the directory / usr/local / tar -zxvf sbt-0.13.15.tgz -C /usr/local/sbt Create sbt file in ...

Posted on Sat, 02 May 2020 23:34:07 -0700 by jmurch

The function and difference of attribute modifier in the main construction method of Scala class

As we all know, Scala runs on the Java platform (Java virtual machine). After the scala program is compiled, the corresponding bytecode file will be generated. We decompile the bytecode file into a java file to know what Scala has done for us Scala source code class Test4(a: String) class Test5(val b: String, var c: String) class Test6( ...

Posted on Sat, 02 May 2020 15:10:20 -0700 by GooberDLX

Search elastic4s search query mode

The previous article mentioned that query mode not only filters the records, but also scores the records that meet the conditions, that is, the similarity matching degree with the conditions. We'll discuss ratings in the blog post that follows, and we'll only cover query queries in this article. Query can be divided into absolute value query an ...

Posted on Mon, 27 Apr 2020 18:47:37 -0700 by gargoylemusic

An article will take you to write HelloWorld in 10 languages

0, programming language Leaderboard There are many computer programming languages. There are more than 600 programming languages in the world, but there are dozens of popular ones. Let's take a look at programming language leaderboards. Here are two languages. Ⅰ TIOBE index The index is updated monthly and it monitors Nearly 300 languages Chan ...

Posted on Fri, 17 Apr 2020 19:03:01 -0700 by LiamProductions

search- elasticsearch scala terminal: elastic4s

The previous article said that elastic search itself is a complete background system, and its operation is carried out through terminal api. elasticsearch itself provides APIs for a variety of programming languages, including java's esjava. elastic4s is a scala api based on esjava. First, let's look at the construction process of ElasticClient ...

Posted on Sat, 21 Mar 2020 07:37:19 -0700 by maskme

Flink's Data Types for busy people

1, Data Type composition in Flink Basic data type: basic data types in java 8 plus their respective packing types, plus void, string, date, BigDecimal, BigInteger Data of basic data type and array of Object type Composite type 1.Flink Java Tuples 2. scala case classes 3. Row 4. POJOs: if you want ...

Posted on Mon, 16 Mar 2020 07:32:17 -0700 by Misticx

Chapter 4 procedure flow control

1, If else... Sentence Example code: package com.lj.scala.main import scala.io.StdIn /** * @author Administrator * @create 2020-03-07 17:21 */ object IfTest { def main(args: Array[String]): Unit = { var i = 0 while (i < 7) { print("please enter name:&q ...

Posted on Sun, 08 Mar 2020 21:59:19 -0700 by ldoozer