Skip to content

Latest commit

 

History

History
230 lines (162 loc) · 7.45 KB

ProvenanceEventsApi.md

File metadata and controls

230 lines (162 loc) · 7.45 KB
Raw

ProvenanceEventsApi

All URIs are relative to http://localhost/nifi-api

Method HTTP request Description
getInputContent GET /provenance-events/{id}/content/input Gets the input content for a provenance event
getOutputContent GET /provenance-events/{id}/content/output Gets the output content for a provenance event
getProvenanceEvent GET /provenance-events/{id} Gets a provenance event
submitReplay POST /provenance-events/replays Replays content from a provenance event

getInputContent

StreamingOutput getInputContent(id, clusterNodeId)

Gets the input content for a provenance event

Example

// Import classes:
//import com.github.hermannpencole.nifi.swagger.ApiClient;
//import com.github.hermannpencole.nifi.swagger.ApiException;
//import com.github.hermannpencole.nifi.swagger.Configuration;
//import com.github.hermannpencole.nifi.swagger.auth.*;
//import com.github.hermannpencole.nifi.swagger.client.ProvenanceEventsApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();

// Configure OAuth2 access token for authorization: auth
OAuth auth = (OAuth) defaultClient.getAuthentication("auth");
auth.setAccessToken("YOUR ACCESS TOKEN");

ProvenanceEventsApi apiInstance = new ProvenanceEventsApi();
String id = "id_example"; // String | The provenance event id.
String clusterNodeId = "clusterNodeId_example"; // String | The id of the node where the content exists if clustered.
try {
    StreamingOutput result = apiInstance.getInputContent(id, clusterNodeId);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ProvenanceEventsApi#getInputContent");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
id String The provenance event id.
clusterNodeId String The id of the node where the content exists if clustered. [optional]

Return type

StreamingOutput

Authorization

auth

HTTP request headers

  • Content-Type: /
  • Accept: /

getOutputContent

StreamingOutput getOutputContent(id, clusterNodeId)

Gets the output content for a provenance event

Example

// Import classes:
//import com.github.hermannpencole.nifi.swagger.ApiClient;
//import com.github.hermannpencole.nifi.swagger.ApiException;
//import com.github.hermannpencole.nifi.swagger.Configuration;
//import com.github.hermannpencole.nifi.swagger.auth.*;
//import com.github.hermannpencole.nifi.swagger.client.ProvenanceEventsApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();

// Configure OAuth2 access token for authorization: auth
OAuth auth = (OAuth) defaultClient.getAuthentication("auth");
auth.setAccessToken("YOUR ACCESS TOKEN");

ProvenanceEventsApi apiInstance = new ProvenanceEventsApi();
String id = "id_example"; // String | The provenance event id.
String clusterNodeId = "clusterNodeId_example"; // String | The id of the node where the content exists if clustered.
try {
    StreamingOutput result = apiInstance.getOutputContent(id, clusterNodeId);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ProvenanceEventsApi#getOutputContent");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
id String The provenance event id.
clusterNodeId String The id of the node where the content exists if clustered. [optional]

Return type

StreamingOutput

Authorization

auth

HTTP request headers

  • Content-Type: /
  • Accept: /

getProvenanceEvent

ProvenanceEventEntity getProvenanceEvent(id, clusterNodeId)

Gets a provenance event

Example

// Import classes:
//import com.github.hermannpencole.nifi.swagger.ApiClient;
//import com.github.hermannpencole.nifi.swagger.ApiException;
//import com.github.hermannpencole.nifi.swagger.Configuration;
//import com.github.hermannpencole.nifi.swagger.auth.*;
//import com.github.hermannpencole.nifi.swagger.client.ProvenanceEventsApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();

// Configure OAuth2 access token for authorization: auth
OAuth auth = (OAuth) defaultClient.getAuthentication("auth");
auth.setAccessToken("YOUR ACCESS TOKEN");

ProvenanceEventsApi apiInstance = new ProvenanceEventsApi();
String id = "id_example"; // String | The provenance event id.
String clusterNodeId = "clusterNodeId_example"; // String | The id of the node where this event exists if clustered.
try {
    ProvenanceEventEntity result = apiInstance.getProvenanceEvent(id, clusterNodeId);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ProvenanceEventsApi#getProvenanceEvent");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
id String The provenance event id.
clusterNodeId String The id of the node where this event exists if clustered. [optional]

Return type

ProvenanceEventEntity

Authorization

auth

HTTP request headers

  • Content-Type: /
  • Accept: application/json

submitReplay

ProvenanceEventEntity submitReplay(body)

Replays content from a provenance event

Example

// Import classes:
//import com.github.hermannpencole.nifi.swagger.ApiClient;
//import com.github.hermannpencole.nifi.swagger.ApiException;
//import com.github.hermannpencole.nifi.swagger.Configuration;
//import com.github.hermannpencole.nifi.swagger.auth.*;
//import com.github.hermannpencole.nifi.swagger.client.ProvenanceEventsApi;

ApiClient defaultClient = Configuration.getDefaultApiClient();

// Configure OAuth2 access token for authorization: auth
OAuth auth = (OAuth) defaultClient.getAuthentication("auth");
auth.setAccessToken("YOUR ACCESS TOKEN");

ProvenanceEventsApi apiInstance = new ProvenanceEventsApi();
SubmitReplayRequestEntity body = new SubmitReplayRequestEntity(); // SubmitReplayRequestEntity | The replay request.
try {
    ProvenanceEventEntity result = apiInstance.submitReplay(body);
    System.out.println(result);
} catch (ApiException e) {
    System.err.println("Exception when calling ProvenanceEventsApi#submitReplay");
    e.printStackTrace();
}

Parameters

Name Type Description Notes
body SubmitReplayRequestEntity The replay request.

Return type

ProvenanceEventEntity

Authorization

auth

HTTP request headers

  • Content-Type: application/json
  • Accept: application/json