flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [5/6] flink git commit: [FLINK-6339] [streaming api] Delete unused (and useless) class ConnectorSource
Date Thu, 20 Apr 2017 12:17:15 GMT
[FLINK-6339] [streaming api] Delete unused (and useless) class ConnectorSource


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/81abe73e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/81abe73e
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/81abe73e

Branch: refs/heads/master
Commit: 81abe73e7d9d0a3c2baa2f4a4799dc73083854ef
Parents: 4cf78d6
Author: Stephan Ewen <sewen@apache.org>
Authored: Tue Mar 28 15:02:50 2017 +0200
Committer: Stephan Ewen <sewen@apache.org>
Committed: Thu Apr 20 14:15:58 2017 +0200

----------------------------------------------------------------------
 .../api/functions/source/ConnectorSource.java   | 40 --------------------
 1 file changed, 40 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/81abe73e/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ConnectorSource.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ConnectorSource.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ConnectorSource.java
deleted file mode 100644
index e4e6c68..0000000
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ConnectorSource.java
+++ /dev/null
@@ -1,40 +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.functions.source;
-
-import org.apache.flink.annotation.PublicEvolving;
-import org.apache.flink.api.common.typeinfo.TypeInformation;
-import org.apache.flink.api.java.typeutils.ResultTypeQueryable;
-import org.apache.flink.streaming.util.serialization.DeserializationSchema;
-
-@PublicEvolving
-public abstract class ConnectorSource<OUT> extends RichParallelSourceFunction<OUT>
implements ResultTypeQueryable<OUT> {
-
-	private static final long serialVersionUID = 1L;
-	
-	protected DeserializationSchema<OUT> schema;
-
-	public ConnectorSource(DeserializationSchema<OUT> schema) {
-		this.schema = schema;
-	}
-
-	@Override
-	public TypeInformation<OUT> getProducedType() {
-		return schema.getProducedType();
-	}
-}


Mime
View raw message