@@ -0,0 +1,1762 @@
+package parquet.hadoop.example;%0A%0Aimport org.apache.hadoop.conf.Configuration;%0Aimport org.junit.Test;%0Aimport parquet.hadoop.api.ReadSupport;%0Aimport parquet.schema.MessageType;%0Aimport parquet.schema.MessageTypeParser;%0Aimport java.util.HashMap;%0Aimport java.util.Map;%0Aimport static org.junit.Assert.assertEquals;%0A%0Apublic class GroupReadSupportTest %7B%0A%0A  private String fullSchemaStr= %22message example %7B%5Cn%22 +%0A          %22required int32 line;%5Cn%22 +%0A          %22optional binary content;%5Cn%22 +%0A          %22%7D%22;%0A%0A  private String partialSchemaStr =%22message example %7B%5Cn%22 +%0A          %22required int32 line;%5Cn%22 +%0A          %22optional binary content;%5Cn%22 +%0A          %22%7D%22;%0A%0A%0A  @Test%0A  public void testInitWithoutSpecifyingRequestSchema() throws Exception %7B%0A      GroupReadSupport s=new GroupReadSupport();%0A      Configuration configuration=new Configuration();%0A      Map%3CString,String%3E keyValueMetaData=new HashMap%3CString,String%3E();%0A    MessageType fileSchema= MessageTypeParser.parseMessageType(fullSchemaStr);%0A    ReadSupport.ReadContext context = s.init(configuration,keyValueMetaData,fileSchema);%0A    assertEquals(context.getRequestedSchema(), fileSchema);%0A  %7D%0A%0A  @Test%0A  public void testInitWithPartialSchema()%7B%0A    GroupReadSupport s=new GroupReadSupport();%0A    Configuration configuration=new Configuration();%0A    Map%3CString,String%3E keyValueMetaData=new HashMap%3CString,String%3E();%0A    MessageType fileSchema= MessageTypeParser.parseMessageType(fullSchemaStr);%0A    MessageType partialSchema= MessageTypeParser.parseMessageType(partialSchemaStr);%0A%0A    configuration.set(ReadSupport.PARQUET_READ_SCHEMA, partialSchemaStr);%0A    ReadSupport.ReadContext context = s.init(configuration, keyValueMetaData, fileSchema);%0A    assertEquals(context.getRequestedSchema(), partialSchema);%0A  %7D%0A%7D%0A

add unit test