Skip to main content

flink_artifacts

Creates, updates, deletes, gets or lists a flink_artifacts resource.

Overview

Nameflink_artifacts
TypeResource
Idconfluent.flink_artifacts.flink_artifacts

Fields

NameDatatypeDescription
idstringID is the "natural identifier" for an object within its scope/namespace; it is normally unique across time but not space. That is, you can assume that the ID will not be reclaimed and reused after an object is deleted ("time"); however, it may collide with IDs for other object kinds or objects of the same kind within a different scope/namespace ("space").
descriptionstringDescription of the Flink Artifact.
api_versionstringAPIVersion defines the schema version of this representation of a resource.
classstringJava class or alias for the artifact as provided by developer.
cloudstringCloud provider where the Flink Artifact archive is uploaded.
content_formatstringArchive format of the Flink Artifact.
display_namestringDisplay name of the Flink Artifact.
documentation_linkstringDocument link of the Flink Artifact.
environmentstringEnvironment the Flink Artifact belongs to.
kindstringKind defines the object this REST resource represents.
metadata``ObjectMeta is metadata that all persisted resources must have, which includes all objects users must create.
regionstringThe Cloud provider region the Flink Artifact archive is uploaded.
runtime_languagestringRuntime language of the Flink Artifact.
versionsarrayVersions associated with this Flink Artifact.

Methods

NameAccessible byRequired ParamsDescription
get_artifact_v1flink_artifactSELECTcloud, id, regionEarly Access Request Access To Flink Artifact API EA Make a request to read a flink artifact.
list_artifact_v1flink_artifactsSELECTcloud, regionEarly Access Request Access To Flink Artifact API EA Retrieve a sorted, filtered, paginated list of all flink artifacts. If no environment filter is specified, returns Artifacts across envs for cloud & region.
create_artifact_v1flink_artifactINSERTcloud, region, data__class, data__cloud, data__display_name, data__environment, data__region, data__upload_sourceEarly Access Request Access To Flink Artifact API EA Make a request to create a flink artifact.
delete_artifact_v1flink_artifactDELETEcloud, id, regionEarly Access Request Access To Flink Artifact API EA Make a request to delete a flink artifact.
update_artifact_v1flink_artifactUPDATEcloud, id, regionEarly Access Request Access To Flink Artifact API EA Make a request to update a flink artifact.

SELECT examples

Early Access Request Access To Flink Artifact API EA Retrieve a sorted, filtered, paginated list of all flink artifacts. If no environment filter is specified, returns Artifacts across envs for cloud & region.

SELECT
id,
description,
api_version,
class,
cloud,
content_format,
display_name,
documentation_link,
environment,
kind,
metadata,
region,
runtime_language,
versions
FROM confluent.flink_artifacts.flink_artifacts
WHERE cloud = '{{ cloud }}'
AND region = '{{ region }}';

INSERT example

Use the following StackQL query and manifest file to create a new flink_artifacts resource.

/*+ create */
INSERT INTO confluent.flink_artifacts.flink_artifacts (
data__cloud,
data__region,
data__environment,
data__display_name,
data__class,
data__content_format,
data__description,
data__documentation_link,
data__runtime_language,
data__upload_source,
cloud,
region
)
SELECT
'{{ cloud }}',
'{{ region }}',
'{{ environment }}',
'{{ display_name }}',
'{{ class }}',
'{{ content_format }}',
'{{ description }}',
'{{ documentation_link }}',
'{{ runtime_language }}',
'{{ upload_source }}'
;

UPDATE example

Updates a flink_artifacts resource.

/*+ update */
UPDATE confluent.flink_artifacts.flink_artifacts
SET
cloud = '{{ cloud }}',
region = '{{ region }}',
environment = '{{ environment }}',
display_name = '{{ display_name }}',
content_format = '{{ content_format }}',
description = '{{ description }}',
documentation_link = '{{ documentation_link }}',
runtime_language = '{{ runtime_language }}',
versions = '{{ versions }}'
WHERE
cloud = '{{ cloud }}'
AND id = '{{ id }}'
AND region = '{{ region }}';

DELETE example

Deletes the specified flink_artifacts resource.

/*+ delete */
DELETE FROM confluent.flink_artifacts.flink_artifacts
WHERE cloud = '{{ cloud }}'
AND id = '{{ id }}'
AND region = '{{ region }}';