스칼라는 케이스 클래스 개념을 지원하는데 특징은 아래와 같다. 불변 패턴매칭을 통해 분해가능 레퍼런스가 아닌 구조적인 동등성으로 비교 초기화와 운영이 간결 예제 Notification.scala이라는 case class스칼라 파일을 생성 abstract class Notification case class Email(sourceEmail: String, title: String, body: String) extends Notifica case class SMS(sourceNumber: String, message: String) extends Notification case class VoiceRecording(contactName: String, link: String) extends Notificat..

접속정보를 option으로 주는 방법과 java.util.properties객체를 이용해 Mysql Server와 연결하는 방법이있다. import org.apache.spark.SparkConf import org.apache.spark.sql.SparkSession import java.util.Properties object RdbToHive { def main(args: Array[String]): Unit = { val conf = new SparkConf() .setAppName("SELECT RDBMS DATA") .setMaster("local") val spark = SparkSession.builder.config(conf).getOrCreate() // Loading data from..

[ IntelliJ ] 1. File->settings->plugin 에서 scala검색 후 설치 2. File->New Project->Maven->Next->설정값입력 후 Maven프로젝트 생성 3. pom.xml에 아래와 같이 추가 org.scala-lang scala-library 2.12.4 org.scala-lang.modules scala-xml_2.12 1.0.6 org.apache.spark spark-core_2.12 2.4.7 org.apache.spark spark-sql_2.12 2.4.7 4. 프로젝트 우클릭 -> Add Framework Support... -> scala SDK다운 및 적용 5. 특정폴더에 hadoop/bin 만들고 winutils.exe넣기 -> window..