本文主要实际编程讲解kafka生产者相关内容,版本kafka_2.11-0.10.1.0。 安装 linux集群安装过程请参考http://www.cnblogs.com/molyeo/p/7151949.html。 window安装过...
阅读(3) 评论(0)
本文主要讲解泛型、类型边界、协变、逆变的基础概念和应用。 泛型定义和调用 泛型是值定义以类型为参数的类,在scala源码中对泛型的使用相当广泛。 一般使用字母A作为类型参数标识符,并放在方括号[]中。如果有多个类型参数,则可以依次用A,...
阅读(3) 评论(0)
函数 本篇主要讲解函数的声明、定义和调用,同时对scala中各种函数进行了实例说明。 scala中方法(methods)是类的一部分;函数(functions)则是一个对象,可以赋值给一个变量,即定义在类中的函数即为方法。 函数的声明...
阅读(7) 评论(0)
本篇主要讲解spark运行架构,包含如下内容: Spark运行架构 基本概念 Application Spark的应用程序,包含一个Driver program和若干Executor SparkContext Spark应用程序的入...
阅读(7) 评论(0)
1.文件IO Scala的IO主要是对java的IO进行简单的封装. 1.1.读取本地文件 package com.tv189.test import java.io.{File, PrintWriter} imp...
阅读(30) 评论(0)