@Operator(group="io") public final class ReaderReadUpTo extends PrimitiveOp
Will dequeue from the input queue if necessary (e.g. when the Reader needs to start reading from a new file since it has finished with the previous file). It may return less than `num_records` even before the last batch.
operation
Modifier and Type | Method and Description |
---|---|
static ReaderReadUpTo |
create(Scope scope,
Operand<?> readerHandle,
Operand<?> queueHandle,
Operand<Long> numRecords)
Factory method to create a class wrapping a new ReaderReadUpTo operation.
|
Output<String> |
keys()
A 1-D tensor.
|
Output<String> |
values()
A 1-D tensor.
|
equals, hashCode, op, toString
public static ReaderReadUpTo create(Scope scope, Operand<?> readerHandle, Operand<?> queueHandle, Operand<Long> numRecords)
scope
- current scopereaderHandle
- Handle to a `Reader`.queueHandle
- Handle to a `Queue`, with string work items.numRecords
- number of records to read from `Reader`.Copyright © 2022. All rights reserved.