Package org.elasticsearch.hadoop.serialization.Parser

Examples of org.elasticsearch.hadoop.serialization.Parser.Token

223
224
225
226
227
228
229
230
231
232
233
        parser.nextToken();
        return obj;
    }

    protected Object list(String fieldMapping) {
        Token t = parser.currentToken();

        if (t == null) {
            t = parser.nextToken();
        }
        if (t == Token.START_ARRAY) {
View Full Code Here
247
248
249
250
251
252
253
254
255
256
257
        array = reader.addToArray(array, content);
        return array;
    }

    protected Object map(String fieldMapping) {
        Token t = parser.currentToken();

        if (t == null) {
            t = parser.nextToken();
        }
        if (t == Token.START_OBJECT) {
View Full Code Here
289
290
291
292
293
294
295
296
297
298
299
300
        if (esType != null) {
            return esType;
        }

        // fall back to JSON
        Token currentToken = parser.currentToken();
        if (!currentToken.isValue()) {
            // nested type
            return FieldType.OBJECT;
        }

        switch (currentToken) {
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
    public static Token seek(Parser parser, String[] path1, String[] path2) {
        return doSeekToken(parser, path1, 0, path2, 0);
    }

    private static Token doSeekToken(Parser parser, String[] path1, int index1, String[] path2, int index2) {
        Token token = null;

        String currentName;
        token = parser.currentToken();
        if (token == null) {
            token = parser.nextToken();
View Full Code Here
147
148
149
150
151
152
153
154
155
156
157
        return matches;
    }

    private static void doFind(Parser parser, List<Matcher> current, List<Matcher> active, Set<Matcher> inactive) {
        Token token = null;
        List<Matcher> matchingCurrentLevel = null;

        String currentName;
        token = parser.currentToken();
        if (token == null) {
View Full Code Here
228
229
230
231
232
233
234
235
236
237
238
        generator.close();
        return out.toString();
    }

    private static void traverse(Parser parser, Generator generator) {
        Token t = parser.currentToken();
        switch (t) {
        case START_OBJECT:
            traverseMap(parser, generator);
            break;
        case START_ARRAY:
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
        if (hits() == 0) {
            return null;
        }

        // move to hits/hits
        Token token = ParsingUtils.seek(parser, HITS);

        // move through the list and for each hit, extract the _id and _source
        Assert.isTrue(token == Token.START_ARRAY, "invalid response");

        List<Object[]> results = new ArrayList<Object[]>();
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
        return results;
    }

    private Object[] readHit() {
        Token t = parser.currentToken();
        Assert.isTrue(t == Token.START_OBJECT, "expected object, found " + t);
        Assert.notNull(ParsingUtils.seek(parser, ID), "no id found");
        Object[] result = new Object[2];
        result[0] = parser.text();
        Token seek = ParsingUtils.seek(parser, SOURCE, FIELDS);
        // no fields found
        result[1] = (seek == null ? Collections.emptyMap() : read(t, null));

        if (trace) {
            log.trace(String.format("Read hit result [%s]=[%s]", result[0], result[1]));
View Full Code Here
155
156
157
158
159
160
161
162
163
164
165
        parser.nextToken();
        return obj;
    }

    protected Object list(String fieldMapping) {
        Token t = parser.currentToken();

        if (t == null) {
            t = parser.nextToken();
        }
        if (t == Token.START_ARRAY) {
View Full Code Here
179
180
181
182
183
184
185
186
187
188
189
        array = reader.addToArray(array, content);
        return array;
    }

    protected Object map(String fieldMapping) {
        Token t = parser.currentToken();

        if (t == null) {
            t = parser.nextToken();
        }
        if (t == Token.START_OBJECT) {
View Full Code Here
TOP

Related Classes of org.elasticsearch.hadoop.serialization.Parser.Token

  • org.elasticsearch.hadoop.serialization.builder.JdkValueReader
  • org.elasticsearch.hadoop.serialization.ParsingUtils
  • org.elasticsearch.hadoop.serialization.ScrollReader
    • 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.