pyarrow.flight.FlightStreamWriter#

class pyarrow.flight.FlightStreamWriter#

Bases: MetadataRecordBatchWriter

A writer that also allows closing the write side of a stream.

__init__(*args, **kwargs)#

Methods

__init__(*args,**kwargs)
begin(self,Schemaschema[,options])	Prepare to write data to this stream with the given schema.
close(self)	Close stream and write end-of-stream 0 marker.
done_writing(self)	Indicate that the client is done writing, but not done reading.
write(self,table_or_batch)	Write RecordBatch or Table to stream.
write_batch(self,RecordBatchbatch)	Write RecordBatch to stream.
write_metadata(self,buf)	Write Flight metadata by itself.
write_table(self,Tabletable[,max_chunksize])	Write Table to stream in (contiguous) RecordBatch objects.
write_with_metadata(self,RecordBatchbatch,buf)	Write a RecordBatch along with Flight metadata.

Attributes

stats

Current IPC write statistics.

begin(self, Schema schema: Schema, options=None)#

Prepare to write data to this stream with the given schema.

close(self)#

Close stream and write end-of-stream 0 marker.

done_writing(self)#

Indicate that the client is done writing, but not done reading.

stats#

Current IPC write statistics.

write(self, table_or_batch)#

Write RecordBatch or Table to stream.

Parameters:

table_or_batch{RecordBatch, Table}

write_batch(self, RecordBatch batch)#

Write RecordBatch to stream.

Parameters:

batchRecordBatch

write_metadata(self, buf)#

Write Flight metadata by itself.

write_table(self, Table table, max_chunksize=None, **kwargs)#

Write Table to stream in (contiguous) RecordBatch objects.

Parameters:

tableTable

max_chunksizeint, default None

Maximum number of rows for RecordBatch chunks. Individual chunks may be smaller depending on the chunk layout of individual columns.

write_with_metadata(self, RecordBatch batch, buf)#

Write a RecordBatch along with Flight metadata.

Parameters:

batchRecordBatch

The next RecordBatch in the stream.

bufBuffer

Application-specific metadata for the batch as defined by Flight.