Examples of ElasticSearchDownloader

Examples of com.aconex.scrutineer.elasticsearch.ElasticSearchDownloader

74
75
76
77
78
79
80
81
82
83
84
        ElasticSearchSorter elasticSearchSorter = new ElasticSearchSorter(createSorter(factory));
        IteratorFactory iteratorFactory = new IteratorFactory(factory);
        String workingDirectory = SystemUtils.getJavaIoTmpDir().getAbsolutePath();

        ElasticSearchIdAndVersionStream esStream = new ElasticSearchIdAndVersionStream(
            new ElasticSearchDownloader(client, indexName, "_type:" + mapping.getTypeAlias(), factory),
            elasticSearchSorter, iteratorFactory, workingDirectory);

        long start = System.currentTimeMillis();

        BulkIndexHelper h = new BulkIndexHelper().setMaxRunning(2);
View Full Code Here

Examples of com.aconex.scrutineer.elasticsearch.ElasticSearchDownloader

103
104
105
106
107
108
109
    }

    ElasticSearchIdAndVersionStream createElasticSearchIdAndVersionStream(ScrutineerCommandLineOptions options) {
        this.node = new NodeFactory().createNode(options);
        this.client = node.client();
        return new ElasticSearchIdAndVersionStream(new ElasticSearchDownloader(client, options.indexName, options.query, idAndVersionFactory), new ElasticSearchSorter(createSorter()), new IteratorFactory(idAndVersionFactory), SystemUtils.getJavaIoTmpDir().getAbsolutePath());
    }
View Full Code Here

Examples of com.aconex.scrutineer.elasticsearch.ElasticSearchDownloader

99
100
101
102
103
104
105
  }

    ElasticSearchIdAndVersionStream createElasticSearchIdAndVersionStream(ScrutineerCommandLineOptions options) {
        this.node = nodeBuilder().client(true).clusterName(options.clusterName).node();
        this.client = node.client();
        return new ElasticSearchIdAndVersionStream(new ElasticSearchDownloader(client, options.indexName, options.query, idAndVersionFactory), new ElasticSearchSorter(createSorter()), new IteratorFactory(idAndVersionFactory), SystemUtils.getJavaIoTmpDir().getAbsolutePath());
    }
View Full Code Here

Examples of com.aconex.scrutineer.elasticsearch.ElasticSearchDownloader

93
94
95
96
97
98
99
    }

    ElasticSearchIdAndVersionStream createElasticSearchIdAndVersionStream(ScrutineerCommandLineOptions options) {
        this.node = nodeBuilder().client(true).clusterName(options.clusterName).node();
        this.client = node.client();
        return new ElasticSearchIdAndVersionStream(new ElasticSearchDownloader(client, options.indexName, options.query), new ElasticSearchSorter(createSorter()), new IteratorFactory(), SystemUtils.getJavaIoTmpDir().getAbsolutePath());
    }
View Full Code Here

Examples of com.aconex.scrutineer.elasticsearch.ElasticSearchDownloader

68
69
70
71
72
73
74
75
76
77
78
        ElasticSearchSorter elasticSearchSorter = new ElasticSearchSorter(createSorter(factory));
        IteratorFactory iteratorFactory = new IteratorFactory(factory);
        String workingDirectory = SystemUtils.getJavaIoTmpDir().getAbsolutePath();

        ElasticSearchIdAndVersionStream esStream = new ElasticSearchIdAndVersionStream(
            new ElasticSearchDownloader(client, indexName, "_type:" + mapping.getTypeAlias(), factory),
            elasticSearchSorter, iteratorFactory, workingDirectory);

        BulkIndexHelper bulkHelper = new BulkIndexHelper().setMaxRunning(2);
        bulkHelper.setResponseHandler(new BulkIndexHelper.IResponseHandler() {
View Full Code Here

Examples of com.aconex.scrutineer.elasticsearch.ElasticSearchDownloader

70
71
72
73
74
75
76
77
78
79
80
        ElasticSearchSorter elasticSearchSorter = new ElasticSearchSorter(createSorter(factory));
        IteratorFactory iteratorFactory = new IteratorFactory(factory);
        String workingDirectory = SystemUtils.getJavaIoTmpDir().getAbsolutePath();

        ElasticSearchIdAndVersionStream esStream = new ElasticSearchIdAndVersionStream(
            new ElasticSearchDownloader(client, indexName, "_type:" + mapping.getTypeAlias(), factory),
            elasticSearchSorter, iteratorFactory, workingDirectory);

        BulkIndexHelper bulkHelper = new BulkIndexHelper().setMaxRunning(2);
        bulkHelper.setResponseHandler(new BulkIndexHelper.IResponseHandler() {
View Full Code Here

Examples of com.aconex.scrutineer.elasticsearch.ElasticSearchDownloader

74
75
76
77
78
79
80
81
82
83
84
        ElasticSearchSorter elasticSearchSorter = new ElasticSearchSorter(createSorter(factory));
        IteratorFactory iteratorFactory = new IteratorFactory(factory);
        String workingDirectory = SystemUtils.getJavaIoTmpDir().getAbsolutePath();

        ElasticSearchIdAndVersionStream esStream = new ElasticSearchIdAndVersionStream(
            new ElasticSearchDownloader(client, indexName, "_type:" + mapping.getTypeAlias(), factory),
            elasticSearchSorter, iteratorFactory, workingDirectory);

        long start = System.currentTimeMillis();

        BulkIndexHelper h = new BulkIndexHelper().setMaxRunning(2);
View Full Code Here

Examples of com.aconex.scrutineer.elasticsearch.ElasticSearchDownloader

127
128
129
130
131
132
133
    }

    ElasticSearchIdAndVersionStream createElasticSearchIdAndVersionStream(ScrutineerCommandLineOptions options) {
        this.node = new NodeFactory().createNode(options);
        this.client = node.client();
        return new ElasticSearchIdAndVersionStream(new ElasticSearchDownloader(client, options.indexName, options.query, idAndVersionFactory), new ElasticSearchSorter(createSorter()), new IteratorFactory(idAndVersionFactory), SystemUtils.getJavaIoTmpDir().getAbsolutePath());
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.