spark_demo

spark_demo

import java.sql.Statement;

import org.apache.spark.SparkConf;
import org.apache.spark.SparkContext;
import org.apache.spark.api.java.function.ForeachFunction;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SQLContext;
import org.apache.spark.sql.SparkSession;

/**
 * Hello world!
 */
public class App {
	public static String		URL			= “jdbc:oracle:thin:@172.16.3.17:1521:orcl17“;
	public static String		DRIVER		= “oracle.jdbc.driver.OracleDriver“;
	public static String		USER		= “zhcx“;
	public static String		PASSWORD	= “2017oracle2017“;
	public static String		ORC			= “hdfs://172.16.4.200:8020///dataImportResult/fromOracleBig/wth/“;
	public static String		ORC_config	= “SYS_TABS_COLUM_RYXM_DHHM_SFZH.orc“;
	public static Stri

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

    I.A....      1022  2018-03-01 09:45  wth\wthFileToOracle\.classpath

    I.A....       567  2018-03-01 09:45  wth\wthFileToOracle\.project

    I.A....       119  2018-03-01 09:45  wth\wthFileToOracle\.settings\org.eclipse.core.resources.prefs

    I.A....       243  2018-03-01 09:45  wth\wthFileToOracle\.settings\org.eclipse.jdt.core.prefs

    I.A....        90  2018-03-01 09:45  wth\wthFileToOracle\.settings\org.eclipse.m2e.core.prefs

    I.A....      3921  2018-03-01 09:45  wth\wthFileToOracle\pom.xml

    I.A....      3547  2018-03-01 09:45  wth\wthFileToOracle\src\main\java\App.java

    I.A....      1337  2018-03-01 09:45  wth\wthFileToOracle\src\main\java\DBUtils.java

    I.A....     17413  2018-03-01 09:45  wth\wthFilter\.classpath

    I.A....       666  2018-03-01 09:45  wth\wthFilter\.project

    I.A....        88  2018-03-01 09:45  wth\wthFilter\.settings\org.eclipse.core.resources.prefs

    I.A....       373  2018-03-01 09:45  wth\wthFilter\.settings\org.eclipse.jdt.core.prefs

    I.A....        90  2018-03-01 09:45  wth\wthFilter\.settings\org.eclipse.m2e.core.prefs

    I.A....      4023  2018-03-01 09:45  wth\wthFilter\pom.xml

    I.A....      7478  2018-03-01 09:45  wth\wthFilter\src\main\java\App.java

    I.A....     13815  2018-03-01 09:45  wth\wthFilter\src\main\java\wthFilter\RegUtils.java

    I.A....      3975  2018-03-01 09:45  wth\wthFilter\src\main\java\wthFilter\StringConstrant.java

    I.A....     17413  2018-03-01 09:45  wth\wthOracle\.classpath

    I.A....       666  2018-03-01 09:45  wth\wthOracle\.project

    I.A....        88  2018-03-01 09:45  wth\wthOracle\.settings\org.eclipse.core.resources.prefs

    I.A....       373  2018-03-01 09:45  wth\wthOracle\.settings\org.eclipse.jdt.core.prefs

    I.A....        90  2018-03-01 09:45  wth\wthOracle\.settings\org.eclipse.m2e.core.prefs

    I.A....      3887  2018-03-01 09:45  wth\wthOracle\pom.xml

    I.A....      3762  2018-03-01 09:45  wth\wthOracle\src\main\java\App.java

    I.A....      1552  2018-03-01 09:45  wth\wthOracle\src\main\java\App2.java

    I.A....       445  2018-03-01 09:45  wth\wthOracle\src\main\java\StringConstrant.java

    I.A....      4059  2018-03-01 09:45  wth\wthOracle\target\classes\App.class

    I.A....      4775  2018-03-01 09:45  wth\wthOracle\target\classes\meta-INF\MANIFEST.MF

    I.A....       228  2018-03-01 09:45  wth\wthOracle\target\classes\meta-INF\maven\org.smkj.spark\wthOracle\pom.properties

    I.A....      3887  2018-03-01 09:45  wth\wthOracle\target\classes\meta-INF\maven\org.smkj.spark\wthOracle\pom.xml

............此处省略124个文件信息