zoukankan      html  css  js  c++  java
  • sqoop java api

     SqoopOptions options = new SqoopOptions();
            options.setConnectString("jdbc:mysql://HOSTNAME:PORT/DATABASE_NAME");
            //options.setTableName("TABLE_NAME");
            //options.setWhereClause("id>10");     // this where clause works when importing whole table, ie when setTableName() is used
            options.setUsername("USERNAME");
            options.setPassword("PASSWORD");
            //options.setDirectMode(true);    // Make sure the direct mode is off when importing data to HBase
            options.setNumMappers(8);         // Default value is 4
            options.setSqlQuery("SELECT * FROM user_logs WHERE $CONDITIONS limit 10");
            options.setSplitByCol("log_id");
    
            // HBase options
            options.setHBaseTable("HBASE_TABLE_NAME");
            options.setHBaseColFamily("colFamily");
            options.setCreateHBaseTable(true);    // Create HBase table, if it does not exist
            options.setHBaseRowKeyColumn("log_id");
    
            int ret = new ImportTool().run(options);
    来自: https://stackoverflow.com/questions/9229611/how-to-use-sqoop-in-java-program    
  • 相关阅读:
    SpringMVC拦截器
    SpringMVC异常
    SpringMVC文件上传
    SpringMVC返回值类型
    JVM字节码
    使用Apache JMeter进行测试
    Tomcat优化
    垃圾收集器
    GC常见算法
    VisualVM远程连接Tomcat
  • 原文地址:https://www.cnblogs.com/chengjunhao/p/7723988.html
Copyright © 2011-2022 走看看