-
Notifications
You must be signed in to change notification settings - Fork 11
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Clean-ups around javadocs #15
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Good job! Seems like a lot of effort to write thousand lines of missing Javadocs.
I just scanned through. There are few typos, but it's cool. I recommend a spell checker in IDEA.
Thanks!
@@ -21,17 +21,17 @@ | |||
|
|||
/** | |||
* Annotation marking an operator a {@code Basic} operator. | |||
* A basic operator is such operator that an executor *must* implement | |||
* in order to be able to run any flow. | |||
* Such an operator *must* be implement (natively) by an executor |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
be implement_ed_
?
* @param <T> the type of elements in the dataset | ||
* | ||
* @param flow the flow to associate the dataset with | ||
* @param source the source to represents as the returned dataset |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
represent
or maybe the source producing the returned dataset
?
*/ | ||
public int size() { | ||
return operators.size(); | ||
} | ||
|
||
/** | ||
* Retrieve currently registered consumers of dataset. | ||
* Determines the consumers of a given dataset asscuming that data set is directly |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
the consumers
without the
+ assuming
typo
* | ||
* @return a dataset representing the specified source | ||
* | ||
* @throws Exception if setting up the source fails for some reason | ||
*/ | ||
public <T> Dataset<T> createInput(URI uri) throws Exception { | ||
return createInput(getSourceFromURI(uri)); | ||
} | ||
|
||
/** | ||
* Create new input dataset. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Creates
*/ | ||
@FunctionalInterface | ||
public interface BinaryFunction<LEFT, RIGHT, OUT> extends Serializable { | ||
|
||
|
||
/** Return the result of this function. */ | ||
/** | ||
* Return the result of this function. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This function returns result of this function
, cpt. obvious 😄
We can omit that.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
:D good catch!
@@ -100,6 +109,12 @@ public static TaskAttemptContext createTaskContext(Configuration conf, | |||
/** | |||
* Serialization helper to try deserializaing the given byte array into an object |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
typo deserializaing
* @return Modified configuration | ||
* | ||
* @throws IOException if serializaing the given data source fails for some reason |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
typo serializaing
* | ||
* @param operator the operator to inspect | ||
* | ||
* @return the given operotor's single input data set/stream |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
typo operotor
* Creates a new input/source data set based on the specified URI. | ||
* | ||
* @param <T> the type of elements extracted form the source; this is not | ||
* type-safe. if a caller mixes up the source and the exected type from |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
typo exected
@@ -28,13 +28,16 @@ | |||
@Target(ElementType.TYPE) | |||
public @interface Recommended { | |||
|
|||
/** Textual documentation of the reason of the recommendation. */ | |||
/** | |||
* @return a human readable explanation why the annoated operator is recommendation |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
typo annoated
000a2a8
to
7ee2b97
Compare
@vanekjar many thanks for the correction suggestions! fixed all of them and squashed into the original commit. ready to merge. |
Clean-ups around javadocs
mvn clean package
I'm not sure I can properly describe the generic type parameter onupdate: will resolve this separately. many thanks for the offline discussion!Dataset#getgetPartitioning()
😟 May I ask for help on this one?