Package org.apache.ignite.example.streaming

Class DetectFailedEntriesExample

java.lang.Object

org.apache.ignite.example.streaming.DetectFailedEntriesExample

public class DetectFailedEntriesExample
extends Object

This example demonstrates how to use the streaming API to catch both asynchronous errors during background streaming and immediate submission errors. If data streamer fails to process any entries, it collects the failed items in a DataStreamerException.

Constructor Summary

Constructors

Constructor	Description
DetectFailedEntriesExample()

Method Summary

Modifier and Type	Method	Description
static void	main(String[] arg)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DetectFailedEntriesExample

public DetectFailedEntriesExample()

Method Details

main

public static void main(String[] arg)