Merge pull request #23 from matthewtckr/suspended

Update Suspended Tickets Output step
matthewtckr · Mar 21, 2017 · bd31a8f · bd31a8f
2 parents 47159c7 + b07f57b
commit bd31a8f
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/src/main/java/org/pentaho/di/trans/steps/zendesk/ZendeskOutputSuspendedTickets.java b/src/main/java/org/pentaho/di/trans/steps/zendesk/ZendeskOutputSuspendedTickets.java
@@ -57,6 +57,8 @@ public boolean processRow( StepMetaInterface smi, StepDataInterface sdi ) throws
     if ( first ) {
       data.ticketFieldNameIndex = getInputRowMeta().indexOfValue( meta.getTicketFieldName() );
       first = false;
+      data.outputRowMeta = getInputRowMeta().clone();
+      meta.getFields( data.outputRowMeta, getStepname(), null, null, this, repository, metaStore );
     }
 
     Long ticketId = (Long) r[data.ticketFieldNameIndex];
@@ -65,6 +67,7 @@ public boolean processRow( StepMetaInterface smi, StepDataInterface sdi ) throws
         data.conn.deleteSuspendedTicket( ticketId );
         break;
     }
+    putRow( data.outputRowMeta, r );
     return true;
   }
 

diff --git a/src/main/java/org/pentaho/di/trans/steps/zendesk/ZendeskOutputSuspendedTicketsData.java b/src/main/java/org/pentaho/di/trans/steps/zendesk/ZendeskOutputSuspendedTicketsData.java
@@ -22,7 +22,10 @@
 
 package org.pentaho.di.trans.steps.zendesk;
 
+import org.pentaho.di.core.row.RowMetaInterface;
+
 public class ZendeskOutputSuspendedTicketsData extends ZendeskInputData {
 
   int ticketFieldNameIndex;
+  RowMetaInterface outputRowMeta;
 }