public class HttpJsonLineageStub extends LineageStub
REST stub implementation for the Lineage service API.
This class is for advanced usage and reflects the underlying API directly.
Static Methods
create(ClientContext clientContext)
public static final HttpJsonLineageStub create(ClientContext clientContext)
Parameter
Returns
Exceptions
create(ClientContext clientContext, HttpJsonStubCallableFactory callableFactory)
public static final HttpJsonLineageStub create(ClientContext clientContext, HttpJsonStubCallableFactory callableFactory)
Parameters
Returns
Exceptions
create(LineageStubSettings settings)
public static final HttpJsonLineageStub create(LineageStubSettings settings)
Parameter
Returns
Exceptions
getMethodDescriptors()
public static List<ApiMethodDescriptor> getMethodDescriptors()
Returns
Constructors
HttpJsonLineageStub(LineageStubSettings settings, ClientContext clientContext)
protected HttpJsonLineageStub(LineageStubSettings settings, ClientContext clientContext)
Constructs an instance of HttpJsonLineageStub, using the given settings. This is protected so
that it is easy to make a subclass, but otherwise, the static factory methods should be
preferred.
Parameters
HttpJsonLineageStub(LineageStubSettings settings, ClientContext clientContext, HttpJsonStubCallableFactory callableFactory)
protected HttpJsonLineageStub(LineageStubSettings settings, ClientContext clientContext, HttpJsonStubCallableFactory callableFactory)
Constructs an instance of HttpJsonLineageStub, using the given settings. This is protected so
that it is easy to make a subclass, but otherwise, the static factory methods should be
preferred.
Parameters
Methods
awaitTermination(long duration, TimeUnit unit)
public boolean awaitTermination(long duration, TimeUnit unit)
Parameters
Returns
Exceptions
batchSearchLinkProcessesCallable()
public UnaryCallable<BatchSearchLinkProcessesRequest,BatchSearchLinkProcessesResponse> batchSearchLinkProcessesCallable()
Returns
Overrides
batchSearchLinkProcessesPagedCallable()
public UnaryCallable<BatchSearchLinkProcessesRequest,LineageClient.BatchSearchLinkProcessesPagedResponse> batchSearchLinkProcessesPagedCallable()
Returns
Overrides
close()
public final void close()
Overrides
createLineageEventCallable()
public UnaryCallable<CreateLineageEventRequest,LineageEvent> createLineageEventCallable()
Returns
Overrides
createProcessCallable()
public UnaryCallable<CreateProcessRequest,Process> createProcessCallable()
Returns
Overrides
createRunCallable()
public UnaryCallable<CreateRunRequest,Run> createRunCallable()
Returns
Overrides
deleteLineageEventCallable()
public UnaryCallable<DeleteLineageEventRequest,Empty> deleteLineageEventCallable()
Returns
Overrides
deleteProcessCallable()
public UnaryCallable<DeleteProcessRequest,Operation> deleteProcessCallable()
Returns
Overrides
deleteProcessOperationCallable()
public OperationCallable<DeleteProcessRequest,Empty,OperationMetadata> deleteProcessOperationCallable()
Returns
Overrides
deleteRunCallable()
public UnaryCallable<DeleteRunRequest,Operation> deleteRunCallable()
Returns
Overrides
deleteRunOperationCallable()
public OperationCallable<DeleteRunRequest,Empty,OperationMetadata> deleteRunOperationCallable()
Returns
Overrides
getHttpJsonOperationsStub()
public HttpJsonOperationsStub getHttpJsonOperationsStub()
Returns
Overrides
getLineageEventCallable()
public UnaryCallable<GetLineageEventRequest,LineageEvent> getLineageEventCallable()
Returns
Overrides
getProcessCallable()
public UnaryCallable<GetProcessRequest,Process> getProcessCallable()
Returns
Overrides
getRunCallable()
public UnaryCallable<GetRunRequest,Run> getRunCallable()
Returns
Overrides
isShutdown()
public boolean isShutdown()
Returns
isTerminated()
public boolean isTerminated()
Returns
listLineageEventsCallable()
public UnaryCallable<ListLineageEventsRequest,ListLineageEventsResponse> listLineageEventsCallable()
Returns
Overrides
listLineageEventsPagedCallable()
public UnaryCallable<ListLineageEventsRequest,LineageClient.ListLineageEventsPagedResponse> listLineageEventsPagedCallable()
Returns
Overrides
listProcessesCallable()
public UnaryCallable<ListProcessesRequest,ListProcessesResponse> listProcessesCallable()
Returns
Overrides
listProcessesPagedCallable()
public UnaryCallable<ListProcessesRequest,LineageClient.ListProcessesPagedResponse> listProcessesPagedCallable()
Returns
Overrides
listRunsCallable()
public UnaryCallable<ListRunsRequest,ListRunsResponse> listRunsCallable()
Returns
Overrides
listRunsPagedCallable()
public UnaryCallable<ListRunsRequest,LineageClient.ListRunsPagedResponse> listRunsPagedCallable()
Returns
Overrides
searchLinksCallable()
public UnaryCallable<SearchLinksRequest,SearchLinksResponse> searchLinksCallable()
Returns
Overrides
searchLinksPagedCallable()
public UnaryCallable<SearchLinksRequest,LineageClient.SearchLinksPagedResponse> searchLinksPagedCallable()
Returns
Overrides
shutdown()
shutdownNow()
public void shutdownNow()
updateProcessCallable()
public UnaryCallable<UpdateProcessRequest,Process> updateProcessCallable()
Returns
Overrides
updateRunCallable()
public UnaryCallable<UpdateRunRequest,Run> updateRunCallable()
Returns
Overrides