This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new 6f66e23 [FLINK-11646][test] Remove not used MockRecordWriter (#7730) 6f66e23 is described below commit 6f66e2358f04b96dd9462c89ac192f829db8846c Author: zhijiang <wangzhijiang...@aliyun.com> AuthorDate: Tue Mar 12 19:34:30 2019 +0800 [FLINK-11646][test] Remove not used MockRecordWriter (#7730) MockRecordWriter is not used any more, so remove it to make code clean. --- .../streaming/api/streamtask/MockRecordWriter.java | 48 ---------------------- 1 file changed, 48 deletions(-) diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/streamtask/MockRecordWriter.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/streamtask/MockRecordWriter.java deleted file mode 100644 index 781a216..0000000 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/streamtask/MockRecordWriter.java +++ /dev/null @@ -1,48 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.flink.streaming.api.streamtask; - -import org.apache.flink.api.java.tuple.Tuple1; -import org.apache.flink.runtime.io.network.api.writer.RecordWriter; -import org.apache.flink.runtime.operators.DataSourceTask; -import org.apache.flink.runtime.plugable.SerializationDelegate; -import org.apache.flink.streaming.runtime.streamrecord.StreamRecord; - -import java.util.ArrayList; - -/** - * Mock {@link RecordWriter}. - */ -public class MockRecordWriter extends RecordWriter<SerializationDelegate<StreamRecord<Tuple1<Integer>>>> { - - public ArrayList<Integer> emittedRecords; - - public MockRecordWriter(DataSourceTask<?> inputBase, Class<StreamRecord<Tuple1<Integer>>> outputClass) { - super(inputBase.getEnvironment().getWriter(0)); - } - - public boolean initList() { - emittedRecords = new ArrayList<Integer>(); - return true; - } - - @Override - public void emit(SerializationDelegate<StreamRecord<Tuple1<Integer>>> record) { - emittedRecords.add(record.getInstance().getValue().f0); - } -}