
public class IterateStream { public static void main(String[] args) throws Exception { StreamExecutionEnvironm
修改 server.properties 允许外部端口连接 listeners=PLAINTEXT://0.0.0.0:9092 外部代理地址 advertised.listeners=PLAINTE....
什么是量化交易?个人理解,量化交易=量化+交易。 量化就是大数据,比如股票,就是各种股票赚钱因子历年历史数据。 交易就是....
目录 一、环境准备 1、RabbitMQ版本 和 Erlang 版本兼容性关系 2、官方安装包下载地址 3、安装包中说明,请下载对应的安装包....
3.5版本以后带bin压缩包 需执行以下命令 针对data 和 logs sudo chmod 777 data sudo chmod 777 logs 由于8080端口占用; 3.....
Hadoop完全分布式环境部署 1、使用软件及其版本 环境虚拟机:VMwareLinux:CentOS 7Windows:Windows10软件JDK:Jdk1.8_131Had....
一、准备好jdk1.8 链接:https://pan.baidu.com/s/1heitZqXjO0dWr8rdIgucXA 提取码:jcif 二、查找系统是否有自带的jdk rp....
dataworks是阿里云基于dataX在云端部署的一套ETL产品,对于中小企业来说大大降低了大数据的门槛和运维开发成本。它可以创建....
报错截图 报错原因 在kafka.config.server.properties文件中更改了broker.id但是没有删除之前的记录 解决方法 删除之前的操....
sink部分,需要自己定义的实现类有 动态topic实现类 DynKeyedSerializationSchema.java import org.apache.flink.api.common....
现状趋势: 我们主要从安全现状以及趋势分析两个方面来。 讲解这一节的内容。 下面我们先讲安全现状,我们主要从三个方面来介....
背景 之前博客中有讲怎么配置hadoop的HA,在工作中,我因要进行数据治理组件的探究,所以需要部署一个测试集群来测试一下数....
在搭建hadoop时因为一些原因对三个虚拟机进行了备份并重新加载,结果出现了各节点ip改变的情况,如果重新修改hadoop的配置文....
前言 本文的测试是基于740w条测试数据进行的,只讨论like模糊查询的优化方案。其他SQL优化可参考: SQL优化的几种方式 查询....
编辑 | 宋慧 出品 | CSDN 云计算 在人工智能从爆火到普及应用之后,数据分析今年又一次被技术界广泛关注,热度再次到达高点....
最近因为公司关系,服务器在CentOS与Ubuntu间切换,故写几篇博文用于记录,把之前的部署方案记录下来,方便以后快速查找 一....
pandas创建DataFrame的几种方式 如果你是一个pandas初学者,那么不知道你会不会像我一样。在学用列表或者数组创建DataFrame....
生产者:package com.atguigu.util; /** * Copyright (c) 牧原 All Rights Reserved * * Project: Producer * Packag....
Java解析yaml文件 1. 什么是yaml ?2. 导入maven依赖3. yaml 案例文件4. 示例代码5. 解析结果 1. 什么是yaml ? 参考下方链接 ....