SupportsWrite Tables¶

SupportsWrite is an extension of the Table abstraction for writable tables.

Contract¶

Creating WriteBuilder¶

WriteBuilder newWriteBuilder(
  LogicalWriteInfo info)

Creates a WriteBuilder for writing (batch and streaming)

See:

• ParquetTable

Used when:

• V1FallbackWriters physical operator is requested to newWriteBuilder
• CreateTableAsSelectExec, ReplaceTableAsSelectExec physical commands are executed
• BatchWriteHelper physical operator is requested to newWriteBuilder
• AtomicTableWriteExec physical command is requested to writeToStagedTable
• StreamExecution stream execution engine (Spark Structured Streaming) is requested to createStreamingWrite

Implementations¶

• ConsoleTable (Spark Structured Streaming)
• FileTable
• ForeachWriterTable (Spark Structured Streaming)
• KafkaTable
• MemorySink (Spark Structured Streaming)
• NoopTable