deepr.jobs.SaveDataset

class deepr.jobs.SaveDataset(input_fn, path, fields, prepro_fn=<function SaveDataset.<lambda>>, num_parallel_calls=None, chunk_size=None, compression_type='GZIP', secs=60, mode=None)[source]

Save Dataset Job.

__init__(input_fn, path, fields, prepro_fn=<function SaveDataset.<lambda>>, num_parallel_calls=None, chunk_size=None, compression_type='GZIP', secs=60, mode=None)

Methods

`__init__`(input_fn, path, fields[, ...])
`prepro_fn`(_)
`run`()	Run Job

Attributes

`chunk_size`
`compression_type`
`mode`
`num_parallel_calls`
`secs`
`input_fn`
`path`
`fields`