Advertisement
Guest User

Untitled

a guest
Jul 13th, 2017
74
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.83 KB | None | 0 0
  1. public static int export()
  2. {
  3. SqoopOptions options = new SqoopOptions();
  4. options.setConnectString("jdbc:oracle:thin:elvira/elvira@(DESCRIPTION =
  5. (ADDRESS = (PROTOCOL = TCP)(HOST = viumdbtest)(PORT = 1521))(CONNECT_DATA =(SERVICE_NAME = iumdb)))");
  6.  
  7. String query = "select
  8. ID,SERVEDIMEISV,SERVEDIMSI,FIRSTDATETIME,SECONDDATETIME " +
  9. "from elvira.PGW_INPUTDATA where $CONDITIONS and STATE='0' order by DATA_ID";
  10. options.setSqlQuery(query);
  11. options.setNumMappers(1);
  12. options.setTargetDir("/user/abulal/test");
  13. options.setHiveDatabaseName("pgw");
  14. options.setOverwriteHiveTable(true);
  15. options.setHiveTableName("pgw_oracle");
  16. options.setHiveImport(true);
  17. options.setFieldsTerminatedBy('01');
  18. options.setLinesTerminatedBy('n');
  19. options.setDeleteMode(true);
  20. int ret = new ImportTool().run(options);
  21. return ret;
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement