NewServer instantiates a DistSQLServer.

ProcessInboundStream receives rows from a DistSQL_FlowStreamServer and sends them to a RowReceiver.

Flow status indicators.

Flow status indicators.

Flow status indicators.

The input streams are guaranteed to be ordered according to the column ordering field; rows from the streams are interleaved to preserve that ordering.

Rows from the input streams are interleaved arbitrarily.

Each row is sent to one stream, chosen by hashing certain columns of the row (specified by the hash_columns field).

Each row is sent to one stream, chosen according to preset boundaries for the values of certain columns of the row.

Each row is sent to all output streams (also used if there is a single output stream).

Flow represents a flow which consists of processors and streams.

FlowCtx encompasses the contexts needed for various flow components.

FlowID identifies a flow.

FlowSpec describes a "flow" which is a subgraph of a distributed SQL computation consisting of processors and streams.

InputSyncSpec is the specification for an input synchronizer; it decides how to interleave rows from multiple input streams.

JoinReaderSpec is the specification for a "join reader".

A mailbox is where a stream "crosses" hosts - it is an endpoint of a local stream which receives data from or sends to a remote host.

MultiplexedRowChannel is a RowChannel wrapper which allows multiple row producers to push rows on the same channel.

NoopCoreSpec indicates a "no-op" processor core.

Ordering defines an order - specifically a list of column indices and directions.

OutputRouterSpec is the specification for the output router of a processor; it decides how to send results to multiple output streams.

RowBuffer is an implementation of RowReceiver that buffers (accumulates) results in memory, as well as an implementation of rowSender that returns rows from a row buffer.

RowChannel is a thin layer over a StreamMsg channel, which can be used to transfer rows between goroutines.

ServerConfig encompasses the configuration required to create a DistSQLServer.

ServerImpl implements the server for the distributed SQL APIs.

SorterSpec is the specification for a "sorting aggregator".

StreamData is a message that can be sent multiple times as part of a stream.

StreamDecoder converts a sequence of StreamMessage to EncDatumRows.

StreamEncoder converts EncDatum rows into a sequence of StreamMessage.

StreamEndpointSpec describes one of the endpoints (input or output) of a physical stream.

StreamHeader is a message that is sent once at the beginning of a stream.

StreamMsg is the message used in the channels that implement local physical streams.

StreamTrailer is a message that is sent once at the end of a stream.

TableReaderSpec is the specification for a "table reader".

RowReceiver is any component of a flow that receives rows from another component.

RowSource is any component of a flow that produces rows that cam be consumed by another component.

LocalStreamID identifies a stream that is local to a flow.

The direction of the desired ordering for a column.

StreamID identifies a stream that crosses machine boundaries.