common.data_writers.buffered
new_file_id
def new_file_id() -> str
Creates new file id which is globally unique within table_name scope
BufferedDataWriter Objects
class BufferedDataWriter(Generic[TWriter])
write_empty_file
def write_empty_file(columns: TTableSchemaColumns) -> DataWriterMetrics
Writes empty file: only header and footer without actual items. Closed the empty file and returns metrics. Mind that header and footer will be written.
import_file
def import_file(file_path: str,
metrics: DataWriterMetrics) -> DataWriterMetrics
Import a file from file_path
into items storage under a new file name. Does not check
the imported file format. Uses counts from metrics
as a base. Logically closes the imported file
The preferred import method is a hard link to avoid copying the data. If current filesystem does not support it, a regular copy is used.