Pipelines

Pipelines

Methods

list(, ):
Deprecated
get/accounts/{account_id}/pipelines

Deprecated

Use list_v1 instead. This endpoint will be removed in the future.

[DEPRECATED] List, filter, and paginate pipelines in an account. Use the new /pipelines/v1/pipelines endpoint instead.

get(, , ):
Deprecated
get/accounts/{account_id}/pipelines/{pipeline_name}

Deprecated

Use get_v1 instead. This endpoint will be removed in the future.

[DEPRECATED] Get configuration of a pipeline. Use the new /pipelines/v1/pipelines endpoint instead.

create(, ):
Deprecated
post/accounts/{account_id}/pipelines

Deprecated

Use create_v1 instead. This endpoint will be removed in the future.

[DEPRECATED] Create a new pipeline. Use the new /pipelines/v1/pipelines endpoint instead.

update(, , ):
Deprecated
put/accounts/{account_id}/pipelines/{pipeline_name}

Deprecated

The v1 API does not support updates. This endpoint will be removed in the future.

[DEPRECATED] Update an existing pipeline. Use the new /pipelines/v1/pipelines endpoint instead.

delete(, , ): void
Deprecated
delete/accounts/{account_id}/pipelines/{pipeline_name}

Deprecated

Use delete_v1 instead. This endpoint will be removed in the future.

[DEPRECATED] Delete a pipeline. Use the new /pipelines/v1/pipelines endpoint instead.

listV1(, ): <>
get/accounts/{account_id}/pipelines/v1/pipelines

List/Filter Pipelines in Account.

getV1(, , ):
get/accounts/{account_id}/pipelines/v1/pipelines/{pipeline_id}

Get Pipelines Details.

createV1(, ):
post/accounts/{account_id}/pipelines/v1/pipelines

Create a new Pipeline.

deleteV1(, , ): void
delete/accounts/{account_id}/pipelines/v1/pipelines/{pipeline_id}

Delete Pipeline in Account.

validateSql(, ):
post/accounts/{account_id}/pipelines/v1/validate_sql

Validate Arroyo SQL.

Pipelines.Sinks

Methods

list(, ): <>
get/accounts/{account_id}/pipelines/v1/sinks

List/Filter Sinks in Account.

get(, , ):
get/accounts/{account_id}/pipelines/v1/sinks/{sink_id}

Get Sink Details.

create(, ):
post/accounts/{account_id}/pipelines/v1/sinks

Create a new Sink.

delete(, , ): void
delete/accounts/{account_id}/pipelines/v1/sinks/{sink_id}

Delete Pipeline in Account.

Pipelines

Streams

Pipelines.Streams

Methods

list(, ): <>
get/accounts/{account_id}/pipelines/v1/streams

List/Filter Streams in Account.

get(, , ):
get/accounts/{account_id}/pipelines/v1/streams/{stream_id}

Get Stream Details.

create(, ):
post/accounts/{account_id}/pipelines/v1/streams

Create a new Stream.

update(, , ):
patch/accounts/{account_id}/pipelines/v1/streams/{stream_id}

Update a Stream.

delete(, , ): void
delete/accounts/{account_id}/pipelines/v1/streams/{stream_id}

Delete Stream in Account.