@aws-cdk/aws-kinesisanalytics-flink-alpha.ApplicationCode

Experimental

@aws-cdk/aws-kinesisanalytics-flink-alpha is an experimental (alpha) package: its API may change in any release, without a major version bump.

ApplicationCode Class

Code configuration providing the location to a Flink application JAR file.

Stability

Experimental

Source

lib/application-code.ts

Example

declare const bucket: s3.Bucket;
const flinkApp = new flink.Application(this, 'Application', {
  propertyGroups: {
    FlinkApplicationProperties: {
      inputStreamName: 'my-input-kinesis-stream',
      outputStreamName: 'my-output-kinesis-stream',
    },
  },
  // ...
  runtime: flink.Runtime.FLINK_2_2,
  code: flink.ApplicationCode.fromBucket(bucket, 'my-app.jar'),
});

Initializer

new ApplicationCode()

ApplicationCode()

new ApplicationCode()

new ApplicationCode()

NewApplicationCode()

Methods

bind(scope: Construct): ApplicationCodeConfigdef bind(self, scope: Construct) -> ApplicationCodeConfigpublic ApplicationCodeConfig bind(Construct scope)public ApplicationCodeConfig Bind(Construct scope)func Bind(Scope Construct) ApplicationCodeConfig#

A method to lazily bind asset resources to the parent FlinkApplication.

fromAsset(path: string, options?: AssetOptions): ApplicationCode // chainable@staticmethod def from_asset(path: str, options: typing.Optional[AssetOptions] = None) -> ApplicationCodepublic static ApplicationCode fromAsset(String path, AssetOptions options)public static ApplicationCode FromAsset(string path, AssetOptions? options = null)func FromAsset(Path *string, Options AssetOptions) ApplicationCodestatic#

Reference code from a local directory containing a Flink JAR file.

1 parameter

Parameters

• pathpathpathpathPath — - a local directory path.

fromBucket(bucket: IBucket, fileKey: string, objectVersion?: string): ApplicationCode // chainable@staticmethod def from_bucket(bucket: IBucket, file_key: str, object_version: typing.Optional[str] = None) -> ApplicationCodepublic static ApplicationCode fromBucket(IBucket bucket, String fileKey, String objectVersion)public static ApplicationCode FromBucket(IBucket bucket, string fileKey, string? objectVersion = null)func FromBucket(Bucket IBucket, FileKey *string, ObjectVersion *string) ApplicationCodestatic#

Reference code from an S3 bucket.

3 parameters

Parameters

• bucketbucketbucketbucketBucket — - an s3 bucket.
• fileKeyfile_keyfileKeyfileKeyFileKey — - a key pointing to a Flink JAR file.
• objectVersionobject_versionobjectVersionobjectVersionObjectVersion — - an optional version string for the provided fileKey.