Expand description
TableProvider for stream sources, such as FIFO files
Structs§
- File
Stream Provider - Stream data from the file at
location - Stream
Config - The configuration for a
StreamTable - Stream
Table - A
TableProviderfor an unbounded stream source - Stream
Table Factory - A
TableProviderFactoryforStreamTable
Enums§
- Stream
Encoding - The data encoding for
StreamTable
Traits§
- Stream
Provider - The StreamProvider trait is used as a generic interface for reading and writing from streaming
data sources (such as FIFO, Websocket, Kafka, etc.). Implementations of the provider are
responsible for providing a
RecordBatchReaderand optionally aRecordBatchWriter.