@Test public void testAvroByDefault() { final TypeSerializer<User> serializer = new AvroTypeInfo<>(User.class).createSerializer(new ExecutionConfig()); assertTrue(serializer instanceof AvroSerializer); }
@Override @SuppressWarnings("deprecation") public TypeSerializer<T> createSerializer(ExecutionConfig config) { return new AvroSerializer<>(getTypeClass()); }
AvroTypeInfo extends PojoTypeInfo<T> { @Override @SuppressWarnings("deprecation") public TypeSerializer<T> createSerializer(ExecutionConfig config) { return new AvroSerializer<>(getTypeClass()); } }
AvroTypeInfo extends PojoTypeInfo<T> { @Override @SuppressWarnings("deprecation") public TypeSerializer<T> createSerializer(ExecutionConfig config) { return new AvroSerializer<>(getTypeClass()); } AvroTypeInfo(Class<T> typeClass); }
AvroTypeInfo extends PojoTypeInfo<T> { @Override @SuppressWarnings("deprecation") public TypeSerializer<T> createSerializer(ExecutionConfig config) { return new AvroSerializer<>(getTypeClass()); } AvroTypeInfo(Class<T> typeClass); @Override @SuppressWarnings("deprecation") TypeSerializer<T> createSerializer(ExecutionConfig config); }
AvroTypeInfo extends PojoTypeInfo<T> { @Override @SuppressWarnings("deprecation") public TypeSerializer<T> createSerializer(ExecutionConfig config) { return new AvroSerializer<>(getTypeClass()); } AvroTypeInfo(Class<T> typeClass); @Override @SuppressWarnings("deprecation") TypeSerializer<T> createSerializer(ExecutionConfig config);  }