240 发简信
IP属地:贵州
  • 120
    java线程之FutureTask+Callable

    简介 创建线程的方式有两种,一种是实现Runnable接口,另一种是继承Thread,但是这两种方式都有个缺点,那就是在任务执行完成之后无法获取返回结果.那如果我们想要获取返...

  • 面试官问我如何保证Kafka不丢失消息?我哭了!

    ## kafka如何保证不丢消息 ps:这篇文章自我感觉说的很大白话了!希望你们看过了之后能有收获。 不了解 Kafka 的朋友建议先看一看我的下面这几篇文章,第一篇一定要...

  • 博主,请教个问题,我们的数据和hbase是在两个集群,所以需要先生成hfile然后distcp到hbase集群,表已经建好,并且做了预分区比如说十个,那么我生成的hfile的个数必须也是和region相同吗?

    Spark:DataFrame生成HFile 批量导入Hbase

    批量加载-Bulk Load 在工作过程中有个需求,需要将DataFrame的数据保存进Hbase,并且在Spark集群并没有安装Hbase,此时对于常规的使用put将Dat...

  • 分析的挺好的,但是在实际生产上不建议使用这个参数,因为资源你可以释放,但是并不一定可以很随意的申请到特别是在集群的资源隔离做的不好的情况下,遇到了资源紧张的时候,很可能会无法申请到资源,导致任务的滞后,甚至是失败

    Spark Streaming Executor DynamicAllocation 机制分析

    —————☼—————☼—————☼—————☼—————☼—————Spark Streaming概述Spark Streaming 初始化过程Spark Streamin...

  • 博主的那个文件内容的展示 是个亮点 赞一个

    消息中间件—Kafka数据存储(一)

    摘要:消息存储对于每一款消息队列都非常重要,那么Kafka在这方面是如何来设计做到高效的呢?Kafka这款分布式消息队列使用文件系统和操作系统的页缓存(page cache)...

  • 120
    消息中间件—Kafka数据存储(一)

    摘要:消息存储对于每一款消息队列都非常重要,那么Kafka在这方面是如何来设计做到高效的呢?Kafka这款分布式消息队列使用文件系统和操作系统的页缓存(page cache)...