提交 10aae991 编写于 作者: Z zentol

[FLINK-8250][runtime] Remove unused RecordSerializer#instantiateMetrics

This closes #5162.
上级 50301254
......@@ -22,7 +22,6 @@ package org.apache.flink.runtime.io.network.api.serialization;
import org.apache.flink.core.io.IOReadableWritable;
import org.apache.flink.runtime.io.network.buffer.Buffer;
import org.apache.flink.runtime.io.network.buffer.BufferBuilder;
import org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup;
import java.io.IOException;
......@@ -125,11 +124,4 @@ public interface RecordSerializer<T extends IOReadableWritable> {
* @return <tt>true</tt> if some data is present
*/
boolean hasData();
/**
* Instantiates all metrics.
*
* @param metrics metric group
*/
void instantiateMetrics(TaskIOMetricGroup metrics);
}
......@@ -23,7 +23,6 @@ import org.apache.flink.core.memory.DataOutputSerializer;
import org.apache.flink.core.memory.MemorySegment;
import org.apache.flink.runtime.io.network.buffer.Buffer;
import org.apache.flink.runtime.io.network.buffer.BufferBuilder;
import org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup;
import javax.annotation.Nullable;
......@@ -178,8 +177,4 @@ public class SpanningRecordSerializer<T extends IOReadableWritable> implements R
// either data in current target buffer or intermediate buffers
return (targetBuffer != null && !targetBuffer.isEmpty()) || lengthBuffer.hasRemaining() || dataBuffer.hasRemaining();
}
@Override
public void instantiateMetrics(TaskIOMetricGroup metrics) {
}
}
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册