public TableRow apply()

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


  public TableRow apply(OrderBookEvent input) {
    TableRow result = new TableRow();
    result.set("session_id", input.getSessionId());
    result.set("contract_id", input.getContractId());
    result.set("event_ts", Instant.ofEpochMilli(input.getTimestampMS()));
    result.set("contract_sequence_id", input.getContractSeqId());
    result.set("last_contract_message", input.getLastContractMessage());
    result.set("order_type", input.getType().toString());
    result.set("order_id", input.getOrderId());
    result.set("side", input.getSide().toString());
    result.set("price", input.getPrice());
    result.set("quantity", input.getQuantity());
    result.set("quantity_remaining", input.getQuantityRemaining());
    result.set("quantity_filled", input.getQuantityFilled());
    result.set("match_number", input.getMatchNumber());
    return result;
  }