Package org.apache.ignite.table

Class DataStreamerException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

org.apache.ignite.lang.IgniteException

org.apache.ignite.table.DataStreamerException

All Implemented Interfaces:

Serializable, TraceableException

public final class DataStreamerException
extends IgniteException

Represents an exception that is thrown during data streaming. Includes information about failed items.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
DataStreamerException(Set<?> failedItems, Throwable cause)	Constructor.
DataStreamerException(UUID traceId, int code, String message, @Nullable Throwable cause)	Creates an exception with the given trace ID, error code, detailed message, and cause.

Method Summary

Modifier and Type	Method	Description
Set<?>	failedItems()	Gets the set of items that were not streamed to the cluster.

Methods inherited from class org.apache.ignite.lang.IgniteException

code, codeAsString, errorCode, groupCode, groupName, toString, traceId

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace

Methods inherited from class java.lang.Object

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

Constructor Details

DataStreamerException

public DataStreamerException(Set<?> failedItems,
 Throwable cause)

Constructor.

Parameters:

failedItems - Set of failed items.

cause - Cause of the exception.

DataStreamerException

public DataStreamerException(UUID traceId,
 int code,
 String message,
 @Nullable
 @Nullable Throwable cause)

Creates an exception with the given trace ID, error code, detailed message, and cause.

Parameters:

traceId - Unique identifier of the exception.

code - Full error code.

message - Detailed message.

cause - Optional nested exception (can be null).

Method Details

failedItems

public Set<?> failedItems()

Gets the set of items that were not streamed to the cluster.

Returns:

Set of failed items.