github-actions[bot] opened a new issue, #649: URL: https://github.com/apache/incubator-wayang/issues/649
Revise implementation to support multiple field projection, by names and indexes. https://github.com/apache/incubator-wayang/blob/3fa657bcc8c86198b9532aa06bf27964c3f771be/wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/function/ProjectionDescriptor.java#L41 ```java package org.apache.wayang.basic.function; import java.lang.reflect.Field; import java.util.Arrays; import java.util.Collections; import java.util.List; import org.apache.wayang.basic.data.Record; import org.apache.wayang.basic.types.RecordType; import org.apache.wayang.core.function.FunctionDescriptor; import org.apache.wayang.core.function.TransformationDescriptor; import org.apache.wayang.core.types.BasicDataUnitType; /** * This descriptor pertains to projections. It takes field names of the input * type to describe the projection. */ public class ProjectionDescriptor<Input, Output> extends TransformationDescriptor<Input, Output> { /** * Java implementation of a projection on POJOs via reflection. */ // TODO: Revise implementation to support multiple field projection, by names // and indexes. private static class PojoImplementation<Input, Output> implements FunctionDescriptor.SerializableFunction<Input, Output> { private final String fieldName; private Field field; private PojoImplementation(final String fieldName) { this.fieldName = fieldName; } @Override @SuppressWarnings("unchecked") public Output apply(final Input input) { // Initialization code. if (this.field == null) { ``` 40e1e0f9785d58f9ab9731824c00aef5b0a84db7 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
