Package org.elasticsearch.hadoop.rest

Examples of org.elasticsearch.hadoop.rest.Resource

105
106
107
108
109
110
111
112
113
114
115
                return createJsonFieldExtractor(fieldName, jsonPaths);
            }
        };
        indexExtractor.setSettings(settings);

        indexExtractor.compile(new Resource(settings, false).toString());

        // if there's no pattern, simply remove it
        indexExtractor = (indexExtractor.hasPattern() ? indexExtractor : null);

        if (settings.hasUpdateScriptParams()) {
View Full Code Here
181
182
183
184
185
186
187
188
189
190
191
                        settings.getMappingTimestampExtractorClassName(), settings);
            }

            // create adapter
            IndexExtractor iformat = ObjectUtils.<IndexExtractor> instantiate(settings.getMappingIndexExtractorClassName(), settings);
            iformat.compile(new Resource(settings, false).toString());

            if (iformat.hasPattern()) {
                indexExtractor = iformat;
            }
View Full Code Here
62
63
64
65
66
67
68
69
70
71
    public void testEmptyBulkWrite() throws Exception {
        TestSettings testSettings = new TestSettings("rest/emptybulk");
        testSettings.setProperty(ConfigurationOptions.ES_SERIALIZATION_WRITER_VALUE_CLASS, JdkValueWriter.class.getName());
        RestRepository restRepo = new RestRepository(testSettings);
        RestClient client = restRepo.getRestClient();
        client.bulk(new Resource(testSettings, false), new TrackingBytesArray(new BytesArray("{}")));
        restRepo.waitForYellow();
        restRepo.close();
        client.close();
    }
View Full Code Here
187
188
189
190
191
192
193
194
195
196
197
            settings.setProperty(InternalConfigurationOptions.INTERNAL_ES_HOSTS, StringUtils.concatenate(nodes, ","));

            beat = new HeartBeat(progressable, cfg, settings.getHeartBeatLead(), log);
            beat.start();

            resource = new Resource(settings, false);

            // single index vs multi indices
            IndexExtractor iformat = ObjectUtils.instantiate(settings.getMappingIndexExtractorClassName(), settings);
            iformat.compile(resource.toString());
            if (iformat.hasPattern()) {
View Full Code Here
181
182
183
184
185
186
187
188
189
190
191
                        settings.getMappingTimestampExtractorClassName(), settings);
            }

            // create adapter
            IndexExtractor iformat = ObjectUtils.<IndexExtractor> instantiate(settings.getMappingIndexExtractorClassName(), settings);
            iformat.compile(new Resource(settings, false).toString());

            if (iformat.hasPattern()) {
                indexExtractor = iformat;
            }
View Full Code Here
TOP

Related Classes of org.elasticsearch.hadoop.rest.Resource

  • org.elasticsearch.hadoop.integration.rest.AbstractRestSaveTest
  • org.elasticsearch.hadoop.mr.EsOutputFormat$EsRecordWriter
  • org.elasticsearch.hadoop.serialization.bulk.AbstractBulkFactory
  • org.elasticsearch.hadoop.serialization.field.JsonFieldExtractors
  • org.elasticsearch.hadoop.EsHadoopIllegalArgumentException
    • Copyright © 2018 www.massapicom. 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.