Package | Description |
---|---|
org.apache.tez.dag.api.client | |
org.apache.tez.dag.api.client.rpc |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
Modifier and Type | Method and Description |
---|---|
DAGStatus |
DAGClientTimelineImpl.getDAGStatus(Set<StatusGetOpts> statusOptions) |
abstract DAGStatus |
DAGClientInternal.getDAGStatus(Set<StatusGetOpts> statusOptions)
Get the status of the specified DAG
|
DAGStatus |
DAGClientImpl.getDAGStatus(Set<StatusGetOpts> statusOptions) |
abstract DAGStatus |
DAGClient.getDAGStatus(Set<StatusGetOpts> statusOptions)
Get the status of the specified DAG
|
DAGStatus |
DAGClientTimelineImpl.getDAGStatus(Set<StatusGetOpts> statusOptions,
long timeout) |
abstract DAGStatus |
DAGClientInternal.getDAGStatus(Set<StatusGetOpts> statusOptions,
long timeout)
Get the status of the specified DAG when it reaches a final state, or the timeout expires.
|
DAGStatus |
DAGClientImpl.getDAGStatus(Set<StatusGetOpts> statusOptions,
long timeout) |
abstract DAGStatus |
DAGClient.getDAGStatus(Set<StatusGetOpts> statusOptions,
long timeout)
Get the status of the specified DAG when it reaches a final state, or the timeout expires.
|
protected DAGStatus |
DAGClientImpl.getDAGStatusViaRM()
Get the DAG status via the YARN ResourceManager
|
DAGStatus |
DAGClientTimelineImpl.waitForCompletion() |
abstract DAGStatus |
DAGClientInternal.waitForCompletion()
Wait for DAG to complete without printing any vertex statuses
|
DAGStatus |
DAGClientImpl.waitForCompletion() |
abstract DAGStatus |
DAGClient.waitForCompletion()
Wait for DAG to complete without printing any vertex statuses
|
DAGStatus |
DAGClientTimelineImpl.waitForCompletionWithStatusUpdates(Set<StatusGetOpts> statusGetOpts) |
abstract DAGStatus |
DAGClientInternal.waitForCompletionWithStatusUpdates(Set<StatusGetOpts> statusGetOpts)
Wait for DAG to complete and periodically print *all* vertices' status.
|
DAGStatus |
DAGClientImpl.waitForCompletionWithStatusUpdates(Set<StatusGetOpts> statusGetOpts) |
abstract DAGStatus |
DAGClient.waitForCompletionWithStatusUpdates(Set<StatusGetOpts> statusGetOpts)
Wait for DAG to complete and periodically print *all* vertices' status.
|
Modifier and Type | Method and Description |
---|---|
DAGStatus |
DAGClientRPCImpl.getDAGStatus(Set<StatusGetOpts> statusOptions) |
DAGStatus |
DAGClientRPCImpl.getDAGStatus(Set<StatusGetOpts> statusOptions,
long timeout) |
DAGStatus |
DAGClientRPCImpl.waitForCompletion() |
DAGStatus |
DAGClientRPCImpl.waitForCompletionWithStatusUpdates(Set<StatusGetOpts> statusGetOpts) |
Copyright © 2016 Apache Software Foundation. All rights reserved.