OriginalCompleteBefore

OriginalCompleteAfter

Before

After

Project

Commit

CompilationUnit

LineNos

Names

TemplateVariableToCodeBefore

RelevantImports

TemplateVariableToCodeAfter

isRelevant

isSafe

outputFilePath = FLINK_TMP_DATA_DIR + STR0 + envID+ STR1+ setID+ this.function.getRuntimeContext().getIndexOfThisSubtask()+ STR2

outputFile = new File(tmpDir,envID + STR1 + setID+ this.function.getRuntimeContext().getIndexOfThisSubtask()+ STR3)

FLINK_TMP_DATA_DIR + STR0 + envID+ STR1+ setID+ this.function.getRuntimeContext().getIndexOfThisSubtask()+ STR2

new File(tmpDir,envID + STR1 + setID+ this.function.getRuntimeContext().getIndexOfThisSubtask()+ STR3)

flink

bdcebfda06846a1e21bb6a4678909d503ebc6333

org.apache.flink.python.api.streaming.data.PythonStreamer

_1	104
_2	105

_1	outputFilePath
_2	outputFile

v0	envID
v1	STR1

v0	envID
v1	STR1

AssignedTo

False

inputFilePath = FLINK_TMP_DATA_DIR + STR0 + envID+ STR1+ setID+ this.function.getRuntimeContext().getIndexOfThisSubtask()+ STR2

inputFile = new File(tmpDir,envID + STR1 + setID+ this.function.getRuntimeContext().getIndexOfThisSubtask()+ STR3)