ccx-migration-274

Input

{
  "command": "ls /workspace && ls /workspace/flink-streaming-java/src 2>/dev/null | head",
  "description": "List workspace contents"
}

Output

{
  "stdout": "camel--1006f047\nflink--0cc95fcc\nkafka--0753c489",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "command": "ls /workspace/flink--0cc95fcc && ls /workspace/flink--0cc95fcc/flink-streaming-java/src",
  "description": "List flink repo structure"
}

Output

{
  "stdout": "LICENSE\nNOTICE\nREADME.md\nazure-pipelines.yml\ndocs\nflink-annotations\nflink-architecture-tests\nflink-clients\nflink-connectors\nflink-container\nflink-core\nflink-core-api\nflink-datastream\nflink-datastream-api\nflink-dist\nflink-dist-scala\nflink-docs\nflink-dstl\nflink-end-to-end-tests\nflink-examples\nflink-external-resources\nflink-filesystems\nflink-formats\nflink-fs-tests\nflink-kubernetes\nflink-libraries\nflink-metrics\nflink-models\nflink-python\nflink-queryable-state\nflink-quickstart\nflink-rpc\nflink-runtime\nflink-runtime-web\nflink-state-backends\nflink-streaming-java\nflink-table\nflink-test-utils-parent\nflink-tests\nflink-tests-java17\nflink-walkthroughs\nflink-yarn\nflink-yarn-tests\nlicenses\nmvnw\nmvnw.cmd\npom.xml\nsourcegraph.yaml\ntools\nmain\ntest",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "command": "grep -rl \"@Deprecated\" /workspace/flink--0cc95fcc/flink-streaming-java/src/main --include=\"*.java\" | wc -l",
  "description": "Count Java files with @Deprecated in main"
}

Output

{
  "stdout": "3",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "command": "grep -rl \"@Deprecated\" /workspace/flink--0cc95fcc/flink-streaming-java/src --include=\"*.java\"",
  "description": "List all Java files with @Deprecated under src"
}

Output

{
  "stdout": "/workspace/flink--0cc95fcc/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java\n/workspace/flink--0cc95fcc/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextOutputFormat.java\n/workspace/flink--0cc95fcc/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextInputFormat.java\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTestHarness.java\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "command": "grep -rl \"@deprecated\" /workspace/flink--0cc95fcc/flink-streaming-java/src/main --include=\"*.java\"",
  "description": "Find javadoc @deprecated tags in main sources"
}

Output

{
  "stdout": "/workspace/flink--0cc95fcc/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGeneratorSource.java\n/workspace/flink--0cc95fcc/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/legacy/DiscardingSink.java\n/workspace/flink--0cc95fcc/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextInputFormat.java\n/workspace/flink--0cc95fcc/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextOutputFormat.java\n/workspace/flink--0cc95fcc/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/legacy/StreamingFileSink.java\n/workspace/flink--0cc95fcc/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/legacy/TwoPhaseCommitSinkFunction.java",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "command": "cd /workspace/flink--0cc95fcc/flink-streaming-java/src/main/java/org/apache/flink/streaming && ls api/functions/source/legacy api/functions/sink/legacy api/functions/sink/filesystem/legacy api/legacy/io api/functions/timestamps api/functions/source/datagen 2>/dev/null",
  "description": "List legacy package directories"
}

Output

"Error: Exit code 2\napi/functions/sink/filesystem/legacy:\nStreamingFileSink.java\n\napi/functions/sink/legacy:\nDiscardingSink.java\nTwoPhaseCommitSinkFunction.java\n\napi/functions/source/datagen:\nDataGenerator.java\nDataGeneratorSource.java\nRandomGenerator.java\nSequenceGenerator.java\n\napi/functions/timestamps:\nAscendingTimestampExtractor.java\nBoundedOutOfOrdernessTimestampExtractor.java\n\napi/legacy/io:\nCollectionInputFormat.java\nTextInputFormat.java\nTextOutputFormat.java"

Input

{
  "command": "cd /workspace/flink--0cc95fcc/flink-streaming-java/src/main/java/org/apache/flink/streaming && for f in api/functions/source/datagen/DataGeneratorSource.java api/functions/sink/legacy/DiscardingSink.java api/functions/sink/legacy/TwoPhaseCommitSinkFunction.java api/functions/sink/filesystem/legacy/StreamingFileSink.java api/legacy/io/TextInputFormat.java api/legacy/io/TextOutputFormat.java api/functions/timestamps/AscendingTimestampExtractor.java api/functions/timestamps/BoundedOutOfOrdernessTimestampExtractor.java; do echo \"=== $f ===\"; grep -n -B6 -A2 \"@deprecated\\|@Deprecated\" $f | head -40; done",
  "description": "Show deprecation context in candidate files"
}

Output

{
  "stdout": "=== api/functions/source/datagen/DataGeneratorSource.java ===\n31-import javax.annotation.Nullable;\n32-\n33-/**\n34- * A data generator source that abstract data generator. It can be used to easy startup/test for\n35- * streaming job and performance testing. It is stateful, re-scalable, possibly in parallel.\n36- *\n37: * @deprecated Use {@code org.apache.flink.connector.datagen.source.DataGeneratorSource} instead.\n38- */\n39-@Internal\n=== api/functions/sink/legacy/DiscardingSink.java ===\n22-import org.apache.flink.api.common.SupportsConcurrentExecutionAttempts;\n23-\n24-/**\n25- * A stream sink that ignores all elements.\n26- *\n27- * @param <T> The type of elements received by the sink.\n28: * @deprecated This interface will be removed in future versions. Use the new {@link\n29- *     org.apache.flink.streaming.api.functions.sink.v2.DiscardingSink} interface instead.\n30- */\n=== api/functions/sink/legacy/TwoPhaseCommitSinkFunction.java ===\n66- * TXN} (transaction handle) and implement abstract methods handling this transaction handle.\n67- *\n68- * @param <IN> Input type for {@link SinkFunction}.\n69- * @param <TXN> Transaction to store all of the information required to handle a transaction.\n70- * @param <CONTEXT> Context that will be shared across all invocations for the given {@link\n71- *     TwoPhaseCommitSinkFunction} instance. Context is created once\n72: * @deprecated This interface will be removed in future versions. Use the new {@link\n73- *     org.apache.flink.api.connector.sink2.Sink} interface instead.\n74- */\n=== api/functions/sink/filesystem/legacy/StreamingFileSink.java ===\n92- * back to the state it had when that last successful checkpoint occurred. To this end, when\n93- * restoring, the restored files in {@code pending} state are transferred into the {@code finished}\n94- * state while any {@code in-progress} files are rolled back, so that they do not contain data that\n95- * arrived after the checkpoint from which we restore.\n96- *\n97- * @param <IN> Type of the elements emitted by this sink\n98: * @deprecated Use {@link org.apache.flink.connector.file.sink.FileSink} instead.\n99- */\n100-@Internal\n=== api/legacy/io/TextInputFormat.java ===\n27-import java.nio.charset.Charset;\n28-import java.util.Arrays;\n29-\n30-/**\n31- * Input Format that reads text files. Each line results in another element.\n32- *\n33: * @deprecated If you want to read/write data from/to text file, please use FLIP-27 FileSource and\n34- *     Sink-V2 FlinkSink. This class should be removed if we drop the supports for read/write via\n35- *     input/output format in DataStream api.\n36- */\n37:@Deprecated\n38-@PublicEvolving\n39-public class TextInputFormat extends DelimitedInputFormat<String> {\n=== api/legacy/io/TextOutputFormat.java ===\n31-/**\n32- * A {@link FileOutputFormat} that writes objects to a text file.\n33- *\n34- * <p>Objects are converted to Strings using either {@link Object#toString()} or a {@link\n35- * TextFormatter}.\n36- *\n37: * @deprecated If you want to read/write data from/to text file, please use FLIP-27 FileSource and\n38- *     Sink-V2 FlinkSink. This class should be removed if we drop all supports for {@link\n39- *     org.apache.flink.api.common.io.InputFormat} and {@link\n40- *     org.apache.flink.api.common.io.OutputFormat}\n41- */\n42:@Deprecated\n43-@PublicEvolving\n44-public class TextOutputFormat<T> extends FileOutputFormat<T> {\n=== api/functions/timestamps/AscendingTimestampExtractor.java ===\n31- * A timestamp assigner and watermark generator for streams where timestamps are monotonously\n32- * ascending. In this case, the local watermarks for the streams are easy to generate, because they\n33- * strictly follow the timestamps.\n34- *\n35- * @param <T> The type of the elements that this function can extract timestamps from\n36- */\n37:@Deprecated\n38-@PublicEvolving\n39-public abstract class AscendingTimestampExtractor<T>\n=== api/functions/timestamps/BoundedOutOfOr
...

Input

{
  "command": "ls -R api/functions/source api/functions/sink | head -60; echo ---; grep -n \"@deprecated\" -r api/functions/timestamps api/legacy/io api/functions/source api/functions/sink | head -30",
  "description": "List source/sink function dirs and deprecated tags"
}

Output

{
  "stdout": "api/functions/sink:\nPrintSink.java\nSinkContextUtil.java\nfilesystem\nlegacy\nv2\n\napi/functions/sink/filesystem:\nBucket.java\nBucketFactory.java\nBucketLifeCycleListener.java\nBucketState.java\nBucketStateSerializer.java\nBuckets.java\nDefaultBucketFactoryImpl.java\nFileLifeCycleListener.java\nStreamingFileSinkHelper.java\nlegacy\n\napi/functions/sink/filesystem/legacy:\nStreamingFileSink.java\n\napi/functions/sink/legacy:\nDiscardingSink.java\nTwoPhaseCommitSinkFunction.java\n\napi/functions/sink/v2:\nDiscardingSink.java\n\napi/functions/source:\nSerializedCheckpointData.java\ndatagen\n\napi/functions/source/datagen:\nDataGenerator.java\nDataGeneratorSource.java\nRandomGenerator.java\nSequenceGenerator.java\n---\napi/legacy/io/TextInputFormat.java:33: * @deprecated If you want to read/write data from/to text file, please use FLIP-27 FileSource and\napi/functions/source/datagen/DataGeneratorSource.java:37: * @deprecated Use {@code org.apache.flink.connector.datagen.source.DataGeneratorSource} instead.\napi/legacy/io/TextOutputFormat.java:37: * @deprecated If you want to read/write data from/to text file, please use FLIP-27 FileSource and\napi/functions/sink/legacy/DiscardingSink.java:28: * @deprecated This interface will be removed in future versions. Use the new {@link\napi/functions/sink/legacy/TwoPhaseCommitSinkFunction.java:72: * @deprecated This interface will be removed in future versions. Use the new {@link\napi/functions/sink/filesystem/legacy/StreamingFileSink.java:98: * @deprecated Use {@link org.apache.flink.connector.file.sink.FileSink} instead.",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "command": "sed -n 20,60p api/functions/timestamps/AscendingTimestampExtractor.java; echo ===; grep -rn -B4 \"@Deprecated\" /workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java /workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTestHarness.java /workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java | head -40",
  "description": "Inspect AscendingTimestampExtractor and test harness deprecations"
}

Output

{
  "stdout": "import org.apache.flink.annotation.PublicEvolving;\nimport org.apache.flink.streaming.api.watermark.Watermark;\nimport org.apache.flink.streaming.runtime.operators.util.WatermarkStrategyWithPeriodicWatermarks;\n\nimport org.slf4j.Logger;\nimport org.slf4j.LoggerFactory;\n\nimport static java.util.Objects.requireNonNull;\n\n/**\n * A timestamp assigner and watermark generator for streams where timestamps are monotonously\n * ascending. In this case, the local watermarks for the streams are easy to generate, because they\n * strictly follow the timestamps.\n *\n * @param <T> The type of the elements that this function can extract timestamps from\n */\n@Deprecated\n@PublicEvolving\npublic abstract class AscendingTimestampExtractor<T>\n        implements WatermarkStrategyWithPeriodicWatermarks<T> {\n\n    private static final long serialVersionUID = 1L;\n\n    /** The current timestamp. */\n    private long currentTimestamp = Long.MIN_VALUE;\n\n    /** Handler that is called when timestamp monotony is violated. */\n    private MonotonyViolationHandler violationHandler = new LoggingHandler();\n\n    /**\n     * Extracts the timestamp from the given element. The timestamp must be monotonically\n     * increasing.\n     *\n     * @param element The element that the timestamp is extracted from.\n     * @return The new timestamp.\n     */\n    public abstract long extractAscendingTimestamp(T element);\n\n    /**\n     * Sets the handler for violations to the ascending timestamp order.\n===\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTestHarness.java-52- *\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTestHarness.java-53- * @deprecated Please use {@link StreamTaskMailboxTestHarness} and {@link\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTestHarness.java-54- *     StreamTaskMailboxTestHarnessBuilder}. Do not add new code using this test harness.\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTestHarness.java-55- */\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTestHarness.java:56:@Deprecated\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java-52- *\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java-53- * @deprecated Please use {@link StreamTaskMailboxTestHarness} and {@link\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java-54- *     StreamTaskMailboxTestHarnessBuilder}. Do not add new code using this test harness.\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java-55- */\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java:56:@Deprecated\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java-97- *\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java-98- * @deprecated Please use {@link StreamTaskMailboxTestHarness} and {@link\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java-99- *     StreamTaskMailboxTestHarnessBuilder}. Do not add new code using this test harness.\n/workspace/flink--0cc95fcc/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarnes
...

Input

{
  "command": "grep -rn \"@Deprecated\" /workspace/flink--0cc95fcc/flink-streaming-java/src/main --include=\"*.java\"; echo ===; cat /workspace/flink--0cc95fcc/sourcegraph.yaml 2>/dev/null; head -3 /workspace/flink--0cc95fcc/README.md",
  "description": "List all @Deprecated occurrences and confirm repo identity"
}

Output

{
  "stdout": "/workspace/flink--0cc95fcc/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextOutputFormat.java:42:@Deprecated\n/workspace/flink--0cc95fcc/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextInputFormat.java:37:@Deprecated\n/workspace/flink--0cc95fcc/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java:37:@Deprecated\n===\n# Auto-indexing configuration for Sourcegraph SCIP.\n# Presence of this file on the scip-enabled branch signals that\n# precise code intelligence should be enabled for this repository.\n# Inference is used to determine which indexers to run.\nindex_jobs: []\n\n# Apache Flink\n\nApache Flink is an open source stream processing framework with powerful stream- and batch-processing capabilities.",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "file_path": "/workspace/answer.json",
  "content": "{\n  \"files\": [\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextInputFormat.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextOutputFormat.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGeneratorSource.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/legacy/DiscardingSink.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/legacy/TwoPhaseCommitSinkFunction.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/legacy/StreamingFileSink.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTestHarness.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java\"}\n  ],\n  \"symbols\": [\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java\", \"symbol\": \"AscendingTimestampExtractor\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextInputFormat.java\", \"symbol\": \"TextInputFormat\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextOutputFormat.java\", \"symbol\": \"TextOutputFormat\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGeneratorSource.java\", \"symbol\": \"DataGeneratorSource\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/legacy/DiscardingSink.java\", \"symbol\": \"DiscardingSink\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/legacy/TwoPhaseCommitSinkFunction.java\", \"symbol\": \"TwoPhaseCommitSinkFunction\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/legacy/StreamingFileSink.java\", \"symbol\": \"StreamingFileSink\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java\", \"symbol\": \"StreamTaskTestHarness\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTestHarness.java\", \"symbol\": \"OneInputStreamTaskTestHarness\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java\", \"symbol\": \"TwoInputStreamTaskTestHarness\"}\n  ],\n  \"text\": \"Searched apache/flink (checkout at /workspace/flink--0cc95fcc) under flink-streaming-java/src/ for @Deprecated annotations and @deprecated javadoc tags on DataStream API classes, focusing on source functions, sink functions, timestamp extractors, and I/O format classes.\\n\\nC
...

Output

{
  "type": "create",
  "filePath": "/workspace/answer.json",
  "content": "{\n  \"files\": [\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextInputFormat.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextOutputFormat.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGeneratorSource.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/legacy/DiscardingSink.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/legacy/TwoPhaseCommitSinkFunction.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/legacy/StreamingFileSink.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTestHarness.java\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java\"}\n  ],\n  \"symbols\": [\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java\", \"symbol\": \"AscendingTimestampExtractor\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextInputFormat.java\", \"symbol\": \"TextInputFormat\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextOutputFormat.java\", \"symbol\": \"TextOutputFormat\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGeneratorSource.java\", \"symbol\": \"DataGeneratorSource\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/legacy/DiscardingSink.java\", \"symbol\": \"DiscardingSink\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/legacy/TwoPhaseCommitSinkFunction.java\", \"symbol\": \"TwoPhaseCommitSinkFunction\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/legacy/StreamingFileSink.java\", \"symbol\": \"StreamingFileSink\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java\", \"symbol\": \"StreamTaskTestHarness\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTestHarness.java\", \"symbol\": \"OneInputStreamTaskTestHarness\"},\n    {\"repo\": \"apache/flink\", \"path\": \"flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java\", \"symbol\": \"TwoInputStreamTaskTestHarness\"}\n  ],\n  \"text\": \"Searched apache/flink (checkout at /workspace/flink--0cc95fcc) under flink-streaming-java/src/ for @Deprecated annotations and @deprecated javadoc tags on DataStream API classes, focusing on source functions, sink functions, timestamp extractors, and I/O for
...

{
  "files": [
    {"repo": "apache/flink", "path": "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextInputFormat.java"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextOutputFormat.java"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGeneratorSource.java"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/legacy/DiscardingSink.java"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/legacy/TwoPhaseCommitSinkFunction.java"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/legacy/StreamingFileSink.java"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTestHarness.java"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java"}
  ],
  "symbols": [
    {"repo": "apache/flink", "path": "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java", "symbol": "AscendingTimestampExtractor"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextInputFormat.java", "symbol": "TextInputFormat"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/legacy/io/TextOutputFormat.java", "symbol": "TextOutputFormat"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGeneratorSource.java", "symbol": "DataGeneratorSource"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/legacy/DiscardingSink.java", "symbol": "DiscardingSink"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/legacy/TwoPhaseCommitSinkFunction.java", "symbol": "TwoPhaseCommitSinkFunction"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/legacy/StreamingFileSink.java", "symbol": "StreamingFileSink"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java", "symbol": "StreamTaskTestHarness"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTestHarness.java", "symbol": "OneInputStreamTaskTestHarness"},
    {"repo": "apache/flink", "path": "flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java", "symbol": "TwoInputStreamTaskTestHarness"}
  ],
  "text": "Searched apache/flink (checkout at /workspace/flink--0cc95fcc) under flink-streaming-java/src/ for @Deprecated annotations and @deprecated javadoc tags on DataStream API classes, focusing on source functions, sink functions, timestamp extractors, and I/O format classes.\n\nClasses carrying the @Deprecated annotation in src/main:\n1. AscendingTimestampExtractor (api/functions/timestamps/AscendingTimestampExtractor.java:37) — class-level @Deprecated; it is the legacy periodic-watermark timestamp extractor (implements WatermarkStrategyWithPeriodicWatermarks). The...