Amazon Kinesis Data Analytics is a fully managed service that you can use to process and analyze streaming data using Java, SQL, or Scala. The service enables you to quickly author and run Java, SQL, or Scala code against streaming sources to perform time series analytics, feed real-time dashboards, and create real-time metrics.
kinesisanalyticsv2(config = list())
A client for the service. You can call the service's operations using
syntax like svc$operation(...)
, where svc
is the name you've assigned
to the client. The available operations are listed in the
Operations section.
Optional configuration of credentials, endpoint, and/or region.
svc <- kinesisanalyticsv2(
config = list(
credentials = list(
creds = list(
access_key_id = "string",
secret_access_key = "string",
session_token = "string"
),
profile = "string"
),
endpoint = "string",
region = "string"
)
)
add_application_cloud_watch_logging_option | Adds an Amazon CloudWatch log stream to monitor application configuration errors |
add_application_input | Adds a streaming source to your SQL-based Kinesis Data Analytics application |
add_application_input_processing_configuration | Adds an InputProcessingConfiguration to a SQL-based Kinesis Data Analytics application |
add_application_output | Adds an external destination to your SQL-based Kinesis Data Analytics application |
add_application_reference_data_source | Adds a reference data source to an existing SQL-based Kinesis Data Analytics application |
add_application_vpc_configuration | Adds a Virtual Private Cloud (VPC) configuration to the application |
create_application | Creates a Kinesis Data Analytics application |
create_application_presigned_url | Creates and returns a URL that you can use to connect to an application's extension |
create_application_snapshot | Creates a snapshot of the application's state data |
delete_application | Deletes the specified application |
delete_application_cloud_watch_logging_option | Deletes an Amazon CloudWatch log stream from an Kinesis Data Analytics application |
delete_application_input_processing_configuration | Deletes an InputProcessingConfiguration from an input |
delete_application_output | Deletes the output destination configuration from your SQL-based Kinesis Data Analytics application's configuration |
delete_application_reference_data_source | Deletes a reference data source configuration from the specified SQL-based Kinesis Data Analytics application's configuration |
delete_application_snapshot | Deletes a snapshot of application state |
delete_application_vpc_configuration | Removes a VPC configuration from a Kinesis Data Analytics application |
describe_application | Returns information about a specific Kinesis Data Analytics application |
describe_application_snapshot | Returns information about a snapshot of application state data |
discover_input_schema | Infers a schema for a SQL-based Kinesis Data Analytics application by evaluating sample records on the specified streaming source (Kinesis data stream or Kinesis Data Firehose delivery stream) or Amazon S3 object |
list_applications | Returns a list of Kinesis Data Analytics applications in your account |
list_application_snapshots | Lists information about the current application snapshots |
list_tags_for_resource | Retrieves the list of key-value tags assigned to the application |
start_application | Starts the specified Kinesis Data Analytics application |
stop_application | Stops the application from processing data |
tag_resource | Adds one or more key-value tags to a Kinesis Data Analytics application |
untag_resource | Removes one or more tags from a Kinesis Data Analytics application |
update_application | Updates an existing Kinesis Data Analytics application |
if (FALSE) {
svc <- kinesisanalyticsv2()
svc$add_application_cloud_watch_logging_option(
Foo = 123
)
}
Run the code above in your browser using DataLab