@Test public void testAvroClassConversion() { validateUserSchema(AvroSchemaConverter.convertToTypeInfo(User.class)); }
@SuppressWarnings("unchecked") public static <T extends SpecificRecord> TypeInformation<Row> convertToTypeInfo(Class<T> avroClass) { Preconditions.checkNotNull(avroClass, "Avro specific record class must not be null."); final Schema schema = SpecificData.get().getSchema(avroClass); return (TypeInformation<Row>) convertToTypeInfo(schema); }
AvroSchemaConverter { @SuppressWarnings("unchecked") public static <T extends SpecificRecord> TypeInformation<Row> convertToTypeInfo(Class<T> avroClass) { Preconditions.checkNotNull(avroClass, "Avro specific record class must not be null."); final Schema schema = SpecificData.get().getSchema(avroClass); return (TypeInformation<Row>) convertToTypeInfo(schema); } }
AvroSchemaConverter { @SuppressWarnings("unchecked") public static <T extends SpecificRecord> TypeInformation<Row> convertToTypeInfo(Class<T> avroClass) { Preconditions.checkNotNull(avroClass, "Avro specific record class must not be null."); final Schema schema = SpecificData.get().getSchema(avroClass); return (TypeInformation<Row>) convertToTypeInfo(schema); } private  AvroSchemaConverter(); }
AvroSchemaConverter { @SuppressWarnings("unchecked") public static <T extends SpecificRecord> TypeInformation<Row> convertToTypeInfo(Class<T> avroClass) { Preconditions.checkNotNull(avroClass, "Avro specific record class must not be null."); final Schema schema = SpecificData.get().getSchema(avroClass); return (TypeInformation<Row>) convertToTypeInfo(schema); } private  AvroSchemaConverter(); @SuppressWarnings("unchecked") static TypeInformation<Row> convertToTypeInfo(Class<T> avroClass); @SuppressWarnings("unchecked") static TypeInformation<T> convertToTypeInfo(String avroSchemaString); }
AvroSchemaConverter { @SuppressWarnings("unchecked") public static <T extends SpecificRecord> TypeInformation<Row> convertToTypeInfo(Class<T> avroClass) { Preconditions.checkNotNull(avroClass, "Avro specific record class must not be null."); final Schema schema = SpecificData.get().getSchema(avroClass); return (TypeInformation<Row>) convertToTypeInfo(schema); } private  AvroSchemaConverter(); @SuppressWarnings("unchecked") static TypeInformation<Row> convertToTypeInfo(Class<T> avroClass); @SuppressWarnings("unchecked") static TypeInformation<T> convertToTypeInfo(String avroSchemaString);  }