Created class inside KettleElementType.java that stores the rows as they are read. Created new ConcurrentHashMap to store the rows of a given kettle. Key=kettlePath and Value=KettleOutput