[FLINK-6695] Activate strict checkstyle in flink-contrib - #4004
Conversation
greghogan
left a comment
There was a problem hiding this comment.
+1 with minor comments
|
|
||
| /** | ||
| * Verifies that incoming numbers are either even or odd, controlled by the constructor argument. Emitted tuples are | ||
| * enriched with a new string field containing either "even" or "odd", based on the numbers parity. |
There was a problem hiding this comment.
numbers parity -> numbers' parity
| import org.apache.storm.topology.TopologyBuilder; | ||
|
|
||
| /** | ||
| * A simple topology that splits a number stream based the numbers parity, and verifies the result. |
| import java.util.Random; | ||
|
|
||
| /** | ||
| * A Spout implementation that broadcast random numbers across a specified number of output streams, until a specified |
There was a problem hiding this comment.
"broadcast" -> "broadcasts"
"was" -> "is"?
| import java.util.Map; | ||
|
|
||
| /** | ||
| * A Bolt implementation that verifies meta data emitted by a {@link MetaDataSpout}. |
There was a problem hiding this comment.
I think that this should be "metadata" but see that the class is camelcased MetaData.
|
@greghogan fixed. |
|
|
||
| /** | ||
| * A simple topology that splits a number stream based the numbers parity, and verifies the result. | ||
| * A simple topology that splits a numbers stream based the numbers parity, and verifies the result. |
There was a problem hiding this comment.
What if we simplified this to "splits a number stream based on the parity"?
| /** | ||
| * A Spout implementation that broadcast random numbers across a specified number of output streams, until a specified | ||
| * count was reached. | ||
| * A Spout implementation that broadcast randoms numbers across a specified number of output streams, until a specified |
There was a problem hiding this comment.
wow. I really added the s to the wrong word...
| /** | ||
| * Verifies that incoming numbers are either even or odd, controlled by the constructor argument. Emitted tuples are | ||
| * enriched with a new string field containing either "even" or "odd", based on the numbers parity. | ||
| * enriched with a new string field containing either "even" or "odd", based on the numbers' parity. |
There was a problem hiding this comment.
I think I got this wrong, too. Should probably be number's.
|
@greghogan fixed. |
|
|
||
| /** | ||
| * A simple topology that splits a numbers stream based the numbers parity, and verifies the result. | ||
| * A simple topology that splits a numbers stream based their parity, and verifies the result. |
There was a problem hiding this comment.
This would be a "number stream" or a "stream of numbers"? And I think "based on ...".
|
@greghogan did another attempt at fixing the issues. |
|
+1! |
|
YES! :D merging this. |
This PR activates the strict checkstyle for most modules in flink-contrib;
flink-tweet-inputformatis not included due to proposal to remove it in FLINK-6710.