pub async fn create_writer(
file_compression_type: FileCompressionType,
location: &Path,
object_store: Arc<dyn ObjectStore>,
) -> Result<Box<dyn AsyncWrite + Send + Unpin>>
Expand description
Returns an AsyncWrite
which writes to the given object store location
with the specified compression.
We drop the AbortableWrite
struct and the writer will not try to cleanup on failure.
Users can configure automatic cleanup with their cloud provider.