RecordSchemaBuilder recordSchemaBuilder = SchemaBuilder.record("schemaName");
recordSchemaBuilder
.field("intField")
.type(SchemaType.INT32);
SchemaInfo schemaInfo = recordSchemaBuilder.build(SchemaType.AVRO);
Schema<GenericRecord> schema = Schema.generic(schemaInfo);
Created
July 9, 2019 07:36
-
-
Save sijie/c42b7eef78f7fb838e28e3affde53abd to your computer and use it in GitHub Desktop.
Generic Schema Example
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment