Package org.apache.avro.Schema

Examples of org.apache.avro.Schema.Field.schema()

315
316
317
318
319
320
321
322
323
324
325
    assertEquals(Schema.Type.STRING, response.getTypes().get(1).getType());
    // check request schema is union
    Schema request = message.getRequest();
    Field field = request.getField("s");
    assertNotNull("field 's' should not be null", field);
    Schema param = field.schema();
    assertEquals(Schema.Type.UNION, param.getType());
    assertEquals(Schema.Type.NULL, param.getTypes().get(0).getType());
    assertEquals(Schema.Type.STRING, param.getTypes().get(1).getType());
    // check union erasure
    assertEquals(String.class, ReflectData.get().getClass(response));
View Full Code Here
336
337
338
339
340
341
342
343
344
345
346
    Schema e1 = ReflectData.get().getSchema(E1.class);
    assertEquals(Schema.Type.RECORD, e1.getType());
    assertTrue(e1.isError());
    Field message = e1.getField("detailMessage");
    assertNotNull("field 'detailMessage' should not be null", message);
    Schema messageSchema = message.schema();
    assertEquals(Schema.Type.UNION, messageSchema.getType());
    assertEquals(Schema.Type.NULL, messageSchema.getTypes().get(0).getType());
    assertEquals(Schema.Type.STRING, messageSchema.getTypes().get(1).getType());

    Protocol p2 = ReflectData.get().getProtocol(P2.class);
View Full Code Here
322
323
324
325
326
327
328
329
330
331
332
            /* get schema */
            Schema fieldSchema = null;
            if (inputField == null) {
                /* convert pig schema (nullable) */
                fieldSchema = convert(pigFields[i], true);
            } else if (inputField.schema() == null) {
                /* convert pig schema (not-null) */
                fieldSchema = convert(pigFields[i], false);
            } else {
                /* validate pigFields[i] with given avro schema */
                fieldSchema = validateAndConvert(inputField.schema(),
View Full Code Here
327
328
329
330
331
332
333
334
335
336
337
            } else if (inputField.schema() == null) {
                /* convert pig schema (not-null) */
                fieldSchema = convert(pigFields[i], false);
            } else {
                /* validate pigFields[i] with given avro schema */
                fieldSchema = validateAndConvert(inputField.schema(),
                                                pigFields[i]);
            }

            /* get field name of output */
            String outname = (isPartialSchema) ? pigFields[i].getName() : inputField.name();
View Full Code Here
239
240
241
242
243
244
245
246
247
248
249
    assertEquals(Schema.Type.STRING, response.getTypes().get(1).getType());
    // check request schema is union
    Schema request = message.getRequest();
    Field field = request.getField("s");
    assertNotNull("field 's' should not be null", field);
    Schema param = field.schema();
    assertEquals(Schema.Type.UNION, param.getType());
    assertEquals(Schema.Type.NULL, param.getTypes().get(0).getType());
    assertEquals(Schema.Type.STRING, param.getTypes().get(1).getType());
    // check union erasure
    assertEquals(String.class, ReflectData.get().getClass(response));
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
      TypeInfo typeInfo = columnTypes.get(i);
      StructField structFieldRef = allStructFieldRefs.get(i);
      Object structFieldData = structFieldsDataAsList.get(i);
      ObjectInspector fieldOI = structFieldRef.getFieldObjectInspector();

      Object val = serialize(typeInfo, fieldOI, structFieldData, field.schema());
      record.put(field.name(), val);
    }

    if(!GenericData.get().validate(schema, record))
      throw new SerializeToAvroException(schema, record);
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
      TypeInfo colTypeInfo = allStructFieldTypeInfos.get(i);
      StructField structFieldRef = allStructFieldRefs.get(i);
      Object structFieldData = structFieldsDataAsList.get(i);
      ObjectInspector fieldOI = structFieldRef.getFieldObjectInspector();

      Object val = serialize(colTypeInfo, fieldOI, structFieldData, field.schema());
      record.put(field.name(), val);
    }
    return record;
  }
View Full Code Here
251
252
253
254
255
256
257
258
259
260
261
        if (hcol == null) {
          throw new RuntimeException("HBase mapping for field ["
              + persistent.getClass().getName() + "#" + field.name()
              + "] not found. Wrong gora-hbase-mapping.xml?");
        }
        addPutsAndDeletes(put, delete, o, field.schema().getType(),
            field.schema(), hcol, hcol.getQualifier());
      }
      if (put.size() > 0) {
        table.put(put);
      }
View Full Code Here
252
253
254
255
256
257
258
259
260
261
262
          throw new RuntimeException("HBase mapping for field ["
              + persistent.getClass().getName() + "#" + field.name()
              + "] not found. Wrong gora-hbase-mapping.xml?");
        }
        addPutsAndDeletes(put, delete, o, field.schema().getType(),
            field.schema(), hcol, hcol.getQualifier());
      }
      if (put.size() > 0) {
        table.put(put);
      }
      if (delete.size() > 0) {
View Full Code Here
621
622
623
624
625
626
627
628
629
630
631
      if (col == null) {
        throw new  RuntimeException("HBase mapping for field ["+ f +"] not found. " +
            "Wrong gora-hbase-mapping.xml?");
      }
      Field field = fieldMap.get(f);
      Schema fieldSchema = field.schema();
      setField(result,persistent, col, field, fieldSchema);
    }
    persistent.clearDirty();
    return persistent;
  }
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.