搜索结果
查询Tags标签： val，共有 1421条记录-
FlinkCDC读取MySQL并写入Kafka案例(com.ververica)
该方法使用的是com.ververica版本的flink-connector-mysql-cdc，可以解决alibaba版本的以下两个问题： 1）可以有效避免锁表 2）当设置StartupOptions.latest()时做checkpoints可能出现的异常错误 因此不推荐使用alibaba的版本。需要注意点，依赖的POM文件如下，标记为粗体…
2022/1/20 2:20:48 人评论 次浏览 -
Kotlin 协程+Retrofit 最优雅的网络请求使用
1.简介 Retrofit对协程的支持非常的简陋。在kotlin中使用不符合kotlin的优雅 interface TestServer {@GET("banner/json")suspend fun banner(): ApiResponse<List<Banner>> }//实现并行捕获异常的网络请求fun oldBanner(){viewModelScope.launch {…
2022/1/19 23:25:46 人评论 次浏览 -
Kotlin 协程+Retrofit 最优雅的网络请求使用
1.简介 Retrofit对协程的支持非常的简陋。在kotlin中使用不符合kotlin的优雅 interface TestServer {@GET("banner/json")suspend fun banner(): ApiResponse<List<Banner>> }//实现并行捕获异常的网络请求fun oldBanner(){viewModelScope.launch {…
2022/1/19 23:25:46 人评论 次浏览 -
python---循环语句
1. while 循环 简单的while语句 i = 0 while i < 3:print(i)i += 1while循环嵌套i = 1 while i < 10:j = 1while j <= i:print(f{j} * {i} = {i*j}, end= )j += 1print()i += 1运行结果： 2. for循环 list_val = [1, 33, 55, 10] for item in list_val:print(it…
2022/1/19 17:21:32 人评论 次浏览 -
python---循环语句
1. while 循环 简单的while语句 i = 0 while i < 3:print(i)i += 1while循环嵌套i = 1 while i < 10:j = 1while j <= i:print(f{j} * {i} = {i*j}, end= )j += 1print()i += 1运行结果： 2. for循环 list_val = [1, 33, 55, 10] for item in list_val:print(it…
2022/1/19 17:21:32 人评论 次浏览 -
Scala 可变数组ArrayBuffer
1 package chapter072 3 import scala.collection.mutable4 import scala.collection.mutable.ArrayBuffer5 6 object Test02_ArrayBuffer {7 def main(args: Array[String]): Unit = {8 // 1. 创建可变数组9 val arr1: ArrayBuffer[Int] = new ArrayBuffer[Int…
2022/1/18 23:40:53 人评论 次浏览 -
Scala 可变数组ArrayBuffer
1 package chapter072 3 import scala.collection.mutable4 import scala.collection.mutable.ArrayBuffer5 6 object Test02_ArrayBuffer {7 def main(args: Array[String]): Unit = {8 // 1. 创建可变数组9 val arr1: ArrayBuffer[Int] = new ArrayBuffer[Int…
2022/1/18 23:40:53 人评论 次浏览 -
寒假学习进度
今天学习spark的一些行动算子和序列化 （1）行动算子 def main(args: Array[String]): Unit = {val sparkConf = new SparkConf().setMaster("local[*]").setAppName("Operator")val sc = new SparkContext(sparkConf)val rdd = sc.makeRDD(List((&qu…
2022/1/18 23:38:30 人评论 次浏览 -
寒假学习进度
今天学习spark的一些行动算子和序列化 （1）行动算子 def main(args: Array[String]): Unit = {val sparkConf = new SparkConf().setMaster("local[*]").setAppName("Operator")val sc = new SparkContext(sparkConf)val rdd = sc.makeRDD(List((&qu…
2022/1/18 23:38:30 人评论 次浏览 -
使用 Kotlin API 实践 WorkManager，掌握这个提升路径
如果您的即时任务可以在用户脱离某个作用域时结束，比如切换到其它界面，我们建议您还是直接使用 Kotlin 协程。 在这个 WorkManager codelab 教程中，我们会对图片进行模糊化处理，并且将处理后的数据存储在磁盘上。我们看一下这个过程中需要哪些操作。 添加 work-runtim…
2022/1/18 23:34:26 人评论 次浏览 -
使用 Kotlin API 实践 WorkManager，掌握这个提升路径
如果您的即时任务可以在用户脱离某个作用域时结束，比如切换到其它界面，我们建议您还是直接使用 Kotlin 协程。 在这个 WorkManager codelab 教程中，我们会对图片进行模糊化处理，并且将处理后的数据存储在磁盘上。我们看一下这个过程中需要哪些操作。 添加 work-runtim…
2022/1/18 23:34:26 人评论 次浏览 -
Mongodb常见用法
// 获取数据库连接 // val url = MongoClientURI("mongodb://192.168.56.160:27017/") // val mc = MongoClient(url)val mc = MongoClient("192.168.56.160", 27017)val db = mc("mydemo") // 加载数据库val tab = db("userinf…
2022/1/17 19:08:59 人评论 次浏览 -
Mongodb常见用法
// 获取数据库连接 // val url = MongoClientURI("mongodb://192.168.56.160:27017/") // val mc = MongoClient(url)val mc = MongoClient("192.168.56.160", 27017)val db = mc("mydemo") // 加载数据库val tab = db("userinf…
2022/1/17 19:08:59 人评论 次浏览 -
关于原型和原生API
关于原型和原生API 知识o.name = huahua // 此为写操作 o.name // 此为读操作修改对象的原型不推荐 对象.__proto__ = 别的对象 平静且优雅且推荐 Object.setPrototypeOf(对象, 新的原型对象)对一个对象添加属性 defineProperty 配置一个属性 let emp = {} Object.defineP…
2022/1/17 6:06:28 人评论 次浏览 -
关于原型和原生API
关于原型和原生API 知识o.name = huahua // 此为写操作 o.name // 此为读操作修改对象的原型不推荐 对象.__proto__ = 别的对象 平静且优雅且推荐 Object.setPrototypeOf(对象, 新的原型对象)对一个对象添加属性 defineProperty 配置一个属性 let emp = {} Object.defineP…
2022/1/17 6:06:28 人评论 次浏览
