comments

Author: ArnavBalyan

parquet-cli/pom.xml

@@ -97,13 +97,13 @@
       <groupId>com.google.protobuf</groupId>
       <artifactId>protobuf-java</artifactId>
       <version>3.25.6</version>
-      <scope>test</scope>
+      <scope>${deps.scope}</scope>
     </dependency>
     <dependency>
       <groupId>org.apache.parquet</groupId>
       <artifactId>parquet-protobuf</artifactId>
       <version>${project.version}</version>
-      <scope>test</scope>
+      <scope>${deps.scope}</scope>
     </dependency>
     <dependency>
       <groupId>org.apache.parquet</groupId>

parquet-cli/src/main/java/org/apache/parquet/cli/BaseCommand.java

@@ -66,6 +66,7 @@ public abstract class BaseCommand implements Command, Configurable {
 
   private static final String RESOURCE_URI_SCHEME = "resource";
   private static final String STDIN_AS_SOURCE = "stdin";
+  public static final String PARQUET_CLI_ENABLE_GROUP_READER = "parquet.enable.fallback-simple-reader";
 
   /**
    * Note for dev: Due to legancy reasons, parquet-cli used the avro schema reader which
@@ -364,7 +365,8 @@ protected <D> Iterable<D> openDataFile(final String source, Schema projection) t
     switch (format) {
       case PARQUET:
         boolean isProtobufStyle = isProtobufStyleSchema(source);
-        if (isProtobufStyle) {
+        boolean useGroupReader = getConf().getBoolean(PARQUET_CLI_ENABLE_GROUP_READER, false);
+        if (isProtobufStyle || useGroupReader) {
           final ParquetReader<Group> grp = ParquetReader.<Group>builder(
                   new GroupReadSupport(), qualifiedPath(source))
               .withConf(getConf())