springboot如何访问windows本地和linux上的外部文件?首先编写一个WebMvcConfiguration配置文件类@Configurationpublic ...
springboot如何访问windows本地和linux上的外部文件?首先编写一个WebMvcConfiguration配置文件类@Configurationpublic ...
spark连接到hive首先要先配置3个文件,放到idea的resource目录下,如下:core-site.xml从集群环境中拉下来。hdfs-site.xml从环境中拉下...
// HBase.createTable(table, new String[]{family}, false);final LineIterator ...
需要自定义一个sink组件,其实很简单,只需要继承ForeachWriter,实现相关的方法即可。class RedisSink extends ForeachWriterR...
groupingBy和partitioningBy的区别我们先来看官方源码说明public static <T, K> Collector<T, ?, Map<K, List...
手写编写一个工具类的接口程序:package com.ky.kafka.consumer; /** @Author: xwj @Date: 2019/3/12 0012 09...
在项目中,我们需要对url进行解析处理,但是我们但是不知道url是post还是get请求,有时候呢,大量请求的时候有post也有get请求,但是我们又希望能稳定的得到书记,那...
ConnectionDriver 获取驱动public class ConnectionDriver {static class ConnectionHandler impl...
我们知道sparkstreaming官方已经停止了维护,从spark2.2开始全力打造Structured Streaming,下面我们来介绍Structured Strea...