from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/experimental/CollectSink.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/experimental/SocketStreamIterator.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessorFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/serialization/AbstractDeserializationSchema.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/serialization/SerializationSchema.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/serialization/SimpleStringSchema.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/serialization/TypeInformationSerializationSchema.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/serialization/DeserializationSchema.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/functions/StreamingFunctionUtils.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/keys/KeySelectorUtil.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SystemProcessingTimeService.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeServiceImpl.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationHead.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TimerException.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationTail.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsynchronousException.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ExceptionInChainedOperatorException.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TimerService.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTaskActionExecutor.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorEventDispatcherImpl.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceOperatorStreamTask.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeServiceFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AbstractTwoInputStreamTask.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeServiceUtil.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamOperatorWrapper.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeCallback.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeServiceAware.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTaskException.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTask.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxExecutorImpl.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/Mail.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailbox.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailboxImpl.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxExecutorFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxDefaultAction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamstatus/StreamStatus.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamstatus/StreamStatusProvider.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamstatus/StatusWatermarkValve.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamstatus/StreamStatusMaintainer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/util/AssignerWithPeriodicWatermarksAdapter.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/util/AssignerWithPunctuatedWatermarksAdapter.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/TimestampedValue.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/KeyMap.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/EvictingWindowOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalProcessAllWindowContext.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalProcessWindowContext.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/RescalePartitioner.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/ShufflePartitioner.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/KeyGroupStreamPartitioner.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/GlobalPartitioner.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/StreamPartitioner.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/RebalancePartitioner.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/CustomPartitionerWrapper.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/ForwardPartitioner.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/BroadcastPartitioner.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnaligner.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/PushingAsyncDataInput.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/AbstractDataOutput.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTwoInputProcessor.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskInput.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskSourceInput.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BlockingQueueBroker.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/InputGateUtil.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessor.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamInputProcessor.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/InputProcessorUtil.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierTracker.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/MultipleInputSelectionHandler.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordWriterOutput.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/TwoInputSelectionHandler.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskNetworkInput.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamOneInputProcessor.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierAligner.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecord.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamrecord/LatencyMarker.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamElement.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/BroadcastStream.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSink.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/UnsupportedTimeCharacteristicException.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSource.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/QueryableStateStream.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamUtils.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedStreams.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/IterativeStream.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/StreamProjection.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AsyncDataStream.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SplitStream.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/BroadcastConnectedStream.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/MultipleConnectedStreams.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/ExternallyInducedSource.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/ListCheckpointed.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/WithMasterCheckpointHook.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/PartitionTransformation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/AbstractMultipleInputTransformation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/LegacySourceTransformation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/FeedbackTransformation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/CoFeedbackTransformation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SplitTransformation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/MultipleInputTransformation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/OneInputTransformation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/ShuffleMode.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SourceTransformation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/KeyedMultipleInputTransformation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/TwoInputTransformation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SinkTransformation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SelectTransformation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/PhysicalTransformation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/UnionTransformation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperator.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/YieldingOperatorFactory.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorFactory.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamMap.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceImpl.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorV2.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SimpleInputFormatOperatorFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSink.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelectable.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializerSnapshot.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/LegacyKeyedProcessOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SimpleOutputFormatOperatorFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerHeapInternalTimer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputFormatOperatorFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractInput.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimeServiceManager.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializerImpl.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/MultipleInputStreamOperator.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorParameters.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/OneInputStreamOperator.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamFilter.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamGroupedReduce.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerService.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/UdfStreamOperatorFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimestampedCollector.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/ProcessOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/OutputTypeConfigurable.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/OutputFormatOperatorFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/BoundedMultiInput.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceSerializationProxy.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/Output.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/BoundedOneInput.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimersSnapshotReaderWriters.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/Input.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SetupableStreamOperator.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/Triggerable.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TwoInputStreamOperator.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamProject.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SimpleUdfStreamOperatorFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/ChainingStrategy.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SimpleOperatorFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/MailboxExecutor.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/OnWatermarkCallback.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamGroupedFold.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorStateHandler.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamFlatMap.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorFactory.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultIterator.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectStreamSink.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoStreamFlatMap.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoStreamMap.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/KeyedCoProcessOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithNonKeyedOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/LegacyKeyedCoProcessOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoProcessOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/TimestampsAndWatermarks.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/BatchTimestampsAndWatermarks.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/TimestampsAndWatermarksContext.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/StreamingTimestampsAndWatermarks.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/SourceOutputWithWatermarks.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/WatermarkToDataOutput.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/WatermarkQueueEntry.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/StreamRecordQueueEntry.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/OrderedStreamElementQueue.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/StreamElementQueue.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/UnorderedStreamElementQueue.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/StreamElementQueueEntry.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/TimerService.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/TimeCharacteristic.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/CheckpointingMode.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/SimpleTimerService.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/collector/selector/OutputSelector.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/watermark/Watermark.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironmentFactory.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamPipelineOptions.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/ExecutionCheckpointingOptions.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/SumAggregator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/SumFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/AggregationFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/ComparableAggregator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/Comparator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/ProcessFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/AscendingTimestampExtractor.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/KeyedProcessFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/RichCoMapFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/KeyedBroadcastProcessFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/CoProcessFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/ProcessJoinFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/RichCoFlatMapFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/KeyedCoProcessFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/CoFlatMapFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/CoMapFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/BaseBroadcastProcessFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/BroadcastProcessFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichSourceFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FileProcessingMode.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MessageAcknowledgingSourceBase.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MultipleIdsMessageAcknowledgingSourceBase.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/InputFormatSourceFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromIteratorFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichParallelSourceFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromSplittableIteratorFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FileReadFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FileMonitoringFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ParallelSourceFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/RandomGenerator.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGeneratorSource.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGenerator.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/AsyncFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/ResultFuture.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormatAsText.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormatAsCsv.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteSinkFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/RichSinkFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/PrintSinkFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteSinkFunctionByMillis.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/OutputFormatSinkFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/DiscardingSink.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormat.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkContextUtil.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/bucketassigners/BasePathBucketAssigner.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/bucketassigners/DateTimeBucketAssigner.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/bucketassigners/SimpleVersionedStringSerializer.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/RowWiseBucketWriter.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/InProgressFileWriter.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketStateSerializer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketAssigner.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/RollingPolicy.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketWriter.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/OutputFileConfig.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BulkBucketWriter.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketState.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/WriterProperties.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSinkHelper.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/DefaultBucketFactoryImpl.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/Buckets.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/PartFileInfo.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BulkPartWriter.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketLifeCycleListener.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/RowWisePartWriter.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/Bucket.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/rollingpolicies/OnCheckpointRollingPolicy.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/rollingpolicies/CheckpointRollingPolicy.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/rollingpolicies/DefaultRollingPolicy.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/DeltaFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/ExtractionAwareDeltaFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/CosineDistance.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/EuclideanDistance.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/ConcatenatedExtract.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/ArrayFromTuple.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldsFromTuple.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldFromTuple.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldFromArray.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldsFromArray.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/Extractor.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/PassThroughWindowFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessWindowFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/InternalProcessApplyWindowContext.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessWindowFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyProcessWindowFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/RichProcessWindowFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AllWindowFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/PassThroughAllWindowFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyWindowFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/InternalProcessApplyAllWindowContext.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyProcessAllWindowFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessAllWindowFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyWindowFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/RichWindowFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessAllWindowFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyAllWindowFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/RichAllWindowFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyWindowFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/WindowFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyAllWindowFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/RichProcessAllWindowFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/query/QueryableAppendingStateOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/query/QueryableValueStateOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/query/AbstractQueryableStateOperator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ProcessingTimeoutTrigger.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/EventTimeTrigger.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/DeltaTrigger.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ProcessingTimeTrigger.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/Trigger.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/PurgingTrigger.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousProcessingTimeTrigger.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/CountTrigger.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/time/Time.java" contains "import org.apache.flink.annotation.Public;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/MergingWindowAssigner.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/WindowAssigner.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SessionWindowTimeGapExtractor.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/GlobalWindows.java" contains "import org.apache.flink.annotation.Internal;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingEventTimeWindows.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicProcessingTimeSessionWindows.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingEventTimeWindows.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/WindowStagger.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingProcessingTimeWindows.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/EventTimeSessionWindows.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingTimeWindows.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingTimeWindows.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/ProcessingTimeSessionWindows.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/evictors/Evictor.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/evictors/TimeEvictor.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/evictors/DeltaEvictor.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/evictors/CountEvictor.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/Window.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/GlobalWindow.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-streaming-java to: flink-annotations evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java" contains "import org.apache.flink.annotation.PublicEvolving;"