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 detect the entries that the data streamer failed to process.

The streamer applies entries in the background, so failures are not reported by submit(). Instead, the streamer collects every entry it could not apply and completes the future returned by streamData() with a DataStreamerException that exposes them through failedItems().

To produce a failure, the example streams one account whose name is longer than the NAME column can hold. The remaining accounts are valid and are applied normally.

Constructor Summary

Constructors

Constructor	Description
DetectFailedEntriesExample()

Method Summary

Modifier and Type	Method	Description
static void	main(String[] arg)	Runs the DetectFailedEntriesExample.

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)

Runs the DetectFailedEntriesExample.

Parameters:

arg - The command line arguments.