Guest User

Untitled

a guest
Feb 12th, 2019
119
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.34 KB | None | 0 0
  1. sqoop import --connect jdbc:mysql://host:port/message
  2. --username message --password message
  3. --query "select 't0_'+ message_id as message_key, some_split_id, some_other_columns
  4. from message_0 where message_id >30000 and message_id <= 31000 and $CONDITIONS"
  5. --split-by some_split_id --hbase-row-key message_key
  6. --hbase-table message --column-family cf1
  7.  
  8. public void set_message_key(String message_key) {
  9. this.message_key = "t0_" + message_key;
  10. }
  11. public MessageImporter with_message_key(String message_key) {
  12. this.message_key = "t0_" + message_key;
  13. return this;
  14. }
  15. ...
  16. public void readFields(DataInput __dataIn) throws IOException {
  17. if (__dataIn.readBoolean()) {
  18. this.message_key = null;
  19. } else {
  20. this.message_key = "t0_" + Text.readString(__dataIn);
  21. }
  22. ...
  23. ...
  24. }
  25. ...
  26. private void __loadFromFields(List<String> fields) {
  27. Iterator<String> __it = fields.listIterator();
  28. String __cur_str;
  29. __cur_str = __it.next();
  30. if (__cur_str.equals("null") || __cur_str.length() == 0) { this.message_key = null; } else {
  31. this.message_key = "t0_" + __cur_str;
  32. }
  33. ...
  34. }
  35. ...
  36. public void setField(String __fieldName, Object __fieldVal) {
  37. if ("message_key".equals(__fieldName)) {
  38. this.message_key = "t0_" + (String) __fieldVal;
  39. }
  40. ...
  41. }
  42.  
  43. --jar-file someJar.jar --class-name com.foo.SomeImportClass
Add Comment
Please, Sign In to add comment