kisimple’s gists

kisimple / DataStreamCorrelateFunction.java

Created March 27, 2018 06:31

	public class DataStreamCorrelateRule$20
	extends org.apache.flink.streaming.api.functions.ProcessFunction {

	final org.apache.flink.table.runtime.TableFunctionCollector instance_org$apache$flink$table$runtime$TableFunctionCollector$15;

	final org.apache.flink.table.examples.scala.UDTFExample.Func0 function_org$apache$flink$table$examples$scala$UDTFExample$Func0$16ea6ef48e35886045c180780a1a0914;



	public DataStreamCorrelateRule$20() throws Exception {

kisimple / example.spark_streaming.pom.xml

Last active December 5, 2017 09:06

	<?xml version="1.0" encoding="UTF-8"?>
	<project xmlns="http://maven.apache.org/POM/4.0.0"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>

	<groupId>me.kisimple</groupId>
	<artifactId>just4fun</artifactId>
	<version>1.0.0-SNAPSHOT</version>

kisimple / DirectKafka010WordCount.scala

Last active November 22, 2017 06:44

	/*
	* Licensed to the Apache Software Foundation (ASF) under one or more
	* contributor license agreements. See the NOTICE file distributed with
	* this work for additional information regarding copyright ownership.
	* The ASF licenses this file to You under the Apache License, Version 2.0
	* (the "License"); you may not use this file except in compliance with
	* the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*

kisimple / DefaultSource.scala

Created August 9, 2017 02:30

org.apache.spark.examples.sql.DefaultSource

	/*
	* Licensed to the Apache Software Foundation (ASF) under one or more
	* contributor license agreements. See the NOTICE file distributed with
	* this work for additional information regarding copyright ownership.
	* The ASF licenses this file to You under the Apache License, Version 2.0
	* (the "License"); you may not use this file except in compliance with
	* the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*

kisimple / GeneratedClass.java

Last active January 4, 2020 14:36

GeneratedClass for Partial aggregate

	//// SELECT count(*), avg(age), gender FROM people WHERE age > 18 GROUP BY gender LIMIT 20

	package org.apache.spark.sql.catalyst.expressions;

	import org.apache.spark.sql.catalyst.InternalRow;
	import org.apache.spark.sql.catalyst.expressions.UnsafeProjection;
	import org.apache.spark.sql.catalyst.expressions.UnsafeRow;
	import org.apache.spark.unsafe.Platform;
	import org.apache.spark.unsafe.types.UTF8String;

kisimple / GeneratedClass.java

Last active January 4, 2020 14:36

GeneratedClass for Final aggregate

	//// SELECT count(*), avg(age), gender FROM people WHERE age > 18 GROUP BY gender LIMIT 20

	package org.apache.spark.sql.catalyst.expressions;

	import org.apache.spark.sql.catalyst.InternalRow;
	import org.apache.spark.sql.catalyst.expressions.UnsafeRow;
	import org.apache.spark.unsafe.types.UTF8String;

	public class GeneratedClass extends
	org.apache.spark.sql.catalyst.expressions.codegen.GeneratedClass {

kisimple / GeneratedClass.java

Last active March 17, 2017 06:51

	//// spark.sql("SELECT name FROM people WHERE age > 18 ORDER BY age LIMIT 20")

	package org.apache.spark.sql.catalyst.expressions;

	import org.apache.spark.sql.catalyst.InternalRow;
	import org.apache.spark.sql.catalyst.expressions.UnsafeRow;
	import org.apache.spark.unsafe.types.UTF8String;

	public class GeneratedClass extends
	org.apache.spark.sql.catalyst.expressions.codegen.GeneratedClass {

boshu Zheng kisimple