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 booleancancelOngoingExecutionShould ongoing executions of the resource ingestion be cancelled.StringidItem id.StringresourceIdIngested resource id.TimestamptimestampItem insertion timestamp.VariantworkerPayloadAdditional payload for the worker
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static QueueItemfromMap(Map<String,Variant> map)Creates a new queue item from a specified map.static QueueItemfromRow(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
-
-