- AWS Code Sample

This version of the AWS Code Sample Catalog has been replaced by the AWS Code Library, which contains new and updated code examples. is a helper class


To run this Java (SDK V2) code example, ensure that you have set up your development environment, including your credentials. For more information, see AWS SDK for Java 2.x Developer Guide.

/* Copyright, Inc. or its affiliates. All Rights Reserved. SPDX-License-Identifier: Apache-2.0 */ package com.example.firehose; import; import com.fasterxml.jackson.databind.DeserializationFeature; import com.fasterxml.jackson.databind.ObjectMapper; /** * Captures the key elements of a stock trade, such as the ticker symbol, price, * number of shares, the type of the trade (buy or sell), and an id uniquely identifying * the trade. */ public class StockTrade { private final static ObjectMapper JSON = new ObjectMapper(); static { JSON.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false); } /** * Represents the type of the stock trade eg buy or sell. */ public enum TradeType { BUY, SELL } private String tickerSymbol; private TradeType tradeType; private double price; private long quantity; private long id; public StockTrade() { } public StockTrade(String tickerSymbol, TradeType tradeType, double price, long quantity, long id) { this.tickerSymbol = tickerSymbol; this.tradeType = tradeType; this.price = price; this.quantity = quantity; = id; } public String getTickerSymbol() { return tickerSymbol; } public TradeType getTradeType() { return tradeType; } public double getPrice() { return price; } public long getQuantity() { return quantity; } public long getId() { return id; } public byte[] toJsonAsBytes() { try { return JSON.writeValueAsBytes(this); } catch (IOException e) { return null; } } public static StockTrade fromJsonAsBytes(byte[] bytes) { try { return JSON.readValue(bytes, StockTrade.class); } catch (IOException e) { return null; } } @Override public String toString() { return String.format("ID %d: %s %d shares of %s for $%.02f", id, tradeType, quantity, tickerSymbol, price); } }

Sample Details

Service: Amazon Kinesis Data Firehose