@Operator(group="io") public final class ReaderRead 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).
operation
Modifier and Type | Method and Description |
---|---|
static ReaderRead |
create(Scope scope,
Operand<?> readerHandle,
Operand<?> queueHandle)
Factory method to create a class wrapping a new ReaderRead operation.
|
Output<String> |
key()
A scalar.
|
Output<String> |
value()
A scalar.
|
equals, hashCode, op, toString
public static ReaderRead create(Scope scope, Operand<?> readerHandle, Operand<?> queueHandle)
scope
- current scopereaderHandle
- Handle to a Reader.queueHandle
- Handle to a Queue, with string work items.Copyright © 2022. All rights reserved.