aiven.FlinkJarApplicationVersion
Explore with Pulumi AI
Creates and manages an Aiven for Apache Flink® jar application version.
This resource is in the beta stage and may change without notice. Set
the PROVIDER_AIVEN_ENABLE_BETA
environment variable to use the resource.
Example Usage
import * as pulumi from "@pulumi/pulumi";
import * as aiven from "@pulumi/aiven";
const example = new aiven.Flink("example", {
project: exampleAivenProject.project,
serviceName: "example-flink-service",
cloudName: "google-europe-west1",
plan: "business-4",
maintenanceWindowDow: "monday",
maintenanceWindowTime: "04:00:00",
flinkUserConfig: {
customCode: true,
},
});
const exampleFlinkJarApplication = new aiven.FlinkJarApplication("example", {
project: example.project,
serviceName: example.serviceName,
name: "example-app-jar",
});
const exampleFlinkJarApplicationVersion = new aiven.FlinkJarApplicationVersion("example", {
project: example.project,
serviceName: example.serviceName,
applicationId: exampleFlinkJarApplication.applicationId,
source: "./example.jar",
});
import pulumi
import pulumi_aiven as aiven
example = aiven.Flink("example",
project=example_aiven_project["project"],
service_name="example-flink-service",
cloud_name="google-europe-west1",
plan="business-4",
maintenance_window_dow="monday",
maintenance_window_time="04:00:00",
flink_user_config={
"custom_code": True,
})
example_flink_jar_application = aiven.FlinkJarApplication("example",
project=example.project,
service_name=example.service_name,
name="example-app-jar")
example_flink_jar_application_version = aiven.FlinkJarApplicationVersion("example",
project=example.project,
service_name=example.service_name,
application_id=example_flink_jar_application.application_id,
source="./example.jar")
package main
import (
"github.com/pulumi/pulumi-aiven/sdk/v6/go/aiven"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
example, err := aiven.NewFlink(ctx, "example", &aiven.FlinkArgs{
Project: pulumi.Any(exampleAivenProject.Project),
ServiceName: pulumi.String("example-flink-service"),
CloudName: pulumi.String("google-europe-west1"),
Plan: pulumi.String("business-4"),
MaintenanceWindowDow: pulumi.String("monday"),
MaintenanceWindowTime: pulumi.String("04:00:00"),
FlinkUserConfig: &aiven.FlinkFlinkUserConfigArgs{
CustomCode: pulumi.Bool(true),
},
})
if err != nil {
return err
}
exampleFlinkJarApplication, err := aiven.NewFlinkJarApplication(ctx, "example", &aiven.FlinkJarApplicationArgs{
Project: example.Project,
ServiceName: example.ServiceName,
Name: pulumi.String("example-app-jar"),
})
if err != nil {
return err
}
_, err = aiven.NewFlinkJarApplicationVersion(ctx, "example", &aiven.FlinkJarApplicationVersionArgs{
Project: example.Project,
ServiceName: example.ServiceName,
ApplicationId: exampleFlinkJarApplication.ApplicationId,
Source: pulumi.String("./example.jar"),
})
if err != nil {
return err
}
return nil
})
}
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aiven = Pulumi.Aiven;
return await Deployment.RunAsync(() =>
{
var example = new Aiven.Flink("example", new()
{
Project = exampleAivenProject.Project,
ServiceName = "example-flink-service",
CloudName = "google-europe-west1",
Plan = "business-4",
MaintenanceWindowDow = "monday",
MaintenanceWindowTime = "04:00:00",
FlinkUserConfig = new Aiven.Inputs.FlinkFlinkUserConfigArgs
{
CustomCode = true,
},
});
var exampleFlinkJarApplication = new Aiven.FlinkJarApplication("example", new()
{
Project = example.Project,
ServiceName = example.ServiceName,
Name = "example-app-jar",
});
var exampleFlinkJarApplicationVersion = new Aiven.FlinkJarApplicationVersion("example", new()
{
Project = example.Project,
ServiceName = example.ServiceName,
ApplicationId = exampleFlinkJarApplication.ApplicationId,
Source = "./example.jar",
});
});
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aiven.Flink;
import com.pulumi.aiven.FlinkArgs;
import com.pulumi.aiven.inputs.FlinkFlinkUserConfigArgs;
import com.pulumi.aiven.FlinkJarApplication;
import com.pulumi.aiven.FlinkJarApplicationArgs;
import com.pulumi.aiven.FlinkJarApplicationVersion;
import com.pulumi.aiven.FlinkJarApplicationVersionArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var example = new Flink("example", FlinkArgs.builder()
.project(exampleAivenProject.project())
.serviceName("example-flink-service")
.cloudName("google-europe-west1")
.plan("business-4")
.maintenanceWindowDow("monday")
.maintenanceWindowTime("04:00:00")
.flinkUserConfig(FlinkFlinkUserConfigArgs.builder()
.customCode(true)
.build())
.build());
var exampleFlinkJarApplication = new FlinkJarApplication("exampleFlinkJarApplication", FlinkJarApplicationArgs.builder()
.project(example.project())
.serviceName(example.serviceName())
.name("example-app-jar")
.build());
var exampleFlinkJarApplicationVersion = new FlinkJarApplicationVersion("exampleFlinkJarApplicationVersion", FlinkJarApplicationVersionArgs.builder()
.project(example.project())
.serviceName(example.serviceName())
.applicationId(exampleFlinkJarApplication.applicationId())
.source("./example.jar")
.build());
}
}
resources:
example:
type: aiven:Flink
properties:
project: ${exampleAivenProject.project}
serviceName: example-flink-service
cloudName: google-europe-west1
plan: business-4
maintenanceWindowDow: monday
maintenanceWindowTime: 04:00:00
flinkUserConfig:
customCode: true
exampleFlinkJarApplication:
type: aiven:FlinkJarApplication
name: example
properties:
project: ${example.project}
serviceName: ${example.serviceName}
name: example-app-jar
exampleFlinkJarApplicationVersion:
type: aiven:FlinkJarApplicationVersion
name: example
properties:
project: ${example.project}
serviceName: ${example.serviceName}
applicationId: ${exampleFlinkJarApplication.applicationId}
source: ./example.jar
Create FlinkJarApplicationVersion Resource
Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.
Constructor syntax
new FlinkJarApplicationVersion(name: string, args: FlinkJarApplicationVersionArgs, opts?: CustomResourceOptions);
@overload
def FlinkJarApplicationVersion(resource_name: str,
args: FlinkJarApplicationVersionArgs,
opts: Optional[ResourceOptions] = None)
@overload
def FlinkJarApplicationVersion(resource_name: str,
opts: Optional[ResourceOptions] = None,
application_id: Optional[str] = None,
project: Optional[str] = None,
service_name: Optional[str] = None,
source: Optional[str] = None)
func NewFlinkJarApplicationVersion(ctx *Context, name string, args FlinkJarApplicationVersionArgs, opts ...ResourceOption) (*FlinkJarApplicationVersion, error)
public FlinkJarApplicationVersion(string name, FlinkJarApplicationVersionArgs args, CustomResourceOptions? opts = null)
public FlinkJarApplicationVersion(String name, FlinkJarApplicationVersionArgs args)
public FlinkJarApplicationVersion(String name, FlinkJarApplicationVersionArgs args, CustomResourceOptions options)
type: aiven:FlinkJarApplicationVersion
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.
Parameters
- name string
- The unique name of the resource.
- args FlinkJarApplicationVersionArgs
- The arguments to resource properties.
- opts CustomResourceOptions
- Bag of options to control resource's behavior.
- resource_name str
- The unique name of the resource.
- args FlinkJarApplicationVersionArgs
- The arguments to resource properties.
- opts ResourceOptions
- Bag of options to control resource's behavior.
- ctx Context
- Context object for the current deployment.
- name string
- The unique name of the resource.
- args FlinkJarApplicationVersionArgs
- The arguments to resource properties.
- opts ResourceOption
- Bag of options to control resource's behavior.
- name string
- The unique name of the resource.
- args FlinkJarApplicationVersionArgs
- The arguments to resource properties.
- opts CustomResourceOptions
- Bag of options to control resource's behavior.
- name String
- The unique name of the resource.
- args FlinkJarApplicationVersionArgs
- The arguments to resource properties.
- options CustomResourceOptions
- Bag of options to control resource's behavior.
Constructor example
The following reference example uses placeholder values for all input properties.
var flinkJarApplicationVersionResource = new Aiven.FlinkJarApplicationVersion("flinkJarApplicationVersionResource", new()
{
ApplicationId = "string",
Project = "string",
ServiceName = "string",
Source = "string",
});
example, err := aiven.NewFlinkJarApplicationVersion(ctx, "flinkJarApplicationVersionResource", &aiven.FlinkJarApplicationVersionArgs{
ApplicationId: pulumi.String("string"),
Project: pulumi.String("string"),
ServiceName: pulumi.String("string"),
Source: pulumi.String("string"),
})
var flinkJarApplicationVersionResource = new FlinkJarApplicationVersion("flinkJarApplicationVersionResource", FlinkJarApplicationVersionArgs.builder()
.applicationId("string")
.project("string")
.serviceName("string")
.source("string")
.build());
flink_jar_application_version_resource = aiven.FlinkJarApplicationVersion("flinkJarApplicationVersionResource",
application_id="string",
project="string",
service_name="string",
source="string")
const flinkJarApplicationVersionResource = new aiven.FlinkJarApplicationVersion("flinkJarApplicationVersionResource", {
applicationId: "string",
project: "string",
serviceName: "string",
source: "string",
});
type: aiven:FlinkJarApplicationVersion
properties:
applicationId: string
project: string
serviceName: string
source: string
FlinkJarApplicationVersion Resource Properties
To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.
Inputs
In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.
The FlinkJarApplicationVersion resource accepts the following input properties:
- Application
Id string - Application Id. Changing this property forces recreation of the resource.
- Project string
- Project name. Changing this property forces recreation of the resource.
- Service
Name string - Service name. Changing this property forces recreation of the resource.
- Source string
- The path to the jar file to upload.
- Application
Id string - Application Id. Changing this property forces recreation of the resource.
- Project string
- Project name. Changing this property forces recreation of the resource.
- Service
Name string - Service name. Changing this property forces recreation of the resource.
- Source string
- The path to the jar file to upload.
- application
Id String - Application Id. Changing this property forces recreation of the resource.
- project String
- Project name. Changing this property forces recreation of the resource.
- service
Name String - Service name. Changing this property forces recreation of the resource.
- source String
- The path to the jar file to upload.
- application
Id string - Application Id. Changing this property forces recreation of the resource.
- project string
- Project name. Changing this property forces recreation of the resource.
- service
Name string - Service name. Changing this property forces recreation of the resource.
- source string
- The path to the jar file to upload.
- application_
id str - Application Id. Changing this property forces recreation of the resource.
- project str
- Project name. Changing this property forces recreation of the resource.
- service_
name str - Service name. Changing this property forces recreation of the resource.
- source str
- The path to the jar file to upload.
- application
Id String - Application Id. Changing this property forces recreation of the resource.
- project String
- Project name. Changing this property forces recreation of the resource.
- service
Name String - Service name. Changing this property forces recreation of the resource.
- source String
- The path to the jar file to upload.
Outputs
All input properties are implicitly available as output properties. Additionally, the FlinkJarApplicationVersion resource produces the following output properties:
- Application
Version stringId - ApplicationVersion ID.
- Created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- Created
By string - The creator of this entity.
- File
Infos List<FlinkJar Application Version File Info> - Flink JarApplicationVersion FileInfo.
- Id string
- The provider-assigned unique ID for this managed resource.
- Source
Checksum string - The sha256 checksum of the jar file to upload.
- Version int
- Version number.
- Application
Version stringId - ApplicationVersion ID.
- Created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- Created
By string - The creator of this entity.
- File
Infos []FlinkJar Application Version File Info - Flink JarApplicationVersion FileInfo.
- Id string
- The provider-assigned unique ID for this managed resource.
- Source
Checksum string - The sha256 checksum of the jar file to upload.
- Version int
- Version number.
- application
Version StringId - ApplicationVersion ID.
- created
At String - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By String - The creator of this entity.
- file
Infos List<FlinkJar Application Version File Info> - Flink JarApplicationVersion FileInfo.
- id String
- The provider-assigned unique ID for this managed resource.
- source
Checksum String - The sha256 checksum of the jar file to upload.
- version Integer
- Version number.
- application
Version stringId - ApplicationVersion ID.
- created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By string - The creator of this entity.
- file
Infos FlinkJar Application Version File Info[] - Flink JarApplicationVersion FileInfo.
- id string
- The provider-assigned unique ID for this managed resource.
- source
Checksum string - The sha256 checksum of the jar file to upload.
- version number
- Version number.
- application_
version_ strid - ApplicationVersion ID.
- created_
at str - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created_
by str - The creator of this entity.
- file_
infos Sequence[FlinkJar Application Version File Info] - Flink JarApplicationVersion FileInfo.
- id str
- The provider-assigned unique ID for this managed resource.
- source_
checksum str - The sha256 checksum of the jar file to upload.
- version int
- Version number.
- application
Version StringId - ApplicationVersion ID.
- created
At String - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By String - The creator of this entity.
- file
Infos List<Property Map> - Flink JarApplicationVersion FileInfo.
- id String
- The provider-assigned unique ID for this managed resource.
- source
Checksum String - The sha256 checksum of the jar file to upload.
- version Number
- Version number.
Look up Existing FlinkJarApplicationVersion Resource
Get an existing FlinkJarApplicationVersion resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.
public static get(name: string, id: Input<ID>, state?: FlinkJarApplicationVersionState, opts?: CustomResourceOptions): FlinkJarApplicationVersion
@staticmethod
def get(resource_name: str,
id: str,
opts: Optional[ResourceOptions] = None,
application_id: Optional[str] = None,
application_version_id: Optional[str] = None,
created_at: Optional[str] = None,
created_by: Optional[str] = None,
file_infos: Optional[Sequence[FlinkJarApplicationVersionFileInfoArgs]] = None,
project: Optional[str] = None,
service_name: Optional[str] = None,
source: Optional[str] = None,
source_checksum: Optional[str] = None,
version: Optional[int] = None) -> FlinkJarApplicationVersion
func GetFlinkJarApplicationVersion(ctx *Context, name string, id IDInput, state *FlinkJarApplicationVersionState, opts ...ResourceOption) (*FlinkJarApplicationVersion, error)
public static FlinkJarApplicationVersion Get(string name, Input<string> id, FlinkJarApplicationVersionState? state, CustomResourceOptions? opts = null)
public static FlinkJarApplicationVersion get(String name, Output<String> id, FlinkJarApplicationVersionState state, CustomResourceOptions options)
resources: _: type: aiven:FlinkJarApplicationVersion get: id: ${id}
- name
- The unique name of the resulting resource.
- id
- The unique provider ID of the resource to lookup.
- state
- Any extra arguments used during the lookup.
- opts
- A bag of options that control this resource's behavior.
- resource_name
- The unique name of the resulting resource.
- id
- The unique provider ID of the resource to lookup.
- name
- The unique name of the resulting resource.
- id
- The unique provider ID of the resource to lookup.
- state
- Any extra arguments used during the lookup.
- opts
- A bag of options that control this resource's behavior.
- name
- The unique name of the resulting resource.
- id
- The unique provider ID of the resource to lookup.
- state
- Any extra arguments used during the lookup.
- opts
- A bag of options that control this resource's behavior.
- name
- The unique name of the resulting resource.
- id
- The unique provider ID of the resource to lookup.
- state
- Any extra arguments used during the lookup.
- opts
- A bag of options that control this resource's behavior.
- Application
Id string - Application Id. Changing this property forces recreation of the resource.
- Application
Version stringId - ApplicationVersion ID.
- Created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- Created
By string - The creator of this entity.
- File
Infos List<FlinkJar Application Version File Info> - Flink JarApplicationVersion FileInfo.
- Project string
- Project name. Changing this property forces recreation of the resource.
- Service
Name string - Service name. Changing this property forces recreation of the resource.
- Source string
- The path to the jar file to upload.
- Source
Checksum string - The sha256 checksum of the jar file to upload.
- Version int
- Version number.
- Application
Id string - Application Id. Changing this property forces recreation of the resource.
- Application
Version stringId - ApplicationVersion ID.
- Created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- Created
By string - The creator of this entity.
- File
Infos []FlinkJar Application Version File Info Args - Flink JarApplicationVersion FileInfo.
- Project string
- Project name. Changing this property forces recreation of the resource.
- Service
Name string - Service name. Changing this property forces recreation of the resource.
- Source string
- The path to the jar file to upload.
- Source
Checksum string - The sha256 checksum of the jar file to upload.
- Version int
- Version number.
- application
Id String - Application Id. Changing this property forces recreation of the resource.
- application
Version StringId - ApplicationVersion ID.
- created
At String - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By String - The creator of this entity.
- file
Infos List<FlinkJar Application Version File Info> - Flink JarApplicationVersion FileInfo.
- project String
- Project name. Changing this property forces recreation of the resource.
- service
Name String - Service name. Changing this property forces recreation of the resource.
- source String
- The path to the jar file to upload.
- source
Checksum String - The sha256 checksum of the jar file to upload.
- version Integer
- Version number.
- application
Id string - Application Id. Changing this property forces recreation of the resource.
- application
Version stringId - ApplicationVersion ID.
- created
At string - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By string - The creator of this entity.
- file
Infos FlinkJar Application Version File Info[] - Flink JarApplicationVersion FileInfo.
- project string
- Project name. Changing this property forces recreation of the resource.
- service
Name string - Service name. Changing this property forces recreation of the resource.
- source string
- The path to the jar file to upload.
- source
Checksum string - The sha256 checksum of the jar file to upload.
- version number
- Version number.
- application_
id str - Application Id. Changing this property forces recreation of the resource.
- application_
version_ strid - ApplicationVersion ID.
- created_
at str - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created_
by str - The creator of this entity.
- file_
infos Sequence[FlinkJar Application Version File Info Args] - Flink JarApplicationVersion FileInfo.
- project str
- Project name. Changing this property forces recreation of the resource.
- service_
name str - Service name. Changing this property forces recreation of the resource.
- source str
- The path to the jar file to upload.
- source_
checksum str - The sha256 checksum of the jar file to upload.
- version int
- Version number.
- application
Id String - Application Id. Changing this property forces recreation of the resource.
- application
Version StringId - ApplicationVersion ID.
- created
At String - The creation timestamp of this entity in ISO 8601 format, always in UTC.
- created
By String - The creator of this entity.
- file
Infos List<Property Map> - Flink JarApplicationVersion FileInfo.
- project String
- Project name. Changing this property forces recreation of the resource.
- service
Name String - Service name. Changing this property forces recreation of the resource.
- source String
- The path to the jar file to upload.
- source
Checksum String - The sha256 checksum of the jar file to upload.
- version Number
- Version number.
Supporting Types
FlinkJarApplicationVersionFileInfo, FlinkJarApplicationVersionFileInfoArgs
- File
Sha256 string - sha256 of the file if known.
- File
Size int - The size of the file in bytes.
- File
Status string - Indicates whether the uploaded .jar file has been verified by the system and deployment ready. The possible values are
FAILED
,INITIAL
andREADY
. - Url string
- The pre-signed url of the bucket where the .jar file is uploaded. Becomes null when the JarApplicationVersion is ready or failed.
- Verify
Error intCode - In the case file_status is FAILED, the error code of the failure. The possible values are
1
,2
and3
. - Verify
Error stringMessage - In the case file_status is FAILED, may contain details about the failure.
- File
Sha256 string - sha256 of the file if known.
- File
Size int - The size of the file in bytes.
- File
Status string - Indicates whether the uploaded .jar file has been verified by the system and deployment ready. The possible values are
FAILED
,INITIAL
andREADY
. - Url string
- The pre-signed url of the bucket where the .jar file is uploaded. Becomes null when the JarApplicationVersion is ready or failed.
- Verify
Error intCode - In the case file_status is FAILED, the error code of the failure. The possible values are
1
,2
and3
. - Verify
Error stringMessage - In the case file_status is FAILED, may contain details about the failure.
- file
Sha256 String - sha256 of the file if known.
- file
Size Integer - The size of the file in bytes.
- file
Status String - Indicates whether the uploaded .jar file has been verified by the system and deployment ready. The possible values are
FAILED
,INITIAL
andREADY
. - url String
- The pre-signed url of the bucket where the .jar file is uploaded. Becomes null when the JarApplicationVersion is ready or failed.
- verify
Error IntegerCode - In the case file_status is FAILED, the error code of the failure. The possible values are
1
,2
and3
. - verify
Error StringMessage - In the case file_status is FAILED, may contain details about the failure.
- file
Sha256 string - sha256 of the file if known.
- file
Size number - The size of the file in bytes.
- file
Status string - Indicates whether the uploaded .jar file has been verified by the system and deployment ready. The possible values are
FAILED
,INITIAL
andREADY
. - url string
- The pre-signed url of the bucket where the .jar file is uploaded. Becomes null when the JarApplicationVersion is ready or failed.
- verify
Error numberCode - In the case file_status is FAILED, the error code of the failure. The possible values are
1
,2
and3
. - verify
Error stringMessage - In the case file_status is FAILED, may contain details about the failure.
- file_
sha256 str - sha256 of the file if known.
- file_
size int - The size of the file in bytes.
- file_
status str - Indicates whether the uploaded .jar file has been verified by the system and deployment ready. The possible values are
FAILED
,INITIAL
andREADY
. - url str
- The pre-signed url of the bucket where the .jar file is uploaded. Becomes null when the JarApplicationVersion is ready or failed.
- verify_
error_ intcode - In the case file_status is FAILED, the error code of the failure. The possible values are
1
,2
and3
. - verify_
error_ strmessage - In the case file_status is FAILED, may contain details about the failure.
- file
Sha256 String - sha256 of the file if known.
- file
Size Number - The size of the file in bytes.
- file
Status String - Indicates whether the uploaded .jar file has been verified by the system and deployment ready. The possible values are
FAILED
,INITIAL
andREADY
. - url String
- The pre-signed url of the bucket where the .jar file is uploaded. Becomes null when the JarApplicationVersion is ready or failed.
- verify
Error NumberCode - In the case file_status is FAILED, the error code of the failure. The possible values are
1
,2
and3
. - verify
Error StringMessage - In the case file_status is FAILED, may contain details about the failure.
Import
$ pulumi import aiven:index/flinkJarApplicationVersion:FlinkJarApplicationVersion example PROJECT/SERVICE_NAME/APPLICATION_ID/APPLICATION_VERSION_ID
To learn more about importing existing cloud resources, see Importing resources.
Package Details
- Repository
- Aiven pulumi/pulumi-aiven
- License
- Apache-2.0
- Notes
- This Pulumi package is based on the
aiven
Terraform Provider.