INNER CODE UNIT · Java

initPipelines

dadoonet/spring-elasticsearch · src/main/java/fr/pilato/spring/elasticsearch/ElasticsearchClientFactoryBean.java:550

    private void initPipelines() throws Exception {
        logger.debug("Initializing ingest pipelines");
        String[] pipelines = discoverFromClasspath(autoscan, this.pipelines, classpathRoot, SettingsFinder.Defaults.PipelinesDir);
        if (pipelines != null) {
            for (String pipeline : pipelines) {
                logger.debug("Initializing pipeline {}", pipeline);
                Assert.hasText(pipeline, "Can not read pipeline in ["
                        + pipeline
                        + "]. Check that pipeline is not empty.");
                createPipeline(lowLevelClient, classpathRoot, pipeline);
            }
        }
    }

    /**
     * It creates or updates the index lifecycles
     */
    private void initLifecycles() throws Exception {

View source record →