搜索结果
查询Tags标签： val，共有 1421条记录-
spark streaming整合kafka中聚合类运算如何和kafka保持exactly once一致性语义（redis方式，利用pipeline）
/*** 从Kafka读取数据，实现ExactlyOnce，偏移量保存到Redis中* 1.将聚合好的数据，收集到Driver端，* 2.然后将计算好的数据和偏移量在一个pipeline中同时保存到Redis中* 3.成功了提交事物* 4.失败了废弃原来的数据并让这个任务重启*/ object ExactlyOnceWordCountOffset…
2022/4/6 2:19:25 人评论 次浏览 -
spark streaming整合kafka中聚合类运算如何和kafka保持exactly once一致性语义（mysql方式，利用事务）
/*** 从Kafka读取数据，实现ExactlyOnce，偏移量保存到MySQL中* 1.将聚合好的数据，收集到Driver端，* 2.然后建计算好的数据和偏移量在一个事物中同时保存到MySQL中* 3.成功了提交事物* 4.失败了让这个任务重启** MySQL数据库中有两张表：保存计算好的结果、保存偏移量*/…
2022/4/6 2:19:24 人评论 次浏览 -
Android Notification使用
一 Android的Notification Notification是用来通知、提示用户的一种机制.起到提示用户的作用.二 Notification的类别 1.状态栏和抽屉式通知//获取NotificationManager对象val notificationManager = getSystemService(NOTIFICATION_SERVICE) as NotificationManagerval in…
2022/4/3 23:22:06 人评论 次浏览 -
Jetpak-Room数据库
使用Room将数据保存到本地数据库 简介 Room持久库在SQLite之上提供了一个抽象层，以便在充分利用SQLite的强大功能的同时，能够流畅的访问数据库，具体来说，Room有以下优点：SQL查询的编译时验证 提供方便的注解，能最大减少重复和易错的样板代码 简化了数据库迁移路径因…
2022/4/3 2:19:37 人评论 次浏览 -
第五章_Spark核心编程_Rdd_任务拆分(Application&Job&Stage&Task)
1.说明/** RDD 任务切分中间分为:Application、Job、Stage 和 TaskApplication:初始化一个SparkContext即生成一个Application;new SparkConf().setMaster("local").setAppName("distinctTest")Job:一个Action算子就会生成一个Job每触发一个Action算子…
2022/4/2 9:19:32 人评论 次浏览 -
第五章_Spark核心编程_Rdd_闭包检测&对象序列化
1. 说明/*闭包检查*//** 1. Scala的闭包* 如果一个函数,访问了它外部的(局部)变量的值,那么这个函数和所处的环境,称之为闭包* 使用场景 :* 在嵌套函数中,内层函数可以 只用外层函数的任意变量** 2. Spark的闭包* 1. 算子之外的代码都是在Driver端执行…
2022/4/1 9:19:25 人评论 次浏览 -
P3467 贴海报
传送门 纯单调栈结构。海报的最大数量为建筑个数，而如果在一个峰/等高的两侧有两个高度相等的建筑则答案减一。用单调栈维护一个不降序列，若进栈元素小于栈顶元素，则不断弹出栈顶，元素入栈后若栈顶与次栈顶相等则答案减一。#include<iostream> #include<algo…
2022/3/30 23:20:12 人评论 次浏览 -
20_100. 相同的树
*题目描述：解题思路：深度优先搜索：同时遍历这两颗树，比对节点值是否一致，然后比对其左右节点是否相同 广度优先搜索：也是同时遍历，使用两个队列存储入队的节点，及时返回错误情况，最后跳出循环时，一定要注意，可能两棵树本身节点数量并不相同。代码：深度优先搜索…
2022/3/30 6:22:20 人评论 次浏览 -
基于react实现输入框数据双向绑定实现 函数组件hook
一、当需要实现函数组件的双向绑定时无非就是实现手动将事件对象加值变量 1.useState + value + onChange事件对象 =>输入框双想绑定const Input=()=>{const [message,setMessage] = useState();return(<><inputvalue={message}type="text"onCh…
2022/3/28 23:56:05 人评论 次浏览 -
113. 路径总和 II
✅做题思路or感想：也是遍历一遍二叉树，判断路径总和和是否是叶子节点，要注意的是这里还需要加一个vector来记录路径class Solution { public:vector<vector<int>>result;void dfs(TreeNode* cur, vector<int>vec, int sum) {//判断条件if (sum == 0 …
2022/3/28 23:54:33 人评论 次浏览 -
剑指 Offer 54. 二叉搜索树的第k大节点
一、题目 二、题目理解1.因为是二叉树搜索树（二叉树排序树），所以可以用中序遍历，先右 中 后左 进行（右边最大的）2.每次dfs的时候 记录一次，当记录数等于 k 的时候，当前值就是最大k节点3.如果进行右边的时候，没有达到最大k节点，我们继续向左边的子节点进行查找，…
2022/3/28 23:53:23 人评论 次浏览 -
Codeforces600E Lomsat gelral
Codeforces600E Lomsat gelral 题目链接 点我跳转 题目大意 一棵树，1号节点为根，每个结点都有一个颜色，第i个节点的颜色为ci。 如果一种颜色在以x为根的子树内出现次数最多（可以不唯一），称其在以x为根的子树中占主导地位。 你的任务是对于每一个i∈[1,n]，求出以i为…
2022/3/28 23:25:25 人评论 次浏览 -
206. 反转链表
206. 反转链表 给你单链表的头节点 head ，请你反转链表，并返回反转后的链表。 示例 1：输入：head = [1,2,3,4,5] 输出：[5,4,3,2,1]示例 2：输入：head = [1,2] 输出：[2,1]示例 3： 输入：head = [] 输出：[] 提示：链表中节点的数目范围是 [0, 5000] -5000 <= N…
2022/3/28 6:24:49 人评论 次浏览 -
BM4 合并两个排序的链表
function ListNode(x){this.val = x;this.next = null; } function Merge(pHead1, pHead2) {// write code herelet cur = new ListNode()let dummy = curwhile(pHead1 && pHead2){if(pHead1.val <= pHead2.val) {cur.next = pHead1pHead1 = pHead1.next} else…
2022/3/27 23:24:56 人评论 次浏览 -
第五章_Spark核心编程_Rdd_行动算子_take
1.定义/* * 1.定义 * def take(num: Int): Array[T] * 2.功能 * 返回一个由 RDD 的前 n 个元素组成的数组 * * */2.示例object takeTest extends App {val sparkconf: SparkConf = new SparkConf().setMaster("local").setAppName("distinctTest&q…
2022/3/27 20:23:05 人评论 次浏览
