public TableRow apply()

in order-book-pipeline/src/main/java/com/google/cloud/dataflow/orderbook/ProcessingStatusToTableRowConverter.java [28:43]

• 16 lines of code
• 1 McCabe index (conditional complexity)

  public TableRow apply(KV<SessionContractKey, OrderedProcessingStatus> input) {
    TableRow result = new TableRow();
    OrderedProcessingStatus status = input.getValue();
    result.set("session_id", input.getKey().getSessionId());
    result.set("contract_id", input.getKey().getContractId());
    result.set("status_ts", status.getStatusDate());
    result.set("received_count", status.getNumberOfReceivedEvents());
    result.set("buffered_count", status.getNumberOfBufferedEvents());
    result.set("last_processed_sequence", status.getLastProcessedSequence());
    result.set("earliest_buffered_sequence", status.getEarliestBufferedSequence());
    result.set("latest_buffered_sequence", status.getLatestBufferedSequence());
    result.set("duplicate_count", status.getDuplicateCount());
    result.set("result_count", status.getResultCount());
    result.set("last_event_received", status.isLastEventReceived());
    return result;
  }