Package org.apache.ignite.example.streaming

package org.apache.ignite.example.streaming
  • Classes
    Class
    Description
    Account
     
    DetectFailedEntriesExample
    This example demonstrates how to use the streaming API to catch both asynchronous errors during background streaming and immediate submission errors.
    DistributedComputeWithReceiverExample
    This example demonstrates how to use the streaming API to simulate a fraud detection process, which typically involves intensive processing of each transaction using ML models.
    MultiTableDataStreamerExample
    This example demonstrates how to use the streaming API to how to implement a receiver that processes data containing customer and address information, and updates two separate tables on the server.
    SingleTableDataStreamerExample
    This example demonstrates how to use the streaming API to configure the data streamer, insert account records into the existing Accounts table and then delete them.
    TwoTableReceiver
    Custom receiver class that extracts data from the provided source and write it into two separate tables: Customers and Addresses