}

    @Override
    public int getQueueShards() {
        return ComponentUtil.getFessConfig().getIndexDocumentCrawlerQueueNumberOfShardsAsInteger();
    }

    @Override
    public int getDataShards() {
        return ComponentUtil.getFessConfig().getIndexDocumentCrawlerDataNumberOfShardsAsInteger();
    }

    @Override
    public int getFilterShards() {

    }

    public int getQueueShards() {
        return queueShards;
    }

    public void setQueueShards(final int queueShards) {
        this.queueShards = queueShards;
    }

    public int getDataShards() {
        return dataShards;
    }

    public void setDataShards(final int dataShards) {
        this.dataShards = dataShards;
    }

    public int getFilterShards() {
        return filterShards;

    public OpenSearchDataService(final OpenSearchCrawlerConfig crawlerConfig) {
        index = crawlerConfig.getDataIndex();
        setNumberOfShards(crawlerConfig.getDataShards());
        setNumberOfReplicas(crawlerConfig.getDataReplicas());
    }

    public OpenSearchDataService(final String name, final String type) {
        index = name + "." + type;
    }

    @PostConstruct