code: public static void setInputColumns(Configuration conf, String columns)
      {
          if (columns == null || columns.isEmpty())
              return;
          
          conf.set(INPUT_CQL_COLUMNS_CONFIG, columns);
      }
docs: Set the CQL columns for the input of this job.
  
  @param conf Job configuration you are about to run
  @param columns