Class DataStreamerException
Represents an exception that is thrown during data streaming. Includes information about failed items.
[Serializable]
public class DataStreamerException : IgniteException, ISerializable
- Inheritance
-
DataStreamerException
- Implements
- Inherited Members
Constructors
DataStreamerException(Guid, int, string?, Exception, ISet<object>)
Initializes a new instance of the DataStreamerException class.
public DataStreamerException(Guid traceId, int code, string? message, Exception innerException, ISet<object> failedItems)
Parameters
traceId
GuidTrace id.
code
intCode.
message
stringMessage.
innerException
ExceptionInner exception.
failedItems
ISet<object>Failed items.
Properties
FailedItems
Gets the set of items that were not streamed to the cluster.
public ISet<object> FailedItems { get; }
Property Value
Methods
Create(Exception, IEnumerable)
Creates a new instance of DataStreamerException from the provided cause and failed items.
public static DataStreamerException Create(Exception cause, IEnumerable failedItems)
Parameters
cause
ExceptionCause.
failedItems
IEnumerableFailed items.
Returns
- DataStreamerException
Exception.