Class QueueItem
- java.lang.Object
-
- com.snowflake.connectors.taskreactor.queue.QueueItem
-
public class QueueItem extends Object
Representation of an item inserted into a task reactor queue.
-
-
Field Summary
Fields Modifier and Type Field Description boolean
cancelOngoingExecution
Should ongoing executions of the resource ingestion be cancelled.String
id
Item id.String
resourceId
Ingested resource id.Timestamp
timestamp
Item insertion timestamp.Variant
workerPayload
Additional payload for the worker
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static QueueItem
fromMap(Map<String,Variant> map)
Creates a new queue item from a specified map.static QueueItem
fromRow(Row row)
Creates a new queue item from a specified row.
-
-
-
Field Detail
-
id
public final String id
Item id.
-
timestamp
public final Timestamp timestamp
Item insertion timestamp.
-
resourceId
public final String resourceId
Ingested resource id.
-
cancelOngoingExecution
public final boolean cancelOngoingExecution
Should ongoing executions of the resource ingestion be cancelled.
-
workerPayload
public final Variant workerPayload
Additional payload for the worker
-
-