pub async fn create_writer(
file_compression_type: FileCompressionType,
location: &Path,
object_store: Arc<dyn ObjectStore>,
) -> Result<Box<dyn AsyncWrite + Unpin + Send>, DataFusionError>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.