@Test public void testGetFields_Primitive_RepeatedInt() throws IOException { List<Type> columns = new ArrayList<>(); columns.add(new PrimitiveType(Type.Repetition.REPEATED, PrimitiveTypeName.INT32, "repeatedInt")); schema = new MessageType("TestProtobuf.RepeatedIntMessage", columns); context.setMetadata(schema); context.setTupleDescription(getColumnDescriptorsFromSchema(schema)); resolver.initialize(context); List<Group> groups = readParquetFile("old-repeated-int.parquet", 1, schema); List<OneField> fields = assertRow(groups, 0, 1); assertEquals(DataType.TEXT.getOID(), fields.get(0).type); assertEquals("[1,2,3]", 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; }