@Test @SuppressWarnings("deprecation") public void testGetFields_Primitive_RepeatedString() throws IOException { List<Type> columns = new ArrayList<>(); columns.add(new PrimitiveType(Type.Repetition.REPEATED, PrimitiveTypeName.BINARY, "myString", OriginalType.UTF8)); schema = new MessageType("TestProtobuf.StringArray", columns); context.setMetadata(schema); context.setTupleDescription(getColumnDescriptorsFromSchema(schema)); resolver.initialize(context); List<Group> groups = readParquetFile("proto-repeated-string.parquet", 3, schema); List<OneField> fields; fields = assertRow(groups, 0, 1); assertEquals(DataType.TEXT.getOID(), fields.get(0).type); assertEquals("[\"hello\",\"world\"]", fields.get(0).val); fields = assertRow(groups, 1, 1); assertEquals(DataType.TEXT.getOID(), fields.get(0).type); assertEquals("[\"good\",\"bye\"]", fields.get(0).val); fields = assertRow(groups, 2, 1); assertEquals(DataType.TEXT.getOID(), fields.get(0).type); assertEquals("[\"one\",\"two\",\"three\"]", fields.get(0).val); }
@Override public void initialize(RequestContext requestContext) { super.initialize(requestContext); this.columnDescriptors = context.getTupleDescription(); }
ParquetResolver extends BasePlugin implements Resolver { @Override public void initialize(RequestContext requestContext) { super.initialize(requestContext); this.columnDescriptors = context.getTupleDescription(); } }
ParquetResolver extends BasePlugin implements Resolver { @Override public void initialize(RequestContext requestContext) { super.initialize(requestContext); this.columnDescriptors = context.getTupleDescription(); } ParquetResolver();   ParquetResolver(ConfigurationFactory configurationFactory); }
ParquetResolver extends BasePlugin implements Resolver { @Override public void initialize(RequestContext requestContext) { super.initialize(requestContext); this.columnDescriptors = context.getTupleDescription(); } ParquetResolver();   ParquetResolver(ConfigurationFactory configurationFactory); @Override void initialize(RequestContext requestContext); @Override List<OneField> getFields(OneRow row); @Override OneRow setFields(List<OneField> record); }
ParquetResolver extends BasePlugin implements Resolver { @Override public void initialize(RequestContext requestContext) { super.initialize(requestContext); this.columnDescriptors = context.getTupleDescription(); } ParquetResolver();   ParquetResolver(ConfigurationFactory configurationFactory); @Override void initialize(RequestContext requestContext); @Override List<OneField> getFields(OneRow row); @Override OneRow setFields(List<OneField> record); static final Pattern TIMESTAMP_PATTERN; }