Toggle navigation
Home
org.apache.flink.streaming.runtime.io.StreamRecordWriter to org.apache.flink.runtime.io.network.api.writer.RecordWriter
No. of Instances - 13
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: R_SUPER_T
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Rename Variable
streamRecordWriter
to
recordWriter
streamRecordWriter
to
recordWriter
streamRecordWriters
to
recordWriters
streamRecordWriters
to
recordWriters
streamRecordWriters
to
recordWriters
streamRecordWriters
to
recordWriters
streamRecordWriters
to
recordWriters
streamRecordWriters
to
recordWriters
streamRecordWriters
to
recordWriters
streamRecordWriter
to
recordWriter
createStreamRecordWriters
to
createRecordWriters
Add or Remove Method invocation
createStreamRecordWriters(configuration,environment)
to
createRecordWriters(configuration,environment)
createStreamRecordWriter(edge,i,environment,environment.getTaskInfo().getTaskName(),chainedConfigs.get(edge.getSourceId()).getBufferTimeout())
to
createRecordWriter(edge,i,environment,environment.getTaskInfo().getTaskName(),chainedConfigs.get(edge.getSourceId()).getBufferTimeout())
createStreamRecordWriter(edge,i,environment,environment.getTaskInfo().getTaskName(),chainedConfigs.get(edge.getSourceId()).getBufferTimeout())
to
createRecordWriter(edge,i,environment,environment.getTaskInfo().getTaskName(),chainedConfigs.get(edge.getSourceId()).getBufferTimeout())