import java.io.Serializable;

public class Issue3032 {
    public static class PCollection<T> implements PValue {
        public <OutputT extends POutput> OutputT apply(
                String name, PTransform<? super PCollection<T>, OutputT> t) {
            throw new RuntimeException();
        }
    }

    public abstract static class PTransform<InputT extends PInput, OutputT extends POutput> {}

    interface PInput {}

    interface POutput {}

    interface PValue extends PInput, POutput {}

    static class BillingEvent {
        InvoiceGroupingKey getInvoiceGroupingKey() {
            throw new RuntimeException();
        }
    }

    public static class MapElements<InputT, OutputT>
            extends PTransform<PCollection<? extends InputT>, PCollection<OutputT>> {
        public static <InputT, OutputT> MapElements<InputT, OutputT> via(
                final ProcessFunction<InputT, OutputT> fn) {
            throw new RuntimeException();
        }
    }

    static class InvoiceGroupingKey {}

    @FunctionalInterface
    public interface ProcessFunction<InputT, OutputT> extends Serializable {
        OutputT apply(InputT input) throws Exception;
    }

    private static class GenerateInvoiceRows
            extends PTransform<PCollection<BillingEvent>, PCollection<String>> {
        public void expand(PCollection<BillingEvent> input) {
            input.apply(
                    "Map to invoicing key", MapElements.via(BillingEvent::getInvoiceGroupingKey));
        }
    }
}