(Optional) Erweitern Sie die Zahl der Verbraucher - Amazon-Kinesis-Data-Streams
Nächste Schritte

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

(Optional) Erweitern Sie die Zahl der Verbraucher

Möglicherweise ist die Anwendung Tutorial: Verarbeiten Sie Aktiendaten in Echtzeit mit KPL und KCL 1.x bereits ausreichend für Ihre Zwecke. Dieser optionale Abschnitt zeigt, wie Sie den Konsumentencode erweitern können, um einem komplexeren Szenario gerecht zu werden.

Wenn Sie minütlich über die größten Verkaufsaufträge informiert werden möchten, können Sie die StockStats-Klasse an drei Stellen bearbeiten.

So erweitern Sie den Konsumenten

  1. Fügen Sie neue Instance-Variablen hinzu:

     // Ticker symbol of the stock that had the largest quantity of shares sold 
 private String largestSellOrderStock;
 // Quantity of shares for the largest sell order trade
 private long largestSellOrderQuantity;

  2. Fügen Sie folgenden Code zu hinz addStockTrade:

     if (type == TradeType.SELL) {
     if (largestSellOrderStock == null || trade.getQuantity() > largestSellOrderQuantity) {
         largestSellOrderStock = trade.getTickerSymbol();
         largestSellOrderQuantity = trade.getQuantity();
     }
 }

  3. Ändern Sie die toString-Methode, um die zusätzlichen Informationen zu drucken:

     public String toString() {
     return String.format(
             "Most popular stock being bought: %s, %d buys.%n" +
             "Most popular stock being sold: %s, %d sells.%n" +
             "Largest sell order: %d shares of %s.",
             getMostPopularStock(TradeType.BUY), getMostPopularStockCount(TradeType.BUY),
             getMostPopularStock(TradeType.SELL), getMostPopularStockCount(TradeType.SELL),
             largestSellOrderQuantity, largestSellOrderStock);
 }

Wenn Sie den Konsumenten jetzt ausführen (führen Sie auch den Produzenten), sollten Sie eine Ausgabe ähnlich der folgenden sehen:

 ****** Shard shardId-000000000001 stats for last 1 minute ******
  Most popular stock being bought: WMT, 27 buys.
  Most popular stock being sold: PTR, 14 sells.
  Largest sell order: 996 shares of BUD.
  ****************************************************************

Nächste Schritte

Bereinigen von -Ressourcen