You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tez.apache.org by GitBox <gi...@apache.org> on 2021/02/10 14:27:54 UTC

[GitHub] [tez] belugabehr commented on a change in pull request #105: TEZ-4284: Various Improvements for InputReadyTracker

belugabehr commented on a change in pull request #105:
URL: https://github.com/apache/tez/pull/105#discussion_r573769717



##########
File path: tez-api/src/main/java/org/apache/tez/runtime/api/ProcessorContext.java
##########
@@ -96,27 +97,26 @@ default void setProgress(float progress) {
    * call. If invoking this method multiple times, it's recommended to remove
    * previously completed Inputs from the invocation list.
    *
-   * @param inputs
-   *          the list of Inputs to monitor
-   * @param timeoutMillis
-   *          timeout to return in milliseconds. If this value is negative,
-   *          this function will wait forever until all inputs get ready
-   *          or interrupted.
-   * @return the Input which is ready for consumption. return null when timeout occurs.
-   * @throws InterruptedException
+   * @param inputs the list of Inputs to monitor
+   * @param time the maximum time to wait
+   * @param unit the time unit of the time argument
+   * @return the {@code Input} which is ready for consumption or null if timeout
+   *         occurs
+   * @throws InterruptedException if the current thread is interrupted (and
+   *           interruption of thread suspension is supported)
    */
-  public Input waitForAnyInputReady(Collection<Input> inputs, long timeoutMillis) throws InterruptedException;
+  public Input waitForAnyInputReady(Collection<Input> inputs, long time, TimeUnit unit) throws InterruptedException;

Review comment:
       Hey @abstractdog,
   
   Thanks for the input.  I'm obviously new to Tez, so I'm learning the process.  Since Tez isn't even 1.0 yet, I wasn't too worried about backwards compatibility, especially a pretty trivial one like this.  I would caution being too strict pre-1.0 and having a thousand deprecated methods, but if you feel strongly on this, I am happy to put in some backwards compatibility. 




----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org