JsonOpenSource
Methods
- batches() : Iterator<int, CorruptedRecordException|Rows>
- Batches of exactly $batchSize rows (the last may be shorter), keyed and ordered by $schema, and every corrupted record handed up in record order. This instance is consumed afterwards.
- close() : void
Methods
batches()
Batches of exactly $batchSize rows (the last may be shorter), keyed and ordered by $schema, and every corrupted record handed up in record order. This instance is consumed afterwards.
public
batches(Schema $schema, int<1, max> $batchSize, Backend $backend[, null|SchemaInference $inference = null ][, null|Schema $known = null ]) : Iterator<int, CorruptedRecordException|Rows>
Parameters
- $schema : Schema
- $batchSize : int<1, max>
- $backend : Backend
- $inference : null|SchemaInference = null
-
the inference that made $schema; null when it was declared
- $known : null|Schema = null
-
the schema the user sees, $schema plus the file's own columns
Tags
Return values
Iterator<int, CorruptedRecordException|Rows>close()
public
close() : void