Skip to content

BatchWrite

BatchWrite is an abstraction of writers to a batch data source.

Contract

Aborting Write

void abort(
  WriterCommitMessage[] messages)

Used when:

  • V2TableWriteExec physical command is requested to writeWithV2

Committing Write

void commit(
  WriterCommitMessage[] messages)

Used when:

  • V2TableWriteExec physical command is requested to writeWithV2

Creating DataWriterFactory

DataWriterFactory createBatchWriterFactory(
  PhysicalWriteInfo info)

Used when:

  • V2TableWriteExec physical command is requested to writeWithV2

onDataWriterCommit

void onDataWriterCommit(
  WriterCommitMessage message)

Used when:

  • V2TableWriteExec physical command is requested to writeWithV2

useCommitCoordinator

boolean useCommitCoordinator()

Default: true

Used when:

  • V2TableWriteExec physical command is requested to writeWithV2

Implementations


Last update: 2020-11-12
Back to top