I am not sure is it possible or not.
I will just go ahead and explain my scenario
I have an HBase table in which I am recording HL7 messages. All the consecutive messages for a patient is one record in Hbase table.
Now I have find out all the patients who were in a given department during given time period, this part is simple.
After this I have to determine how long patient was in the department, was he transferred in or admitted, was patient transferred or discharged. This requires me to break the table into subset of patient with their consecutive messages. I am not sure with PDI I can achieve this.
Any suggestions please?