File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed
src/integrationTest/java/com/mongodb/spark/sql/connector/read/partitioner Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change 2020import static com .mongodb .spark .sql .connector .config .MongoConfig .COMMENT_CONFIG ;
2121import static com .mongodb .spark .sql .connector .config .ReadConfig .PARTITIONER_OPTIONS_PREFIX ;
2222import static com .mongodb .spark .sql .connector .read .partitioner .FieldPartitioner .PARTITION_FIELD_CONFIG ;
23+ import static com .mongodb .spark .sql .connector .read .partitioner .PaginateBySizePartitioner .PARTITION_SIZE_MB_CONFIG ;
2324import static com .mongodb .spark .sql .connector .read .partitioner .PartitionerHelper .SINGLE_PARTITIONER ;
2425import static com .mongodb .spark .sql .connector .read .partitioner .PartitionerHelper .createPartitionPipeline ;
25- import static com .mongodb .spark .sql .connector .read .partitioner .SamplePartitioner .PARTITION_SIZE_MB_CONFIG ;
2626import static java .util .Arrays .asList ;
2727import static java .util .Collections .emptyList ;
2828import static java .util .Collections .singletonList ;
@@ -43,9 +43,7 @@ public class PaginateBySizePartitionerTest extends PartitionerTestCase {
4343
4444 @ Override
4545 List <String > defaultReadConfigOptions () {
46- return asList (
47- ReadConfig .PARTITIONER_OPTIONS_PREFIX + PaginateBySizePartitioner .PARTITION_SIZE_MB_CONFIG ,
48- "1" );
46+ return asList (ReadConfig .PARTITIONER_OPTIONS_PREFIX + PARTITION_SIZE_MB_CONFIG , "1" );
4947 }
5048
5149 @ Test
You can’t perform that action at this time.
0 commit comments