Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public static int export()
- {
- SqoopOptions options = new SqoopOptions();
- options.setConnectString("jdbc:oracle:thin:elvira/elvira@(DESCRIPTION =
- (ADDRESS = (PROTOCOL = TCP)(HOST = viumdbtest)(PORT = 1521))(CONNECT_DATA =(SERVICE_NAME = iumdb)))");
- String query = "select
- ID,SERVEDIMEISV,SERVEDIMSI,FIRSTDATETIME,SECONDDATETIME " +
- "from elvira.PGW_INPUTDATA where $CONDITIONS and STATE='0' order by DATA_ID";
- options.setSqlQuery(query);
- options.setNumMappers(1);
- options.setTargetDir("/user/abulal/test");
- options.setHiveDatabaseName("pgw");
- options.setOverwriteHiveTable(true);
- options.setHiveTableName("pgw_oracle");
- options.setHiveImport(true);
- options.setFieldsTerminatedBy('