java tuple 第3页

Python 数据结构之元组

大家好啊，我是大田。1、元组的定义下面5种形式都为定义元组的方式t=tuple('python')t1=('p','y','t','h','o','n')t2...

一次性带你了解清楚Java内存模型

Java内存模型Java虚拟机内部使用JMM(Java内存模型)将内存划分为两个逻辑单元，线程栈(或者叫本地内存)和堆。每一个线程都有属于自己的线程栈，在线程栈中会保存局部变量(也叫做本地变量)、方法中定义的参数和异常处理器的参数(catch中的参数)；这些参数和变量都属于线程局部操作，会...

Flink DataStream API编程指南

FlinkDataStreamAPI主要分为三个部分，分别为Source、Transformation以及Sink，其中Source是数据源，Flink内置了很多数据源，比如最常用的Kafka。Transformation是具体的转换操作，主要是用户定义的处理数据的逻辑，比如Map，FlatMa...

java + redis zset实现延迟队列(定时到期执行任务)

在Redis中，zet作为有序集合，可以利用其有序的特性，将任务添加到zset中，将任务的到期时间作为score，利用zset的默认有序特性，zrangewithscores可以获取score值最小的元素（也就是最近到期的任务），判断系统时间与该任务的到期时间大小，如果达到到期时间，就执行业务，并删...

Java基础——泛型

1基本概括2主要介绍2.1什么是java泛型？Java泛型是J2SE1.5中引入的一个新特性，其本质是参数化类型，也就是说所操作的数据类型被指定为一个参数（typeparameter）这种参数类型可以用在类、接口和方法的创建中，分别称为泛型类、泛型接口、泛型方法。泛型，即“参数化类型”。一...

阿里Java三面:分布式延时任务方案解析，万字长文一篇点通你

前言在开发中，往往会遇到一些关于延时任务的需求。例如生成订单30分钟未支付，则自动取消生成订单60秒后,给用户发短信对上述的任务，我们给一个专业的名字来形容，那就是延时任务。那么这里就会产生一个问题，这个延时任务和定时任务的区别究竟在哪里呢？一共有如下几点区别定时任务有明确的触发时间，延时任务没有定...

Flink从入门到入土

和其他所有的计算框架一样，flink也有一些基础的开发步骤以及基础，核心的API，从开发步骤的角度来讲，主要分为四大部分1.EnvironmentFlinkJob在提交执行计算时，需要首先建立和Flink框架之间的联系，也就指的是当前的flink运行环境，只有获取了环境信息，才能将task调度到不...

「Flink实时数据分析系列」8.与外部系统的读写交互(上)

数据与智能本公众号关注大数据与人工智能技术。由一批具备多年实战经验的技术极客参与运营管理，持续输出大数据、数据分析、推荐系统、机器学习、人工智能等方向的原创文章，每周至少输出10篇精品原创。同时，我们会关注和分享大数据与人工智能行业动态。欢迎关注。来源|「StreamProcessing...

Python编程:详解命名元组(namedtuple)的使用要点

前言本文继续来介绍Python集合模块，这次主要简明扼要的介绍其内的命名元组，即namedtuple的使用。闲话少叙，我们开始——记得点赞、关注和转发哦~^_^创建命名元组Python集合中的命名元组类namedTuples为元组中的每个位置赋予意义，并增强代码的可读性和描述性。它们可以在任何使用...

干货|Flink入门教程(二)

2基本概念2.1DataStream和DataSetFlink使用DataStream、DataSet在程序中表示数据，我们可以将它们视为可以包含重复项的不可变数据集合。DataSet是有限数据集（比如某个数据文件），而DataStream的数据可以是无限的（比如kafka队列中的消息）。这些集...