Skip to content

Commit

Permalink
0003142: Sync Columns Between Incoming and Outgoing Batch
Browse files Browse the repository at this point in the history
  • Loading branch information
maxwellpettit committed Jun 29, 2017
1 parent d75f894 commit fe3c89d
Showing 1 changed file with 0 additions and 2 deletions.
Expand Up @@ -100,7 +100,6 @@ protected String getAcknowledgementData(boolean requires13Format, String nodeId,
append(builder, WebConstants.ACK_DATABASE_MILLIS + batchId, batch.getLoadMillis());
append(builder, WebConstants.ACK_START_TIME + batchId, batch.getStartTime());
append(builder, WebConstants.ACK_BYTE_COUNT + batchId, batch.getByteCount());
// TODO: Implement new ACKs
append(builder, WebConstants.ACK_LOAD_ROW_COUNT + batchId, batch.getLoadRowCount());
append(builder, WebConstants.ACK_LOAD_INSERT_ROW_COUNT + batchId, batch.getLoadInsertRowCount());
append(builder, WebConstants.ACK_LOAD_UPDATE_ROW_COUNT + batchId, batch.getLoadUpdateRowCount());
Expand Down Expand Up @@ -182,7 +181,6 @@ private static BatchAck getBatchInfo(Map<String, ? extends Object> parameters, l
batchInfo.setFilterMillis(getParamAsNum(parameters, WebConstants.ACK_FILTER_MILLIS + batchId));
batchInfo.setLoadMillis(getParamAsNum(parameters, WebConstants.ACK_DATABASE_MILLIS + batchId));
batchInfo.setByteCount(getParamAsNum(parameters, WebConstants.ACK_BYTE_COUNT + batchId));
// TODO: Implement new ACKs
batchInfo.setLoadRowCount(getParamAsNum(parameters, WebConstants.ACK_LOAD_ROW_COUNT + batchId));
batchInfo.setLoadInsertRowCount(getParamAsNum(parameters, WebConstants.ACK_LOAD_INSERT_ROW_COUNT + batchId));
batchInfo.setLoadUpdateRowCount(getParamAsNum(parameters, WebConstants.ACK_LOAD_UPDATE_ROW_COUNT + batchId));
Expand Down

0 comments on commit fe3c89d

Please sign in to comment.