Skip to content

F
flink

doujutun3207 / flink
与 Fork 源项目一致

从无法访问的项目Fork

通知 24
Star 0
Fork 0
F
flink

体验新版 GitCode，发现更多精彩内容 >>

提交 9b31a87b 编写于 作者: M Márton Balassi 提交者： Stephan Ewen
浏览文件
操作

[streaming] minor refactor

上级 9a5801ca
显示空白变更内容
内联 并排
Showing with 3 addition and 3 deletion
flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/StreamRecordTest.java
浏览文件 @ 9b31a87b
...@@ -249,7 +249,7 @@ public class StreamRecordTest { ...@@ -249,7 +249,7 @@ public class StreamRecordTest {
t2 = System.nanoTime() - t; t2 = System.nanoTime() - t;
System.out.println("getFieldFast:\t" + t2 + " ns"); System.out.println("getFieldFast:\t" + t2 + " ns");
StreamRecord record25 = new StreamRecord( StreamRecord record20 = new StreamRecord(
new Tuple20<Integer, Long, String, String, String, String, String, String, String, String, String, String, String, String, String, String, String, String, String, String>( new Tuple20<Integer, Long, String, String, String, String, String, String, String, String, String, String, String, String, String, String, String, String, String, String>(
0, 42L, "Stratosphere", "Streaming", "Stratosphere", 0, 42L, "Stratosphere", "Streaming", "Stratosphere",
"Stratosphere", "Streaming", "Stratosphere", "Stratosphere", "Streaming", "Stratosphere",
...@@ -260,7 +260,7 @@ public class StreamRecordTest { ...@@ -260,7 +260,7 @@ public class StreamRecordTest {
t = System.nanoTime(); t = System.nanoTime();
for (int i = 0; i < ITERATION; i++) { for (int i = 0; i < ITERATION; i++) {
record25.getField(0, i % 20); record20.getField(0, i % 20);
} }
t2 = System.nanoTime() - t; t2 = System.nanoTime() - t;
System.out.println("Tuple20"); System.out.println("Tuple20");
...@@ -268,7 +268,7 @@ public class StreamRecordTest { ...@@ -268,7 +268,7 @@ public class StreamRecordTest {
t = System.nanoTime(); t = System.nanoTime();
for (int i = 0; i < ITERATION; i++) { for (int i = 0; i < ITERATION; i++) {
record25.getFieldFast(0, i % 20); record20.getFieldFast(0, i % 20);
} }
t2 = System.nanoTime() - t; t2 = System.nanoTime() - t;
System.out.println("getFieldFast:\t" + t2 + " ns"); System.out.println("getFieldFast:\t" + t2 + " ns");
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或