加载中
flink细粒度资源管理

Apache Flink努力为所有应用程序自动派生合理的默认资源需求。对于希望根据特定场景的知识调整资源消耗的用户,Flink提供了细粒度的资源管理。 这个页面描述了细粒度资源管理的使用、适用场景...

flink细粒度资源管理

Apache Flink努力为所有应用程序自动派生合理的默认资源需求。对于希望根据特定场景的知识调整资源消耗的用户,Flink提供了细粒度的资源管理。 这个页面描述了细粒度资源管理的使用、适用场景...

2022/02/14 01:24
109
flink流式概念

Flink 的 Table API 和 SQL 是流批统一的 API。 这意味着 Table API & SQL 在无论有限的批式输入还是无限的流式输入下,都具有相同的语义。 因为传统的关系代数以及 SQL 最开始都是为了批式处...

2022/02/14 00:40
15
flink并行度设置(重要!!!)

本节描述了在 Flink 中配置程序的并行执行。一个 Flink 程序由多个任务 task 组成(转换/算子、数据源和数据接收器)。一个 task 包括多个并行执行的实例,且每一个实例都处理 task 输入数据...

2022/02/14 00:18
2.1K
flink执行配置

StreamExecutionEnvironment包含ExecutionConfig,它允许为运行时设置特定于作业的配置值。若要更改影响所有作业的默认值,请参见Configuration。 Java StreamExecutionEnvironment env = St...

2022/02/13 23:59
731
flink join

Window Join # 窗口连接连接两个流的元素,它们共享一个公共键,并且位于同一个窗口中。这些窗口可以通过使用窗口赋值器来定义,并在两个流的元素上求值。 然后将来自双方的元素传递给用户定...

2022/02/13 23:46
20
flink自定义序列化管理状态

本页面的目标是为需要对其状态使用自定义序列化的用户提供指导方针,包括如何提供自定义状态序列化器,以及实现允许状态模式演化的序列化器的指导方针和最佳实践。 如果您只是使用Flink自己的...

2022/02/13 23:29
194
flink自定义序列化管理状态

本页面的目标是为需要对其状态使用自定义序列化的用户提供指导方针,包括如何提供自定义状态序列化器,以及实现允许状态模式演化的序列化器的指导方针和最佳实践。 如果您只是使用Flink自己的...

2022/02/13 23:29
62
flink自定义序列化管理状态

本页面的目标是为需要对其状态使用自定义序列化的用户提供指导方针,包括如何提供自定义状态序列化器,以及实现允许状态模式演化的序列化器的指导方针和最佳实践。 如果您只是使用Flink自己的...

2022/02/13 23:29
91
flink及时流处理

及时流处理是有状态流处理的扩展,时间在计算中起着一定的作用。除此之外,当您进行时间序列分析、基于特定时间段(通常称为窗口)进行聚合、或者在事件发生时间非常重要的情况下进行事件处理时...

flink有状态流处理

What is State? # 虽然数据流中的许多操作只是一次查看一个单独的事件(例如事件解析器),但有些操作会记住跨多个事件的信息(例如窗口操作符)。这些操作称为有状态的。 一些有状态操作的例子:...

Dubbo 总结

Dubbo是一款高性能、轻量级的开源 Java RPC 框架。 根据 Dubbo 官方文档 (opens new window)的介绍,Dubbo 提供了六大核心能力 面向接口代理的高性能RPC调用。 智能容错和负载均衡。 服务自动...

Fast Distributed Deep Learning on RDMA阅读笔记

RPC认为是有害的 RPC Considered Harmful: Fast Distributed Deep Learning on RDMA Jilong Xue, Youshan Miao, Cheng Chen, Ming Wu, Lintao Zhang, Lidong Zhou Microsoft Research...

rpc
2018/05/25 22:27
1.2K
194. 转置文件

给定一个文件 file.txt,转置它的内容。 你可以假设每行列数相同,并且每个字段由 ' ' 分隔. 示例: 假设 file.txt 文件内容如下: name age alice 21 ryan 30 应当输出: name alice ryan ag...

2018/05/25 21:49
512
bash 词频统计

bash脚本语法复习

2018/05/25 19:23
1.1K
LeetCode 41. 缺失的第一个正数

给定一个未排序的整数数组,找出其中没有出现的最小的正整数。 示例 1: 输入: [1,2,0] 输出: 3 示例 2: 输入: [3,4,-1,1] 输出: 2 示例 3: 输入: [7,8,9,11,12] 输出: 1 说明: 你的算法的时间...

2018/05/25 11:16
1K
scala泛函编程(1)

函数式编程又称泛函编程,是一种编程范式,它将程序运算视为数学上的函数计算,并且避免使用程序状态及可变对象。函数式编程语言最重要的基础是λ演算(lambda calculus)。λ演算的函数可以...

2018/05/24 18:14
126
LeetCode 262. Trips and Users

Trips 表中存所有出 租 车的行程信息。每段行程有唯一健 Id,Client_Id 和 Driver_Id 是 Users 表中 Users_Id 的外键。Status 是枚举类型,枚举成员为 (‘completed’, ‘cancelled_by_driv...

2018/05/24 02:03
327
Hbase过滤器(Filter)

Filter CompareFilter 是高层的抽象类,下面我们将看到他的实现类和实现类代表的各种过滤条件 RowFilter,FamliyFilter,QualifierFilter,ValueFilter 行,列组,列,值等的过滤 SingleColumn...

2018/05/10 10:39
213

没有更多内容

加载失败,请刷新页面

返回顶部
顶部