Sink
A data destination for pipeline output.
Usage
Sink()Parameters
uri: str-
Destination URI.
format: str = "json"-
Output format.
Methods
| Name | Description |
|---|---|
| write() | Write records to the sink. |
write()
Write records to the sink.
Usage
write(records)Parameters
records: list-
Records to write.
Returns
int-
Number of records written.