| Package | Description |
|---|---|
| com.datastax.oss.dsbulk.connectors.commons | |
| com.datastax.oss.dsbulk.connectors.csv | |
| com.datastax.oss.dsbulk.connectors.json |
| Modifier and Type | Method and Description |
|---|---|
protected abstract AbstractFileBasedConnector.RecordReader |
AbstractFileBasedConnector.newSingleFileReader(URL url)
Returns a new
AbstractFileBasedConnector.RecordReader instance; cannot be null. |
AbstractFileBasedConnector.RecordReader |
AbstractFileBasedConnector.RecordReader.readNext(SynchronousSink<Record> sink)
Reads the next record and emits the record to the sink, if any.
|
| Modifier and Type | Method and Description |
|---|---|
protected AbstractFileBasedConnector.RecordReader |
CSVConnector.newSingleFileReader(URL url) |
| Modifier and Type | Method and Description |
|---|---|
protected AbstractFileBasedConnector.RecordReader |
JsonConnector.newSingleFileReader(URL url) |
Copyright © 2017–2021 DataStax. All rights reserved.