in order-book-pipeline/src/main/java/com/google/cloud/dataflow/orderbook/OrderBookCoder.java [66:74]
public OrderBookMutableState decode(InputStream inStream) throws IOException {
int depth = intCoder.decode(inStream);
boolean withTrade = booleanCoder.decode(inStream);
Map<Long, Long> prices = mapCoder.decode(inStream);
OrderBookEvent lastOrderBookEvent = orderBookEventCoder.decode(inStream);
OrderBookMutableState orderBookMutableState = new OrderBookMutableState(depth, withTrade,
prices, lastOrderBookEvent);
return orderBookMutableState;
}