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;
}