Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
doujutun3207
flink
提交
49ca3edd
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,发现更多精彩内容 >>
提交
49ca3edd
编写于
7月 09, 2014
作者:
S
Stephan Ewen
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Clean up checkstyle and JavaDoc errors in core project
上级
52f9cf63
变更
9
隐藏空白更改
内联
并排
Showing
9 changed file
with
8 addition
and
12 deletion
+8
-12
stratosphere-core/src/main/java/eu/stratosphere/api/common/operators/base/BulkIterationBase.java
...tosphere/api/common/operators/base/BulkIterationBase.java
+1
-1
stratosphere-core/src/main/java/eu/stratosphere/api/common/typeutils/TypeComparator.java
.../eu/stratosphere/api/common/typeutils/TypeComparator.java
+2
-2
stratosphere-core/src/main/java/eu/stratosphere/core/memory/DataInputView.java
.../main/java/eu/stratosphere/core/memory/DataInputView.java
+0
-1
stratosphere-core/src/main/java/eu/stratosphere/core/memory/InputViewDataInputStreamWrapper.java
...tosphere/core/memory/InputViewDataInputStreamWrapper.java
+1
-0
stratosphere-core/src/main/java/eu/stratosphere/core/memory/InputViewObjectInputStreamWrapper.java
...sphere/core/memory/InputViewObjectInputStreamWrapper.java
+1
-0
stratosphere-core/src/main/java/eu/stratosphere/core/memory/SeekableDataInputView.java
...va/eu/stratosphere/core/memory/SeekableDataInputView.java
+0
-3
stratosphere-core/src/main/java/eu/stratosphere/types/NormalizableKey.java
.../src/main/java/eu/stratosphere/types/NormalizableKey.java
+2
-2
stratosphere-core/src/main/java/eu/stratosphere/types/Record.java
...here-core/src/main/java/eu/stratosphere/types/Record.java
+1
-1
stratosphere-core/src/test/java/eu/stratosphere/types/RecordTest.java
...-core/src/test/java/eu/stratosphere/types/RecordTest.java
+0
-2
未找到文件。
stratosphere-core/src/main/java/eu/stratosphere/api/common/operators/base/BulkIterationBase.java
浏览文件 @
49ca3edd
...
...
@@ -145,7 +145,7 @@ public class BulkIterationBase<T> extends SingleInputOperator<T, T, AbstractFunc
}
/**
* @throws Exception
* @throws
InvalidProgram
Exception
*/
public
void
validate
()
throws
InvalidProgramException
{
if
(
this
.
input
==
null
)
{
...
...
stratosphere-core/src/main/java/eu/stratosphere/api/common/typeutils/TypeComparator.java
浏览文件 @
49ca3edd
...
...
@@ -40,7 +40,7 @@ import eu.stratosphere.core.memory.MemorySegment;
* @see java.lang.Object#equals(Object)
* @see java.util.Comparator#compare(Object, Object)
*
* @param
T
The data type that the comparator works on.
* @param
<T>
The data type that the comparator works on.
*/
public
abstract
class
TypeComparator
<
T
>
implements
Serializable
{
...
...
@@ -192,7 +192,7 @@ public abstract class TypeComparator<T> implements Serializable {
/**
* Gets the number of bytes that the normalized key would maximally take. A value of
* {@link java.lang.Integer
.MAX_VALUE}
is interpreted as infinite.
* {@link java.lang.Integer
}.MAX_VALUE
is interpreted as infinite.
*
* @return The number of bytes that the normalized key would maximally take.
*/
...
...
stratosphere-core/src/main/java/eu/stratosphere/core/memory/DataInputView.java
浏览文件 @
49ca3edd
...
...
@@ -30,7 +30,6 @@ public interface DataInputView extends DataInput {
*
* @param numBytes The number of bytes to skip.
*
* @throws EOFException Thrown, when less then {@code numBytes} remain in the input.
* @throws IOException Thrown, if any I/O related problem occurred such that the input could not
* be advanced to the desired position.
*/
...
...
stratosphere-core/src/main/java/eu/stratosphere/core/memory/InputViewDataInputStreamWrapper.java
浏览文件 @
49ca3edd
...
...
@@ -108,6 +108,7 @@ public class InputViewDataInputStreamWrapper implements DataInputView {
return
in
.
readDouble
();
}
@SuppressWarnings
(
"deprecation"
)
@Override
public
String
readLine
()
throws
IOException
{
return
in
.
readLine
();
...
...
stratosphere-core/src/main/java/eu/stratosphere/core/memory/InputViewObjectInputStreamWrapper.java
浏览文件 @
49ca3edd
...
...
@@ -108,6 +108,7 @@ public class InputViewObjectInputStreamWrapper implements DataInputView {
return
in
.
readDouble
();
}
@SuppressWarnings
(
"deprecation"
)
@Override
public
String
readLine
()
throws
IOException
{
return
in
.
readLine
();
...
...
stratosphere-core/src/main/java/eu/stratosphere/core/memory/SeekableDataInputView.java
浏览文件 @
49ca3edd
...
...
@@ -23,9 +23,6 @@ public interface SeekableDataInputView extends DataInputView {
* Sets the read pointer to the given position.
*
* @param position The new read position.
*
* @throws IOException Thrown, if any I/O related problem occurred such that the input could not
* be sought to the desired position.
*/
public
void
setReadPosition
(
long
position
);
}
stratosphere-core/src/main/java/eu/stratosphere/types/NormalizableKey.java
浏览文件 @
49ca3edd
...
...
@@ -32,11 +32,11 @@ public interface NormalizableKey<T> extends Key<T> {
/**
* Gets the maximal length of normalized keys that the data type would produce to determine
* the order of instances solely by the normalized key. A value of {@link java.lang.Integer
.MAX_VALUE}
* the order of instances solely by the normalized key. A value of {@link java.lang.Integer
}.MAX_VALUE
* is interpreted as infinite.
* <p>
* For example, 32 bit integers return four, while Strings (potentially unlimited in length) return
* {@link java.lang.Integer
.MAX_VALUE}
.
* {@link java.lang.Integer
}.MAX_VALUE
.
*
* @return The maximal length of normalized keys.
*/
...
...
stratosphere-core/src/main/java/eu/stratosphere/types/Record.java
浏览文件 @
49ca3edd
...
...
@@ -344,7 +344,7 @@ public final class Record implements Value, CopyableValue<Record> {
* @param positions The positions of the fields to get.
* @param targets The values into which the content of the fields is put.
*
* @throws
A NullKeyFieldException in case of a failing field read.
* @throws
NullKeyFieldException in case of a failing field read.
*/
public
void
getFieldsIntoCheckingNull
(
int
[]
positions
,
Value
[]
targets
)
{
for
(
int
i
=
0
;
i
<
positions
.
length
;
i
++)
{
...
...
stratosphere-core/src/test/java/eu/stratosphere/types/RecordTest.java
浏览文件 @
49ca3edd
...
...
@@ -16,9 +16,7 @@ package eu.stratosphere.types;
import
static
org
.
junit
.
Assert
.
assertTrue
;
import
static
org
.
junit
.
Assert
.
fail
;
import
java.io.DataInput
;
import
java.io.DataInputStream
;
import
java.io.DataOutput
;
import
java.io.DataOutputStream
;
import
java.io.IOException
;
import
java.io.PipedInputStream
;
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录