Add remaining Schema support for AVRO records:
* Add support for SpecificRecord using ByteBuddy codegen. * Add helper methods for GenericRecord. * Fix uncovered bugs involving nullable support.
显示
- build.gradle 1 个添加, 0 个删除build.gradle
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/AvroSpecificRecordGetterFactory.java 30 个添加, 0 个删除...che/beam/sdk/schemas/AvroSpecificRecordGetterFactory.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/AvroSpecificRecordSchema.java 51 个添加, 0 个删除...org/apache/beam/sdk/schemas/AvroSpecificRecordSchema.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/AvroSpecificRecordUserTypeCreatorFactory.java 29 个添加, 0 个删除...sdk/schemas/AvroSpecificRecordUserTypeCreatorFactory.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java 4 个添加, 37 个删除...rg/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/JavaBeanSchema.java 5 个添加, 3 个删除...main/java/org/apache/beam/sdk/schemas/JavaBeanSchema.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/JavaFieldSchema.java 0 个添加, 6 个删除...ain/java/org/apache/beam/sdk/schemas/JavaFieldSchema.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java 8 个添加, 0 个删除...ore/src/main/java/org/apache/beam/sdk/schemas/Schema.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SetterBasedCreatorFactory.java 57 个添加, 0 个删除...rg/apache/beam/sdk/schemas/SetterBasedCreatorFactory.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AvroByteBuddyUtils.java 123 个添加, 0 个删除...org/apache/beam/sdk/schemas/utils/AvroByteBuddyUtils.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AvroSpecificRecordTypeInformationFactory.java 32 个添加, 0 个删除...hemas/utils/AvroSpecificRecordTypeInformationFactory.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AvroUtils.java 192 个添加, 51 个删除...ain/java/org/apache/beam/sdk/schemas/utils/AvroUtils.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java 50 个添加, 0 个删除...ava/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/JavaBeanGetterFactory.java 2 个添加, 1 个删除.../apache/beam/sdk/schemas/utils/JavaBeanGetterFactory.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/JavaBeanTypeInformationFactory.java 2 个添加, 1 个删除...eam/sdk/schemas/utils/JavaBeanTypeInformationFactory.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/JavaBeanUtils.java 27 个添加, 16 个删除...java/org/apache/beam/sdk/schemas/utils/JavaBeanUtils.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/StaticSchemaInference.java 5 个添加, 1 个删除.../apache/beam/sdk/schemas/utils/StaticSchemaInference.java
- sdks/java/core/src/test/avro/org/apache/beam/sdk/schemas/test.avsc 29 个添加, 0 个删除.../core/src/test/avro/org/apache/beam/sdk/schemas/test.avsc
- sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/AvroSchemaTest.java 162 个添加, 0 个删除...test/java/org/apache/beam/sdk/schemas/AvroSchemaTest.java
- sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/utils/AvroUtilsTest.java 39 个添加, 2 个删除...java/org/apache/beam/sdk/schemas/utils/AvroUtilsTest.java
加载中
想要评论请 注册 或 登录