Uses of Interface
com.datastax.oss.dsbulk.connectors.api.Record

Packages that use Record

Package	Description
com.datastax.oss.dsbulk.connectors.api
com.datastax.oss.dsbulk.connectors.commons
com.datastax.oss.dsbulk.workflow.commons.log
com.datastax.oss.dsbulk.workflow.commons.schema
com.datastax.oss.dsbulk.workflow.commons.statement

Uses of Record in com.datastax.oss.dsbulk.connectors.api

Subinterfaces of Record in com.datastax.oss.dsbulk.connectors.api

Modifier and Type	Interface and Description
interface	ErrorRecord A Record that could not be properly processed.

Classes in com.datastax.oss.dsbulk.connectors.api that implement Record

Modifier and Type	Class and Description
class	DefaultErrorRecord A record that could not be fully parsed from its source.
class	DefaultRecord

Methods in com.datastax.oss.dsbulk.connectors.api that return types with arguments of type Record

Modifier and Type	Method and Description
Publisher<Publisher<Record>>	Connector.read() Reads all records from the datasource in a flow of flows that can be consumed in parallel.
Function<Publisher<Record>,Publisher<Record>>	Connector.write() Returns a function that handles writing records to the datasource.
Function<Publisher<Record>,Publisher<Record>>	Connector.write() Returns a function that handles writing records to the datasource.

Uses of Record in com.datastax.oss.dsbulk.connectors.commons

Methods in com.datastax.oss.dsbulk.connectors.commons that return types with arguments of type Record

Modifier and Type	Method and Description
protected Flux<Record>	AbstractFileBasedConnector.applyPerFileLimits(Flux<Record> records) Applies per-file limits to a stream of records coming from AbstractFileBasedConnector.readSingleFile(java.net.URL).
Publisher<Publisher<Record>>	AbstractFileBasedConnector.read()
protected Flux<Record>	AbstractFileBasedConnector.readSingleFile(URL url) Reads a single text file accessible through the given URL.
Function<Publisher<Record>,Publisher<Record>>	AbstractFileBasedConnector.write()
Function<Publisher<Record>,Publisher<Record>>	AbstractFileBasedConnector.write()

Methods in com.datastax.oss.dsbulk.connectors.commons with parameters of type Record

Modifier and Type	Method and Description
void	AbstractFileBasedConnector.RecordWriter.write(Record record) Writes the record to the destination file, in a thread-safe manner (i.e., this method is never called concurrently).

Method parameters in com.datastax.oss.dsbulk.connectors.commons with type arguments of type Record

Modifier and Type	Method and Description
protected Flux<Record>	AbstractFileBasedConnector.applyPerFileLimits(Flux<Record> records) Applies per-file limits to a stream of records coming from AbstractFileBasedConnector.readSingleFile(java.net.URL).
AbstractFileBasedConnector.RecordReader	AbstractFileBasedConnector.RecordReader.readNext(SynchronousSink<Record> sink) Reads the next record and emits the record to the sink, if any.

Uses of Record in com.datastax.oss.dsbulk.workflow.commons.log

Methods in com.datastax.oss.dsbulk.workflow.commons.log that return types with arguments of type Record

Modifier and Type	Method and Description
Function<Flux<Record>,Flux<Record>>	LogManager.newFailedRecordsHandler() Handler for failed records.
Function<Flux<Record>,Flux<Record>>	LogManager.newFailedRecordsHandler() Handler for failed records.
Function<Flux<Record>,Flux<Record>>	LogManager.newUnmappableRecordsHandler() Handler for unmappable records produced by the result mapper.
Function<Flux<Record>,Flux<Record>>	LogManager.newUnmappableRecordsHandler() Handler for unmappable records produced by the result mapper.

Methods in com.datastax.oss.dsbulk.workflow.commons.log with parameters of type Record

Modifier and Type	Method and Description
static String	LogManagerUtils.formatSource(Record record)

Uses of Record in com.datastax.oss.dsbulk.workflow.commons.schema

Methods in com.datastax.oss.dsbulk.workflow.commons.schema that return Record

Modifier and Type	Method and Description
Record	ReadResultMapper.map(ReadResult result)
Record	DefaultReadResultMapper.map(ReadResult result)

Methods in com.datastax.oss.dsbulk.workflow.commons.schema with parameters of type Record

Modifier and Type	Method and Description
BatchableStatement<?>	RecordMapper.map(Record record)
BatchableStatement<?>	DefaultRecordMapper.map(Record record)

Uses of Record in com.datastax.oss.dsbulk.workflow.commons.statement

Methods in com.datastax.oss.dsbulk.workflow.commons.statement that return Record

Modifier and Type	Method and Description
Record	MappedStatement.getRecord() Returns the record that this statement was mapped from.
Record	MappedSimpleStatement.getRecord()
Record	MappedBoundStatement.getRecord()

Constructors in com.datastax.oss.dsbulk.workflow.commons.statement with parameters of type Record

Constructor and Description
MappedBoundStatement(Record source, BoundStatement delegate)
MappedSimpleStatement(Record source, SimpleStatement delegate)
UnmappableStatement(Record record, Throwable error)