remove boolean param to setCommit, rename to setTXCommit

src/main/java/com/zendesk/maxwell/MaxwellAbstractRowsEvent.java

@@ -30,7 +30,7 @@ public abstract class MaxwellAbstractRowsEvent extends AbstractRowEvent {
 	private final AbstractRowEvent event;
 
 	private Long xid;
-	private boolean commit; // whether this row ends the transaction
+	private boolean txCommit; // whether this row ends the transaction
 
 	protected final Table table;
 	protected final Database database;
@@ -41,7 +41,7 @@ public MaxwellAbstractRowsEvent(AbstractRowEvent e, Table table, MaxwellFilter f
 		this.header = e.getHeader();
 		this.table = table;
 		this.database = table.getDatabase();
-		this.commit = false;
+		this.txCommit = false;
 		this.xid = null;
 		this.filter = f;
 	}
@@ -98,12 +98,8 @@ public void setXid(Long xid) {
 		this.xid = xid;
 	}
 
-	public boolean isCommit() {
-		return commit;
-	}
-
-	public void setCommit(boolean commit) {
-		this.commit = commit;
+	public void setTXCommit() {
+		this.txCommit = true;
 	}
 
 
@@ -224,9 +220,8 @@ public void setXid(Long xid) {
 			this.put("xid", xid);
 		}
 
-		public void setCommit(boolean commit) {
-			if ( commit )
-				this.put("commit", commit);
+		public void setTXCommit() {
+			this.put("commit", true);
 		}
 
 		public Object getData(String string) {
@@ -246,7 +241,10 @@ public List<RowMap> jsonMaps() {
 			rowMap.setDatabase(getDatabase().getName());
 			rowMap.setTimestamp(getHeader().getTimestamp() / 1000);
 			rowMap.setXid(getXid());
-			rowMap.setCommit(isCommit() && !ri.hasNext());
+
+			// only set commit: true on the last row of the last event of the transaction
+			if ( this.txCommit && !ri.hasNext() )
+				rowMap.setTXCommit();
 
 			Iterator<Column> colIter = r.getColumns().iterator();
 			Iterator<ColumnDef> defIter = table.getColumnList().iterator();

src/main/java/com/zendesk/maxwell/MaxwellParser.java

@@ -197,7 +197,7 @@ private LinkedList<MaxwellAbstractRowsEvent> getTransactionEvents() throws Excep
 						e.setXid(xe.getXid());
 
 					if ( !list.isEmpty() )
-						list.getLast().setCommit(true);
+						list.getLast().setTXCommit();
 
 					return list;
 			}