File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed
Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -48,7 +48,7 @@ pub struct ConvertOpt {
4848 #[ structopt( short = "c" , long = "compression" , default_value = "zstd" ) ]
4949 compression : String ,
5050
51- /// Number of partitions to produce
51+ /// Number of partitions to produce. By default, uses only 1 partition.
5252 #[ structopt( short = "n" , long = "partitions" , default_value = "1" ) ]
5353 partitions : usize ,
5454
@@ -105,9 +105,7 @@ impl ConvertOpt {
105105 . collect :: < Vec < _ > > ( ) ;
106106
107107 csv = csv. select ( selection) ?;
108- // optionally, repartition the file
109- let partitions = self . partitions ;
110- csv = csv. repartition ( Partitioning :: RoundRobinBatch ( partitions) ) ?;
108+ csv = csv. repartition ( Partitioning :: RoundRobinBatch ( self . partitions ) ) ?;
111109 let csv = if self . sort {
112110 csv. sort_by ( vec ! [ col( key_column_name) ] ) ?
113111 } else {
You can’t perform that action at this time.
0 commit comments