I am trying to create a custom component that will accept dynamic schema inputs and create the extract in a particular format. But when doing getSchema using Record Interface its not returning columns with null values and 1 or 2 columns are coming twice. So for each row i am getting different no of columns in the getSchema method.
@ElementListener
public void onNext(
@Input final Record defaultInput,
@Output final OutputEmitter<Record> defaultOutput) {
// this is the method allowing you to handle the input(s) and emit the output(s)
// after some custom logic you put here, to send a value to next element you can use an
// output parameter and call emit(value).
System.out.println(defaultInput.getSchema());
