api代码示例入下 object DataFrameCase { def main(args: Array[String]): Unit = { val sparksession = SparkSession.builder().appName("DataFrameCase").master("lo ...
今天学习了单向链表的实现，记录一下，方便以后查看~ import util.control.Breaks._ object SingleLinkedListDemo { def main(args: Array[String]): Unit = { //创建和遍历 val singleLinkedL ...
分类：
其他好文 时间：
2020-05-19 23:10:25
阅读次数：
74
这里选择用数组实现，为了队列可以复用，选择环形数组实现 import scala.io.StdIn object CircleArrayQueue { def main(args: Array[String]): Unit = { val queue = new ArrayQueue2(3) //菜 ...
分类：
其他好文 时间：
2020-05-17 11:47:48
阅读次数：
62
批处理代码： package com.wyh.wc import org.apache.flink.api.scala._ /** * 批处理代码 */ object WordCount { def main(args: Array[String]): Unit = { //创建一个批处理的一个环境 ...
分类：
其他好文 时间：
2020-05-11 23:28:06
阅读次数：
79
一、函数作为参数 highOrderFunc是一个高阶函数，因为它可以接收一个函数作为参数 object PartialFunctionDemo { def main(args: Array[String]): Unit = { val add = (d: Double) => d + 1 val ...
分类：
其他好文 时间：
2020-05-02 14:53:58
阅读次数：
54
1 package com.ds 2 3 import org.apache.spark.sql.{Dataset, SparkSession} 4 5 object DataSet { 6 7 def main(args: Array[String]): Unit = { 8 val spark: ...
分类：
其他好文 时间：
2020-05-02 12:10:05
阅读次数：
46
一、流 动态产生无穷多的数据，末尾元素遵循lazy规则 object StreamDemo { //生成流的方法 def numStream(n: BigInt): Stream[BigInt] = n #:: numStream(n + 1) def main(args: Array[String ...
分类：
其他好文 时间：
2020-04-23 11:50:31
阅读次数：
68
spark实现UserCF package cf import breeze.numerics.{pow, sqrt} import org.apache.spark.sql.SparkSession object UserCF { def main(args: Array[String]): Un ...
分类：
其他好文 时间：
2020-04-23 01:08:59
阅读次数：
146
核心代码： object TransformTest { def main(args: Array[String]): Unit = { val env = StreamExecutionEnvironment.getExecutionEnvironment env.setParallelism(1 ...
分类：
其他好文 时间：
2020-04-19 23:43:32
阅读次数：
337
class TestClass { public static void test(params int[] array) { string s;foreach (int i in array) { Console.WrriteLine(i); } } } public static void Ma ...
