@Test public void testConvertExtraFields() throws Descriptors.DescriptorValidationException { Schema schema = new Schema(); schema.add(new Schema.FieldSchema("chararray", DataType.CHARARRAY)); schema.add(new Schema.FieldSchema("bytearray", DataType.BYTEARRAY)); List<Pair<String, DescriptorProtos.FieldDescriptorProto.Type>> extraFields = new ArrayList<Pair<String, DescriptorProtos.FieldDescriptorProto.Type>>(); extraFields.add(new Pair<String, DescriptorProtos.FieldDescriptorProto.Type>( "extra_string", DescriptorProtos.FieldDescriptorProto.Type.TYPE_STRING)); extraFields.add(new Pair<String, DescriptorProtos.FieldDescriptorProto.Type>( "extra_int", DescriptorProtos.FieldDescriptorProto.Type.TYPE_INT32)); Descriptors.Descriptor descriptor = PigToProtobuf.schemaToProtoDescriptor(new ResourceSchema(schema), extraFields); Assert.assertEquals("Incorrect data size", 4, descriptor.getFields().size()); Iterator<Descriptors.FieldDescriptor> fieldIterator = descriptor.getFields().iterator(); assetFieldDescriptor(fieldIterator.next(), "chararray", Descriptors.FieldDescriptor.Type.STRING); assetFieldDescriptor(fieldIterator.next(), "bytearray", Descriptors.FieldDescriptor.Type.BYTES); assetFieldDescriptor(fieldIterator.next(), "extra_string", Descriptors.FieldDescriptor.Type.STRING); assetFieldDescriptor(fieldIterator.next(), "extra_int", Descriptors.FieldDescriptor.Type.INT32); }
public static Descriptor schemaToProtoDescriptor(ResourceSchema schema) throws DescriptorValidationException { return schemaToProtoDescriptor(schema, null); }
PigToProtobuf { public static Descriptor schemaToProtoDescriptor(ResourceSchema schema) throws DescriptorValidationException { return schemaToProtoDescriptor(schema, null); } }
PigToProtobuf { public static Descriptor schemaToProtoDescriptor(ResourceSchema schema) throws DescriptorValidationException { return schemaToProtoDescriptor(schema, null); } PigToProtobuf(); }
PigToProtobuf { public static Descriptor schemaToProtoDescriptor(ResourceSchema schema) throws DescriptorValidationException { return schemaToProtoDescriptor(schema, null); } PigToProtobuf(); @SuppressWarnings("unchecked") static M tupleToMessage(Class<M> protoClass, Tuple tuple); static Message tupleToMessage(Builder builder, Tuple tuple); static Message tupleToMessage(Builder builder, List<FieldDescriptor> fieldDescriptors, Tuple tuple); static Descriptor schemaToProtoDescriptor(ResourceSchema schema); static Descriptor schemaToProtoDescriptor(ResourceSchema schema, List<Pair<String, Type>> extraFields); }
PigToProtobuf { public static Descriptor schemaToProtoDescriptor(ResourceSchema schema) throws DescriptorValidationException { return schemaToProtoDescriptor(schema, null); } PigToProtobuf(); @SuppressWarnings("unchecked") static M tupleToMessage(Class<M> protoClass, Tuple tuple); static Message tupleToMessage(Builder builder, Tuple tuple); static Message tupleToMessage(Builder builder, List<FieldDescriptor> fieldDescriptors, Tuple tuple); static Descriptor schemaToProtoDescriptor(ResourceSchema schema); static Descriptor schemaToProtoDescriptor(ResourceSchema schema, List<Pair<String, Type>> extraFields);  }