`flow.record.adapter.split`¶

Module Contents¶

Classes¶

Attributes¶

`DEFAULT_RECORD_COUNT`
`DEFAULT_SUFFIX_LENGTH`
`__usage__`

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.