Namespace Apache.Ignite.Table
Classes
- ContinuousQueryEventWatermark
Event watermark. Represents a starting point for a continuous query based on previous event.
- ContinuousQueryOptions
Continuous query options.
- ContinuousQueryPhysicalTimeWatermark
Physical time watermark. Represents a starting point for a continuous query.
- ContinuousQueryTransactionWatermark
Continuous query watermark based on a transaction read timestamp.
See more details in AfterTransaction(ITransaction).
- DataStreamerException
Represents an exception that is thrown during data streaming. Includes information about failed items.
- DataStreamerItem
Creates instances of the DataStreamerItem<T> struct.
- DataStreamerOptions
Data streamer options.
- IgniteTuple
Ignite tuple.
- QualifiedName
Represents a qualified name of a database object.
Schema name and object name should conform to SQL syntax rules for identifiers.- Identifier must start from any character in the Unicode General Category classes “Lu”, “Ll”, “Lt”, “Lm”, “Lo”, or “Nl”.
- Identifier character (expect the first one) may be U+00B7 (middle dot), or any character in the Unicode General Category classes “Mn”, “Mc”, “Nd”, “Pc”, or “Cf”.
- Identifier that contains any other characters must be quoted with double-quotes.
- Double-quote inside the identifier must be encoded as 2 consequent double-quote chars.
- ReceiverDescriptor
Receiver descriptor factory methods for .NET receivers.
- ReceiverDescriptor<TArg>
Stream receiver descriptor without results. If the specified receiver returns results, they will be discarded on the server.
- ReceiverDescriptor<TArg, TResult>
Stream receiver descriptor with a result type.
- ReceiverDescriptor<TItem, TArg, TResult>
Stream receiver descriptor with a result type.
- ReceiverExecutionOptions
Data streamer receiver execution options.
Structs
- ContinuousQueryPartitionPosition
Represents a part of the continuous query watermark.
- DataStreamerItem<T>
Data streamer item.
Interfaces
- IContinuousQuerySource<T>
Represents an object which can be queried continuously.
- IContinuousQueryWatermark
Continuous query watermark. Represents a starting point for a continuous query.
- IDataStreamerReceiverContext
Data streamer receiver execution context. See IDataStreamerReceiver<TItem, TArg, TResult>.
- IDataStreamerReceiver<TItem, TArg, TResult>
Data streamer receiver.
- IDataStreamerTarget<T>
Represents an entity that can be used as a target for streaming data.
- IIgniteTuple
Ignite Tuple.
Default implementation is IgniteTuple.
- IKeyValueView<TK, TV>
Key-value view provides access to table records in form of separate key and value parts.
- IPartition
Table partition.
- IPartitionDistribution
Partition distribution provides table partition information. This interface can be used to get all partitions of a table, the location of the primary replica of a partition, the partition for a specific table key.
- IPartitionManager
Partition manager provides table partition information.
- IRecordView<T>
Record view interface provides methods to access table records.
- ITable
Table view.
- ITableRowEventBatch<T>
Table row event batch.
- ITableRowEvent<T>
Table row event.
- ITables
Table management.
Enums
- DataStreamerOperationType
Data streamer operation type.
- TableRowEventType
Table row event type.