code: public static ContentSource getInputContentSource(Configuration conf,
              String host) 
      throws XccConfigException, IOException {      
          String user = conf.get(INPUT_USERNAME, "");
          String password = conf.get(INPUT_PASSWORD, "");
          String port = conf.get(INPUT_PORT,"8000");
          String db = conf.get(INPUT_DATABASE_NAME);
          int portInt = Integer.parseInt(port);
          boolean useSsl = conf.getBoolean(INPUT_USE_SSL, false);
          if (useSsl) {
              return getSecureContentSource(host, portInt, user, password, 
                          db, getInputSslOptions(conf));
          }
          return ContentSourceFactory.newContentSource(host, portInt, 
                  user, password, db);
      }
docs: Get input content source.
  
  @param conf job configuration
  @param host host to connect to
  @return content source
  @throws IOException
  @throws XccConfigException