'Add hdfs path contents to index'

def update_data_from_hdfs(self, fs, collection_or_core_name, fields, path, data_type='separated', indexing_strategy='upload', **kwargs):

    api = SolrApi(SOLR_URL.get(), self.user, SECURITY_ENABLED.get())
    if (indexing_strategy == 'upload'):
        stats = fs.stats(path)
        if (stats.size > MAX_UPLOAD_SIZE):
            raise PopupException(_('File    size    is    too    large    to    handle!'))
        else:
            (unique_key, fields) = self.get_fields(collection_or_core_name)
            fields = [{'name': field, 'type': fields[field]['type']} for field in fields]
            fh = fs.open(path)
            if (data_type == 'log'):
                data = json.dumps([value for value in field_values_from_log(fh, fields)])
                content_type = 'json'
            elif (data_type == 'separated'):
                data = json.dumps([value for value in field_values_from_separated_file(fh, kwargs.get('separator', ','), kwargs.get('quote_character', '"'), fields)], indent=2)
                content_type = 'json'
            else:
                raise PopupException((_('Could    not    update    index.    Unknown    type    %s') % data_type))
            fh.close()
        if (not api.update(collection_or_core_name, data, content_type=content_type)):
            raise PopupException(_('Could    not    update    index.    Check    error    logs    for    more    info.'))
    else:
        raise PopupException((_('Could    not    update    index.    Indexing    strategy    %s    not    supported.') % indexing_strategy))
