生活学习记录

FlinkSQL验证与执行计划查看

大数据数据

import org.apache.flink.api.java.tuple.Tuple2; import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.api.en

springboot多数据源配置

spring 后端开发

import javax.sql.DataSource; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Qualifier;

JAVA8 ArrayBloackingQueue源码分析

Java 编程基础

构造函数用于创建一个带有给定的（固定）容量和默认访问策略的 ArrayBlockingQueue。 public ArrayBlockingQueue(int capacity, boolean fair) { // 初始容量必须大于0 if (capacity <= 0) throw new Il

Code for parquet writer

大数据数据

import com.sf.presto.jdbc.internal.airlift.slice.Slice; import com.sf.presto.jdbc.internal.airlift.slice.Slices; import org.apache.hadoop.conf.Configu

Code for Presto TestCase

大数据数据

/* * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may o