Spark 연산 자-RDD 액 션(saveasNewAPIHadoopFile)

======http://lxw1234.com/archives/2015/07/406.htm====== 4
saveAsNewAPIHadoopFile
4.567913.4.567913.4.567913.4.567913.4.567913.작용 은 saveas HadoopDataset 과 같 고 새로운 버 전의 Hadoop API 만 사용 할 수 있 습 니 다.HBase 를 기록 하 는 예:HBase 작성 표:
<span style="font-weight: normal;"><span style="font-size:12px;">def saveAsNewAPIHadoopFile[F <: OutputFormat[K, V]](path: String)(implicit fm: ClassTag[F]): Unit
def saveAsNewAPIHadoopFile(path: String, keyClass: Class[_], valueClass: Class[_], outputFormatClass: Class[_ <: OutputFormat[_, _]], conf: Configuration = self.context.hadoopConfiguration): Unit</span></span>
완전한 Spark 응용 프로그램:
saveAsNewAPIHadoopFile   RDD     HDFS ,     Hadoop API。     saveAsHadoopFile
주의:HBase 에 저장 하고 실행 할 때 SPARKCLASSPATH 에 HBase 관련 jar 가방 을 추가 합 니 다.참고 가능:http://lxw1234.com/archives/2015/07/332.htm

좋은 웹페이지 즐겨찾기