@Operator(group="io") public final class QueueEnqueue extends PrimitiveOp
The components input has k elements, which correspond to the components of tuples stored in the given queue.
N.B. If the queue is full, this operation will block until the given element has been enqueued (or 'timeout_ms' elapses, if specified).
Modifier and Type | Class and Description |
---|---|
static class |
QueueEnqueue.Options
Optional attributes for
QueueEnqueue |
operation
Modifier and Type | Method and Description |
---|---|
static QueueEnqueue |
create(Scope scope,
Operand<?> handle,
Iterable<Operand<?>> components,
QueueEnqueue.Options... options)
Factory method to create a class wrapping a new QueueEnqueue operation.
|
static QueueEnqueue.Options |
timeoutMs(Long timeoutMs) |
equals, hashCode, op, toString
public static QueueEnqueue create(Scope scope, Operand<?> handle, Iterable<Operand<?>> components, QueueEnqueue.Options... options)
scope
- current scopehandle
- The handle to a queue.components
- One or more tensors from which the enqueued tensors should be taken.options
- carries optional attributes valuespublic static QueueEnqueue.Options timeoutMs(Long timeoutMs)
timeoutMs
- If the queue is full, this operation will block for up to
timeout_ms milliseconds.
Note: This option is not supported yet.Copyright © 2022. All rights reserved.