[ https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905141#comment-15905141 ]
ASF GitHub Bot commented on FLINK-4460: --------------------------------------- Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/3484#discussion_r105399457 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SideOutputTransformation.java --- @@ -0,0 +1,72 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.flink.streaming.api.transformations; + +import static java.util.Objects.requireNonNull; + +import com.google.common.collect.Lists; +import org.apache.flink.util.OutputTag; +import org.apache.flink.streaming.api.operators.ChainingStrategy; + +import java.util.Collection; +import java.util.List; + + +/** + * This transformation represents a selection of a side output of an upstream operation with a + * given {@link OutputTag}. + * + * <p>This does not create a physical operation, it only affects how upstream operations are + * connected to downstream operations. + * + * @param <T> The type of the elements that result from this {@code SideOutputTransformation} + */ +public class SideOutputTransformation<T> extends StreamTransformation<T> { + private final StreamTransformation<T> input; --- End diff -- Leave a blank line here. > Side Outputs in Flink > --------------------- > > Key: FLINK-4460 > URL: https://issues.apache.org/jira/browse/FLINK-4460 > Project: Flink > Issue Type: New Feature > Components: Core, DataStream API > Affects Versions: 1.2.0, 1.1.3 > Reporter: Chen Qin > Assignee: Chen Qin > Labels: latearrivingevents, sideoutput > > https://docs.google.com/document/d/1vg1gpR8JL4dM07Yu4NyerQhhVvBlde5qdqnuJv4LcV4/edit?usp=sharing -- This message was sent by Atlassian JIRA (v6.3.15#6346)