public static void setInputColumns ( Configuration conf , String columns ) { if ( columns == null || columns . isEmpty ( ) ) return ; conf . set ( INPUT_CQL_COLUMNS_CONFIG , columns ) ; }
Set the CQL columns for the input of this job .