Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
doujutun3207
flink
提交
ba2aba80
F
flink
项目概览
doujutun3207
/
flink
与 Fork 源项目一致
从无法访问的项目Fork
通知
24
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
F
flink
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
ba2aba80
编写于
12月 08, 2015
作者:
J
Jun Aoki
提交者:
Fabian Hueske
12月 21, 2015
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[FLINK-3116] Remove RecordOperator
This closes #1444
上级
a6a05288
变更
3
隐藏空白更改
内联
并排
Showing
3 changed file
with
2 addition
and
53 deletion
+2
-53
flink-core/src/main/java/org/apache/flink/api/common/operators/RecordOperator.java
...org/apache/flink/api/common/operators/RecordOperator.java
+0
-35
flink-optimizer/src/main/java/org/apache/flink/optimizer/util/NoOpBinaryUdfOp.java
...java/org/apache/flink/optimizer/util/NoOpBinaryUdfOp.java
+1
-9
flink-optimizer/src/main/java/org/apache/flink/optimizer/util/NoOpUnaryUdfOp.java
.../java/org/apache/flink/optimizer/util/NoOpUnaryUdfOp.java
+1
-9
未找到文件。
flink-core/src/main/java/org/apache/flink/api/common/operators/RecordOperator.java
已删除
100644 → 0
浏览文件 @
a6a05288
/*
* 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.api.common.operators
;
import
org.apache.flink.types.Key
;
/**
* Interface marking operators to be referring to the {@link org.apache.flink.types.Record} data model.
*/
public
interface
RecordOperator
{
/**
* Gets the key classes that this operator works on.
*
* @return The key classes that this operator works on.
*/
Class
<?
extends
Key
<?>>[]
getKeyClasses
();
}
flink-optimizer/src/main/java/org/apache/flink/optimizer/util/NoOpBinaryUdfOp.java
浏览文件 @
ba2aba80
...
...
@@ -25,24 +25,16 @@ import org.apache.flink.api.common.functions.RuntimeContext;
import
org.apache.flink.api.common.functions.util.NoOpFunction
;
import
org.apache.flink.api.common.operators.BinaryOperatorInformation
;
import
org.apache.flink.api.common.operators.DualInputOperator
;
import
org.apache.flink.api.common.operators.RecordOperator
;
import
org.apache.flink.api.common.operators.util.UserCodeClassWrapper
;
import
org.apache.flink.api.common.typeinfo.TypeInformation
;
import
org.apache.flink.types.Key
;
public
class
NoOpBinaryUdfOp
<
OUT
>
extends
DualInputOperator
<
OUT
,
OUT
,
OUT
,
NoOpFunction
>
implements
RecordOperator
{
public
class
NoOpBinaryUdfOp
<
OUT
>
extends
DualInputOperator
<
OUT
,
OUT
,
OUT
,
NoOpFunction
>
{
public
NoOpBinaryUdfOp
(
TypeInformation
<
OUT
>
type
)
{
super
(
new
UserCodeClassWrapper
<
NoOpFunction
>(
NoOpFunction
.
class
),
new
BinaryOperatorInformation
<
OUT
,
OUT
,
OUT
>(
type
,
type
,
type
),
"NoContract"
);
}
@SuppressWarnings
(
"unchecked"
)
@Override
public
Class
<?
extends
Key
<?>>[]
getKeyClasses
()
{
return
(
Class
<?
extends
Key
<?>>[])
new
Class
[
0
];
}
@Override
protected
List
<
OUT
>
executeOnCollections
(
List
<
OUT
>
inputData1
,
List
<
OUT
>
inputData2
,
RuntimeContext
runtimeContext
,
ExecutionConfig
executionConfig
)
{
throw
new
UnsupportedOperationException
();
...
...
flink-optimizer/src/main/java/org/apache/flink/optimizer/util/NoOpUnaryUdfOp.java
浏览文件 @
ba2aba80
...
...
@@ -23,15 +23,13 @@ import java.util.List;
import
org.apache.flink.api.common.ExecutionConfig
;
import
org.apache.flink.api.common.functions.RuntimeContext
;
import
org.apache.flink.api.common.functions.util.NoOpFunction
;
import
org.apache.flink.api.common.operators.RecordOperator
;
import
org.apache.flink.api.common.operators.SingleInputOperator
;
import
org.apache.flink.api.common.operators.UnaryOperatorInformation
;
import
org.apache.flink.api.common.operators.util.UserCodeClassWrapper
;
import
org.apache.flink.api.common.typeinfo.TypeInformation
;
import
org.apache.flink.types.Key
;
public
class
NoOpUnaryUdfOp
<
OUT
>
extends
SingleInputOperator
<
OUT
,
OUT
,
NoOpFunction
>
implements
RecordOperator
{
public
class
NoOpUnaryUdfOp
<
OUT
>
extends
SingleInputOperator
<
OUT
,
OUT
,
NoOpFunction
>
{
@SuppressWarnings
(
"rawtypes"
)
public
static
final
NoOpUnaryUdfOp
INSTANCE
=
new
NoOpUnaryUdfOp
();
...
...
@@ -42,12 +40,6 @@ public class NoOpUnaryUdfOp<OUT> extends SingleInputOperator<OUT, OUT, NoOpFunct
super
(
new
UserCodeClassWrapper
<
NoOpFunction
>(
NoOpFunction
.
class
),
null
,
""
);
}
@SuppressWarnings
(
"unchecked"
)
@Override
public
Class
<?
extends
Key
<?>>[]
getKeyClasses
()
{
return
(
Class
<?
extends
Key
<?>>[])
new
Class
[
0
];
}
@Override
public
UnaryOperatorInformation
<
OUT
,
OUT
>
getOperatorInfo
()
{
TypeInformation
<
OUT
>
previousOut
=
input
.
getOperatorInfo
().
getOutputType
();
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录