Hello @Oleksandr Zhelezniak , yes it's one of my test components.
The source code :
@Service
public class DemoComponentsService {
@DiscoverSchema(value = "CustomDataset")
public Schema discoverSchema(
@Option CustomDataset dataset,
final RecordBuilderFactory recordBuilderFactory) {
Schema.Builder schemaBuilder = recordBuilderFactory.newSchemaBuilder(
Schema.Type.RECORD);
Schema.Entry.Builder entryBuilder =
recordBuilderFactory.newEntryBuilder();
schemaBuilder.withEntry(
setSchemaEntry("col1", Schema.Type.STRING, entryBuilder));
schemaBuilder.withEntry(
setSchemaEntry("col2", Schema.Type.STRING, entryBuilder));
schemaBuilder.withEntry(
setSchemaEntry("col3", Schema.Type.STRING, entryBuilder));
schemaBuilder.withEntry(
setSchemaEntry("col4", Schema.Type.STRING, entryBuilder));
return schemaBuilder.build();
}
private Schema.Entry setSchemaEntry(
String fieldName, Schema.Type type, Schema.Entry.Builder entryBuilder) {
return entryBuilder.withName(
fieldName
).withType(
type
).withNullable(
false
).withComment(
"Comment text here"
).build();
}
}
Best regards
