Package com.cloudera.sqoop.mapreduce

Examples of com.cloudera.sqoop.mapreduce.ImportJobBase


        conf.getClass(IMPORT_JOB_KEY, ImportJobBase.class);

    String tableName = context.getTableName();

    // Instantiate the user's chosen ImportJobBase instance.
    ImportJobBase importJob = ReflectionUtils.newInstance(jobClass, conf);

    // And configure the dependencies to inject
    importJob.setOptions(options);
    importJob.setMapperClass(mapperClass);
    importJob.setInputFormatClass(ifClass);
    importJob.setOutputFormatClass(ofClass);

    importJob.runImport(tableName, context.getJarFile(),
        getSplitColumn(options, tableName), conf);
  }
View Full Code Here

TOP

Related Classes of com.cloudera.sqoop.mapreduce.ImportJobBase

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.