java tuple

Python学习(十)字符串的常用操作详解「Ⅱ」

字符串的查询操作new_str='hello,hello,python'print('使用index()方法查询返回结果',new_str.index('lo'))#使用index()方法查询返回结果3print('使用find...

如果Java 和 C# 同时出现，生态也差不多，你选择谁?

Java与C#比较，哪个语言更是适合你？先来说一说Java和c#的一些语言细节上的区别。第1个方面是数据类型方面。c#支持nullable数据类型，而Java不支持。c#支持指针类型，而Java不支持。c#支持无符号整形型，而Java不支持。c#支持tuple类型，而Java不支持。c#支持值类型，...

Flink的sink实战之三:cassandra3

本文是《Flink的sink实战》系列的第三篇，主要内容是体验Flink官方的cassandraconnector，整个实战如下图所示，我们先从kafka获取字符串，再执行wordcount操作，然后将结果同时打印和写入cassandra：前文链接《Flink的sink实战之一：初探》《Flink...

三石说:java 基础 之 泛型

在没有介绍泛型的使用时想想我们在哪些地方使用泛型的居多，那么一定是集合中。在前面的集合中已经看到了使用到泛型了，今天来看下泛型具体的概念及用法。泛型：要使代码能够应用于“某种具体的类型而不是一个具体的接口或类”。增加了泛型支持后的集合，完全可以记住集合中元素的类型，并可以在编译时检查集合中元素的类型...

Flink的DataSource三部曲之三:自定义

本文是《Flink的DataSource三部曲》的终篇，前面都是在学习Flink已有的数据源功能，但如果这些不能满足需要，就要自定义数据源（例如从数据库获取数据），也就是今天实战的内容，如下图红框所示：往期回顾《Flink的DataSource三部曲之一：直接API》；《Flink的DataSour...

学习HackerOne上Flink、Grafana、jolokia攻击手法

前言那天凑巧上HackerOne看看，所以jarij的漏洞报告刚一放出来就看到了。但是看完三篇RCE的报告-ApacheFlinkRCEviaGETjar/planAPIEndpoint-aiven_ltdGrafanaRCEviaSMTPserverparameter...

Flink入门:读取Kafka实时数据流，实现WordCount

本文主要介绍Flink接收一个Kafka文本数据流，进行WordCount词频统计，然后输出到标准输出上。通过本文你可以了解如何编写和运行Flink程序。代码拆解首先要设置Flink的执行环境：//创建Flink执行环境StreamExecutionEnvironmentenv=Strea...

读Java实战(第二版)笔记15_并行数据处理与性能

1.Stream1.1.允许你声明性地将顺序流转变成并行流1.2.能对这些集合执行操作流水线，可以充分利用计算机的多个核2.并行流2.1.把内容拆分成多个数据块，用不同线程分别处理每个数据块的流2.2.自动地把工作负荷分配到多核处理器的所有核2.3.内部迭代让你可以并行处理一个流，而无须在代码中显式...

浅薄研究intellij的javaagent

这两天学习了一下jvm的字节码，学习过程中，正好想起来java程序员们赖以生存的IDE，大名鼎鼎的Intellij，国内的小伙伴们应该对这个也不陌生，尤其是需要用它的商业版本的时候，刚开始学习的同学们会用各种方法找破解版[奸笑]，而其中有一种方法就是在启动的时候添加-javaagent参数加载一个j...

Flink计算支持的数据类型

Flink处理数据介绍Flink流应用程序处理是以数据对象表示的事件流。在Flink内部，处理数据对象，通过被序列化和反序列化进行网络传送，从状态后端、检查点和保存点读取它们。为了有效地做到这一点，Flink需要明确知道应用程序所处理的数据类型。Flink使用类型信息的概念来表示数据类型，并为每个数...