flow.record.adapter.split#

Module Contents#

Classes#

Attributes#

flow.record.adapter.split.DEFAULT_RECORD_COUNT = 1000#
flow.record.adapter.split.DEFAULT_SUFFIX_LENGTH = 2#
flow.record.adapter.split.__usage__#
class flow.record.adapter.split.SplitWriter(path, **kwargs)#

Bases: flow.record.adapter.AbstractWriter

writer#
write(r)#

Write a record.

flush()#

Flush any buffered writes.

close()#

Close the Writer, no more writes will be possible.