Package com.linkedin.data.schema

Examples of com.linkedin.data.schema.DataSchema

35
36
37
38
39
40
41
42
  }

  @Override
  public boolean evaluate(DataElement element)
  {
    DataSchema schema = element.getSchema();
    return (schema != null && schema instanceof NamedDataSchema && ((NamedDataSchema) schema).getFullName().equals(_name));
  }
View Full Code Here
123
124
125
126
127
128
129
130
131
132
133
    }
    else
    {
      key = _map.keySet().iterator().next();
    }
    DataSchema memberType = _schema.getType(key);
    if (memberType == null)
    {
      throw new TemplateOutputCastException(key + " is not a member of " + _schema);
    }
    return memberType;
View Full Code Here
263
264
265
266
267
268
269
270
271
272
273
   */
  protected <T> void selectDirect(DataSchema memberSchema, Class<T> memberClass, Class<?> dataClass, String key, T value)
      throws ClassCastException, NullUnionUnsupportedOperationException
  {
    checkNotNull();
    DataSchema memberType = _schema.getType(key);
    assert(memberType != null); // something is wrong with the generated code if this occurs.
    Object object = DataTemplateUtil.coerceInput(value, memberClass, dataClass);
    _map.clear();
    _map.put(key, object);
  }
View Full Code Here
287
288
289
290
291
292
293
294
295
296
297
   */
  protected <T extends DataTemplate<?>> void selectWrapped(DataSchema memberSchema, Class<T> memberClass, String key, T value)
      throws ClassCastException, NullUnionUnsupportedOperationException
  {
    checkNotNull();
    DataSchema memberType = _schema.getType(key);
    assert(memberType != null); // something is wrong with the generated code if this occurs.
    if (value.getClass() != memberClass)
    {
      throw new ClassCastException("Input " + value + " should be a " + memberClass.getName());
    }
View Full Code Here
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
   * @param type to get a schema for. Has to be primitive or a generated data template.
   * @throws TemplateRuntimeException if the {@link DataSchema} for the specified type cannot be provided.
   */
  public static DataSchema getSchema(Class<?> type) throws TemplateRuntimeException
  {
    final DataSchema primitiveSchema = DataSchemaUtil.classToPrimitiveDataSchema(type);
    if (primitiveSchema != null)
    {
      return primitiveSchema;
    }

    try
    {
      Field schemaField = type.getDeclaredField(SCHEMA_FIELD_NAME);
      schemaField.setAccessible(true);
      DataSchema schema = (DataSchema) schemaField.get(null);
      if (schema == null)
      {
        throw new TemplateRuntimeException("Class missing schema: " + type.getName());
      }

View Full Code Here
383
384
385
386
387
388
389
390
391
392
393
   * Gets the data schema name for a given java type.
   * @param type to get a schema for. Has to be a named data type.
   */
  public static String getSchemaName(Class<?> type)
  {
    DataSchema schema = getSchema(type);
    if (! (schema instanceof NamedDataSchema))
    {
      throw new TemplateRuntimeException("Class' schema is unnamed: " + type.getName());
    }

View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
    try
    {
      assertTrue(Enum.class.isAssignableFrom(enumClass));

      // has embedded EnumDataSchema
      DataSchema schema = DataTemplateUtil.getSchema(enumClass);
      assertNotNull(schema);
      assertTrue(schema instanceof EnumDataSchema);

      // get symbols
      EnumDataSchema enumSchema = (EnumDataSchema) schema;
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
  @Test
  public void testCustomAnyRecordSchema()
  {
    RecordDataSchema schemaFromInstance = (new AnyRecord()).schema();
    DataSchema schemaFromClass = DataTemplateUtil.getSchema(AnyRecord.class);
    assertSame(schemaFromClass, schemaFromInstance);

    CustomAnyRecord custom = new CustomAnyRecord();
    RecordDataSchema customSchemaFromInstance = custom.schema();
    DataSchema customSchemaFromClass = DataTemplateUtil.getSchema(CustomAnyRecord.class);
    assertSame(customSchemaFromClass, customSchemaFromInstance);

    assertEquals(customSchemaFromClass, schemaFromClass);
  }
View Full Code Here
520
521
522
523
524
525
526
527
  private ValidationResult validateEntity(ByteString entity,
                                          Class<? extends RecordTemplate> recordClass,
                                          ValidationOptions options) throws IOException
  {
    final DataMap respData = _codec.bytesToMap(entity.copyBytes());
    final DataSchema recordSchema = DataTemplateUtil.getSchema(recordClass);
    return ValidateDataAgainstSchema.validate(respData, recordSchema, options);
  }
View Full Code Here
532
533
534
535
536
537
538
539
540
541
542
                                              ValidationOptions options)
      throws IOException
  {
    final DataMap respData = _codec.bytesToMap(response.getEntity().copyBytes());
    final CollectionResponse<T> collResp = new CollectionResponse<T>(respData, recordClass);
    final DataSchema recordSchema = DataTemplateUtil.getSchema(recordClass);

    for (T record: collResp.getElements())
    {
      final ValidationResult valRet = ValidateDataAgainstSchema.validate(record.data(), recordSchema, options);
      if (!valRet.isValid())
View Full Code Here
TOP

Related Classes of com.linkedin.data.schema.DataSchema

  • com.linkedin.data.avro.DataTranslator$AvroGenericToDataTranslator
  • com.linkedin.data.avro.DataTranslator$DataMapToGenericRecordTranslator
  • com.linkedin.data.avro.SchemaToAvroJsonEncoder
  • com.linkedin.data.avro.SchemaTranslator
  • com.linkedin.data.avro.SchemaTranslator$AbstractDefaultDataTranslator
  • com.linkedin.data.avro.SchemaTranslator$AvroToDataSchemaConvertCallback
  • com.linkedin.data.avro.SchemaTranslator$DefaultAvroToDataConvertCallback
  • com.linkedin.data.avro.SchemaTranslator$DefaultDataToAvroConvertCallback
  • com.linkedin.data.avro.TestAvroOverrideFactory
  • com.linkedin.data.avro.TestCustomAvroSchema
    • 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.