Unlock a world of possibilities! Login now and discover the exclusive benefits awaiting you.
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());
Hi,
I am also facing the same issue. I am also looking for a method to have column names populated just once, and call a method to do something after all rows of data are retrieved.
Any help would be appreciated.
Thanks
Can anyone please help on this issue