Package | Description |
---|---|
org.apache.tez.dag.api | |
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 |
---|---|
static StatusGetOpts |
DagTypeConverters.convertStatusGetOptsFromProto(DAGProtos.StatusGetOptsProto proto) |
Modifier and Type | Method and Description |
---|---|
static Set<StatusGetOpts> |
DagTypeConverters.convertStatusGetOptsFromProto(List<DAGProtos.StatusGetOptsProto> protoList) |
Modifier and Type | Method and Description |
---|---|
static DAGProtos.StatusGetOptsProto |
DagTypeConverters.convertStatusGetOptsToProto(StatusGetOpts statusGetOpts) |
Modifier and Type | Method and Description |
---|---|
static List<DAGProtos.StatusGetOptsProto> |
DagTypeConverters.convertStatusGetOptsToProto(Set<StatusGetOpts> statusGetOpts) |
Modifier and Type | Method and Description |
---|---|
static StatusGetOpts |
StatusGetOpts.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static StatusGetOpts[] |
StatusGetOpts.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
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.
|
VertexStatus |
DAGClientTimelineImpl.getVertexStatus(String vertexName,
Set<StatusGetOpts> statusOptions) |
abstract VertexStatus |
DAGClientInternal.getVertexStatus(String vertexName,
Set<StatusGetOpts> statusOptions)
Get the status of a Vertex of a DAG
|
VertexStatus |
DAGClientImpl.getVertexStatus(String vertexName,
Set<StatusGetOpts> statusOptions) |
abstract VertexStatus |
DAGClient.getVertexStatus(String vertexName,
Set<StatusGetOpts> statusOptions)
Get the status of a Vertex of a DAG
|
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) |
VertexStatus |
DAGClientRPCImpl.getVertexStatus(String vertexName,
Set<StatusGetOpts> statusOptions) |
DAGStatus |
DAGClientRPCImpl.waitForCompletionWithStatusUpdates(Set<StatusGetOpts> statusGetOpts) |
Copyright © 2016 Apache Software Foundation. All rights reserved.