logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

java中接口Consumer 的用法

接口是 Java 中非常实用的一个函数式接口,在处理需要对某个对象或值进行处理,但不需要返回结果的场景下特别有用。它可以和其它函数式接口一起使用,方便地实现复杂的业务逻辑。接口修改一个人物列表中每个人的姓名,将其转换成大写形式。注意,在这个示例代码中,我们将。方法只有一个参数,因此在这个示例代码中需要传递一个字符串类型的参数。接口是一个函数式接口,它接受一个输入参数,并且不返回任何结果。接口对象,

文章图片
#java#开发语言
当使用yarn管理我们的flink任务时,提交一个作业,yarn会帮我们启动一个task,还会起到job吗

这是一个很经典的问题。简单直接的答案是:会。当使用模式提交作业时,YARN 不仅仅会启动一个 Task(指容器,Container),而是会完整地管理整个 Flink 集群的生命周期——包括 JobManager 和 TaskManager 的启动。下面我将为你详细拆解这个“启动”过程,并澄清一些容易混淆的概念。首先需要区分两个关键角色:JobManager (JM):Flink 作业的“主节点”

文章图片
#java#flink
hadop和flink有什么关系,他们分别有什么作用

简单来说,Hadoop 和 Flink 是 Apache 基金会旗下为解决不同时代痛点而生的两个明星项目。:Hadoop 像一位皮实耐用的"老管家",负责稳定地存储海量数据和调度资源;而 Flink 更像一位反应敏捷的"特工",擅长对实时流动的数据进行毫秒级响应。

#flink#大数据
hadoop集群和flink集群需要所有服务器都部署吗

在生产环境中,Hadoop 集群和 Flink 客户端并不是每台服务器都要装一遍的,它们遵循的原则。

文章图片
#java#flink
介绍一下hadoop-yarn的工作流程

设计原则具体体现资源与计算分离RM只管资源,不关心计算逻辑调度与监控分离Scheduler只管分配,AM监控任务高可用性RM可HA,AM可重启,NM故障自动处理扩展性支持10000+节点,支持异构资源(GPU/FPGA)一句话总结:YARN 就像一个高效的"酒店前台"——RM是总台分配房间,AM是随行管家负责具体事务,NM是楼层服务员管理房间状态,Container就是被分配的具体房间。

文章图片
#hadoop#大数据#分布式
当使用yarn管理我们的flink任务时,提交一个作业。YARN 实际启动了至少两个容器,这两个容器在同一个服务器上吗

不一定。这两个容器(一个用于JobManager,另一个用于,具体取决于当时的集群资源、调度策略和配置。下面我把几种常见情况和背后的逻辑拆开说清楚。

#flink#服务器#java
SpringCloud 微服务监控 + SkyWalking 完整讲解

Agent 探针(客户端)JavaAgent 无侵入式探针,项目启动时通过-javaagent参数挂载,不需要改一行业务代码。自动拦截 SpringMVC、Feign、Dubbo、MySQL、Redis、MQ 等中间件操作,采集链路、耗时、异常、JVM 指标,异步上报数据。优势:零代码侵入,适配 SpringCloud 全组件。OAP 后端服务(收集处理核心)接收 Agent 上报的链路、指标数据

#spring cloud#微服务#skywalking
微服务限流

限流用于控制请求流量、保护服务避免雪崩;主流四种算法里令牌桶兼顾平稳与峰值,线上最常用;微服务采用多层限流架构:网关全局限流、应用接口细粒度限流、Redis 分布式集群限流;主流工具是 Sentinel,支持动态规则、多粒度限流,触发限流可快速失败、排队或降级兜底。

#微服务#架构#云原生
run () 和 start () 区别

run () 只是普通 Java 方法,封装线程任务逻辑,如果直接调用 run,不会开启新线程,只会在当前线程执行。start () 用来启动线程,内部会调用 native 本地方法 start0,由 JVM 向操作系统申请创建真正操作系统线程;start 只能调用一次,多次调用抛出异常;为什么不能直接调用 run 实现多线程?直接 run 就是普通方法,没有新操作系统线程,串行执行,达不到多线程

#java
    共 22 条
  • 1
  • 2
  • 3
  • 请选择