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 ) ; }
Get input content source .