ccx-crossorg-288

Input

{
  "command": "ls /workspace && ls /workspace/runners 2>/dev/null | head -30",
  "description": "List workspace contents"
}

Output

{
  "stdout": "beam--v2.62.0",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "command": "ls /workspace/beam--v2.62.0/runners/ && ls /workspace/beam--v2.62.0/runners/core-java/src/main/java/org/apache/beam/runners/core/ | head -50",
  "description": "List runners directories"
}

Output

{
  "stdout": "core-java\ndirect-java\nextensions-java\nflink\ngoogle-cloud-dataflow-java\njava-fn-execution\njava-job-service\njet\nlocal-java\nportability\nprism\nsamza\nspark\ntwister2\nActiveWindowSet.java\nConcatenate.java\nDoFnRunner.java\nDoFnRunners.java\nElementByteSizeObservable.java\nGlobalCombineFnRunner.java\nGlobalCombineFnRunners.java\nGroupAlsoByWindowViaWindowSetNewDoFn.java\nGroupAlsoByWindowsAggregators.java\nGroupByKeyViaGroupByKeyOnly.java\nInMemoryBundleFinalizer.java\nInMemoryMultimapSideInputView.java\nInMemoryStateInternals.java\nInMemoryTimerInternals.java\nKeyedWorkItem.java\nKeyedWorkItemCoder.java\nKeyedWorkItems.java\nLateDataDroppingDoFnRunner.java\nLateDataUtils.java\nMergingActiveWindowSet.java\nMergingStateAccessor.java\nNonEmptyPanes.java\nNonMergingActiveWindowSet.java\nNullSideInputReader.java\nOutputAndTimeBoundedSplittableProcessElementInvoker.java\nOutputWindowedValue.java\nPaneInfoTracker.java\nPeekingReiterator.java\nProcessFnRunner.java\nPushbackSideInputDoFnRunner.java\nReadyCheckingSideInputReader.java\nReduceFn.java\nReduceFnContextFactory.java\nReduceFnRunner.java\nSideInputHandler.java\nSideInputReader.java\nSimpleDoFnRunner.java\nSimplePushbackSideInputDoFnRunner.java\nSplittableParDoViaKeyedWorkItems.java\nSplittableProcessElementInvoker.java\nStateAccessor.java\nStateInternals.java\nStateInternalsFactory.java\nStateMerging.java\nStateNamespace.java\nStateNamespaceForTest.java\nStateNamespaces.java\nStateTable.java\nStateTag.java\nStateTags.java",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "command": "ls /workspace/beam--v2.62.0/runners/core-construction-java 2>/dev/null; find /workspace/beam--v2.62.0 -maxdepth 6 -type d -name construction 2>/dev/null | head",
  "description": "Check for core-construction-java location"
}

Output

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

Input

{
  "command": "grep -rl \"PipelineTranslator\" /workspace/beam--v2.62.0/runners --include=*.java -l | head -20; echo ---; find /workspace/beam--v2.62.0/sdks/java/core -type d -name construction | head",
  "description": "Search for PipelineTranslator and construction package"
}

Output

{
  "stdout": "/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchPortablePipelineTranslator.java\n/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/PipelineTranslationModeOptimizer.java\n/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineExecutionEnvironment.java\n/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/adapter/BeamFlinkDataSetAdapter.java\n/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingPortablePipelineTranslator.java\n/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchPipelineTranslator.java\n/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchTranslationContext.java\n/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineTranslator.java\n/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkTransformOverrides.java\n/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/utils/LookupPipelineVisitor.java\n/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchTransformTranslators.java\n/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPortablePipelineTranslator.java\n/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineRunner.java\n/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingPipelineTranslator.java\n/workspace/beam--v2.62.0/runners/flink/src/test/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslatorsTest.java\n/workspace/beam--v2.62.0/runners/flink/src/test/java/org/apache/beam/runners/flink/FlinkTransformOverridesTest.java\n/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/adapter/BeamFlinkDataStreamAdapter.java\n/workspace/beam--v2.62.0/runners/flink/src/test/java/org/apache/beam/runners/flink/FlinkPipelineExecutionEnvironmentTest.java\n/workspace/beam--v2.62.0/runners/flink/src/test/java/org/apache/beam/runners/flink/FlinkStreamingPipelineTranslatorTest.java\n/workspace/beam--v2.62.0/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java\n---\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction\n/workspace/beam--v2.62.0/sdks/java/core/src/test/java/org/apache/beam/sdk/util/construction",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "command": "ls /workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/",
  "description": "List construction package files"
}

Output

{
  "stdout": "ArtifactResolver.java\nBeamUrns.java\nCoderTranslation.java\nCoderTranslator.java\nCoderTranslatorRegistrar.java\nCoderTranslators.java\nCombineTranslation.java\nCreatePCollectionViewTranslation.java\nDeduplicatedFlattenFactory.java\nDefaultArtifactResolver.java\nDefaultExpansionServiceClientFactory.java\nDisplayDataTranslation.java\nEmptyFlattenAsCreateFactory.java\nEnvironments.java\nExecutableStageTranslation.java\nExpansionServiceClient.java\nExpansionServiceClientFactory.java\nExternal.java\nExternalTranslation.java\nExternalTranslationOptions.java\nExternalTranslationOptionsRegistrar.java\nFlattenTranslator.java\nForwardingPTransform.java\nGroupByKeyTranslation.java\nGroupIntoBatchesTranslation.java\nImpulseTranslation.java\nModelCoderRegistrar.java\nModelCoders.java\nNativeTransforms.java\nPCollectionTranslation.java\nPCollectionViewTranslation.java\nPTransformMatchers.java\nPTransformReplacements.java\nPTransformTranslation.java\nParDoTranslation.java\nPipelineOptionsTranslation.java\nPipelineTranslation.java\nPrimitiveCreate.java\nReadTranslation.java\nRehydratedComponents.java\nReplacementOutputs.java\nReshuffleTranslation.java\nRunnerPCollectionView.java\nSdkComponents.java\nSingleInputOutputOverrideFactory.java\nSplittableParDo.java\nSplittableParDoNaiveBounded.java\nSyntheticComponents.java\nTestStreamTranslation.java\nTimer.java\nTransformInputs.java\nTransformPayloadTranslatorRegistrar.java\nTransformUpgrader.java\nTriggerTranslation.java\nUnboundedReadFromBoundedSource.java\nUnconsumedReads.java\nUnknownCoderWrapper.java\nUnsupportedOverrideFactory.java\nWindowIntoTranslation.java\nWindowingStrategyTranslation.java\nWriteFilesTranslation.java\ngraph\npackage-info.java\nrenderer\nresources",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "command": "ls /workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/; echo ---; grep -rln \"interface PipelineTranslator\\|class TransformHierarchy\\|class PTransformOverride\\b\\|PTransformOverride \" /workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/runners/ 2>/dev/null | head; echo ---; ls /workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/runners/",
  "description": "List graph package and sdk runners package"
}

Output

{
  "stdout": "ExecutableStage.java\nFieldAccessVisitor.java\nFusedPipeline.java\nGreedyPCollectionFusers.java\nGreedyPipelineFuser.java\nGreedyStageFuser.java\nImmutableExecutableStage.java\nNetworks.java\nOutputDeduplicator.java\nPCollectionOutputTagVisitor.java\nPipelineNode.java\nPipelineValidator.java\nProjectionProducerVisitor.java\nProjectionPushdownOptimizer.java\nProtoOverrides.java\nQueryablePipeline.java\nSideInputReference.java\nSplittableParDoExpander.java\nTimerReference.java\nTrivialNativeTransformExpander.java\nUserStateReference.java\npackage-info.java\n---\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/runners/PTransformOverride.java\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/runners/TransformHierarchy.java\n---\nAppliedPTransform.java\nPTransformMatcher.java\nPTransformOverride.java\nPTransformOverrideFactory.java\nPipelineRunnerRegistrar.java\nTransformHierarchy.java\npackage-info.java",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "command": "grep -rln \"BoundedSource\\|UnboundedSource\" /workspace/beam--v2.62.0/runners/core-java/src/main/java | head; echo ---; grep -rn \"interface PipelineTranslator\\|interface TransformTranslator\\|interface TransformPayloadTranslator\" /workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/ /workspace/beam--v2.62.0/runners/core-java/src/main/java | head",
  "description": "Find source adapters and translator interfaces"
}

Output

{
  "stdout": "---\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/TransformPayloadTranslatorRegistrar.java:27:public interface TransformPayloadTranslatorRegistrar {\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformTranslation.java:329:  public interface TransformTranslator<T extends PTransform<?, ?>> {\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformTranslation.java:631:  public interface TransformPayloadTranslator<T extends PTransform<?, ?>> {",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "command": "grep -rn \"ExecutableStagePayload\" /workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/ -l; echo ---; grep -rn \"class PipelineTranslation\" /workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PipelineTranslation.java; grep -n \"TransformHierarchy\\|PipelineVisitor\" /workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PipelineTranslation.java | head",
  "description": "Find ExecutableStagePayload usage and PipelineTranslation details"
}

Output

{
  "stdout": "/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/ExecutableStageTranslation.java\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/ExecutableStage.java\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/ImmutableExecutableStage.java\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/PipelineValidator.java\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/TimerReference.java\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/SideInputReference.java\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/UserStateReference.java\n---\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PipelineTranslation.java:40:public class PipelineTranslation {\n31:import org.apache.beam.sdk.Pipeline.PipelineVisitor;\n33:import org.apache.beam.sdk.runners.TransformHierarchy.Node;\n69:        new PipelineVisitor.Defaults() {",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "command": "find /workspace/beam--v2.62.0/sdks/java/core/src/main/java -name \"BoundedReadFromUnboundedSource.java\"; grep -n \"class UnboundedReadFromBoundedSource\\|BoundedToUnboundedSourceAdapter\" /workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/UnboundedReadFromBoundedSource.java | head -3; grep -n \"class\\|interface\" /workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/ReadTranslation.java | head -5",
  "description": "Check source adapter classes"
}

Output

{
  "stdout": "/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java\n76:public class UnboundedReadFromBoundedSource<T> extends PTransform<PBegin, PCollection<T>> {\n94:    return input.getPipeline().apply(Read.from(new BoundedToUnboundedSourceAdapter<>(source)));\n115:  public static class BoundedToUnboundedSourceAdapter<T>\n51:public class ReadTranslation {\n76:          String.format(\"Unknown %s type %s\", Source.class.getSimpleName(), source.getClass()));\n150:  public static class UnboundedReadPayloadTranslator\n180:  public static class BoundedReadPayloadTranslator\n207:  @AutoService(TransformPayloadTranslatorRegistrar.class)",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "command": "grep -rln \"Translat\\|OverrideFactory\" /workspace/beam--v2.62.0/runners/core-java/src/main/java | head; echo ---; grep -n \"class SplittableParDoViaKeyedWorkItems\\|OverrideFactory\" /workspace/beam--v2.62.0/runners/core-java/src/main/java/org/apache/beam/runners/core/SplittableParDoViaKeyedWorkItems.java | head -5",
  "description": "Check core-java for translation/override classes"
}

Output

{
  "stdout": "/workspace/beam--v2.62.0/runners/core-java/src/main/java/org/apache/beam/runners/core/GroupAlsoByWindowViaWindowSetNewDoFn.java\n/workspace/beam--v2.62.0/runners/core-java/src/main/java/org/apache/beam/runners/core/SplittableParDoViaKeyedWorkItems.java\n/workspace/beam--v2.62.0/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachines.java\n---\n31:import org.apache.beam.sdk.runners.PTransformOverrideFactory;\n74: * <p>A runner that uses {@link OverrideFactory} will need to also provide runner-specific overrides\n77:public class SplittableParDoViaKeyedWorkItems {\n114:  public static class OverrideFactory<InputT, OutputT, RestrictionT, WatermarkEstimatorStateT>\n115:      implements PTransformOverrideFactory<",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "command": "grep -n \"class Primitive\\|class SplittableParDo\\b\\|class NaiveProcessFn\\|class SplittableParDoNaiveBounded\" /workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDo.java /workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDoNaiveBounded.java | head",
  "description": "Confirm Read adapter classes in SplittableParDo"
}

Output

{
  "stdout": "/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDo.java:105:public class SplittableParDo<InputT, OutputT, RestrictionT, WatermarkEstimatorStateT>\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDo.java:774:  private abstract static class PrimitiveRead<T> extends PTransform<PBegin, PCollection<T>> {\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDo.java:816:  public static class PrimitiveBoundedRead<T> extends PrimitiveRead<T> {\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDo.java:836:  public static class PrimitiveUnboundedRead<T> extends PrimitiveRead<T> {\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDoNaiveBounded.java:67:public class SplittableParDoNaiveBounded {\n/workspace/beam--v2.62.0/sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDoNaiveBounded.java:133:  public static class NaiveProcessFn<",
  "stderr": "",
  "interrupted": false,
  "isImage": false,
  "noOutputExpected": false
}

Input

{
  "file_path": "/workspace/answer.json",
  "content": "{\n  \"files\": [\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PipelineTranslation.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformTranslation.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SdkComponents.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/runners/TransformHierarchy.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/runners/PTransformOverride.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/runners/PTransformOverrideFactory.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/runners/PTransformMatcher.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformMatchers.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformReplacements.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/ReplacementOutputs.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SingleInputOutputOverrideFactory.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/UnsupportedOverrideFactory.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/ProtoOverrides.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/ExecutableStage.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/ImmutableExecutableStage.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/ExecutableStageTranslation.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/GreedyPipelineFuser.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/GreedyStageFuser.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/FusedPipeline.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/UnboundedReadFromBoundedSource.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/ReadTranslation.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDo.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDoNaiveBounded.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"runners/core-java/src/main/java/org/apache/beam/runners/core/SplittableParDoViaKeyedWorkItems.java\"}\n  ],\n  \"symbols\": [\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PipelineTranslation.java\", \"symbol\": \"PipelineTranslation\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformTranslation.java\", \"symbol\": \"PTransformTranslatio
...

Output

{
  "type": "create",
  "filePath": "/workspace/answer.json",
  "content": "{\n  \"files\": [\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PipelineTranslation.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformTranslation.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SdkComponents.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/runners/TransformHierarchy.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/runners/PTransformOverride.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/runners/PTransformOverrideFactory.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/runners/PTransformMatcher.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformMatchers.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformReplacements.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/ReplacementOutputs.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SingleInputOutputOverrideFactory.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/UnsupportedOverrideFactory.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/ProtoOverrides.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/ExecutableStage.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/ImmutableExecutableStage.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/ExecutableStageTranslation.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/GreedyPipelineFuser.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/GreedyStageFuser.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/FusedPipeline.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/UnboundedReadFromBoundedSource.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/ReadTranslation.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDo.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDoNaiveBounded.java\"},\n    {\"repo\": \"apache/beam\", \"path\": \"runners/core-java/src/main/java/org/apache/beam/runners/core/SplittableParDoViaKeyedWorkItems.java\"}\n  ],\n  \"symbols\": [\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PipelineTranslation.java\", \"symbol\": \"PipelineTranslation\"},\n    {\"repo\": \"apache/beam\", \"path\": \"sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformTranslation.java\", \"symbol\": \"P
...

{
  "files": [
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PipelineTranslation.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformTranslation.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SdkComponents.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/runners/TransformHierarchy.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/runners/PTransformOverride.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/runners/PTransformOverrideFactory.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/runners/PTransformMatcher.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformMatchers.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformReplacements.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/ReplacementOutputs.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SingleInputOutputOverrideFactory.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/UnsupportedOverrideFactory.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/ProtoOverrides.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/ExecutableStage.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/ImmutableExecutableStage.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/ExecutableStageTranslation.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/GreedyPipelineFuser.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/GreedyStageFuser.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/FusedPipeline.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/UnboundedReadFromBoundedSource.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/ReadTranslation.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDo.java"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDoNaiveBounded.java"},
    {"repo": "apache/beam", "path": "runners/core-java/src/main/java/org/apache/beam/runners/core/SplittableParDoViaKeyedWorkItems.java"}
  ],
  "symbols": [
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PipelineTranslation.java", "symbol": "PipelineTranslation"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformTranslation.java", "symbol": "PTransformTranslation.TransformTranslator"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformTranslation.java", "symbol": "PTransformTranslation.TransformPayloadTranslator"},
    {"repo": "apache/beam", "path": "sdks/java/core/src/main/java/org/apache/beam/sdk/util/co...