AWS Kinesis · Schema
Input
When you configure the application input for a SQL-based Kinesis Data Analytics application, you specify the streaming source, the in-application stream name that is created, and the mapping between the two.
AnalyticsApache FlinkBig DataData ProcessingReal-TimeStreamingVideo
Properties
| Name | Type | Description |
|---|---|---|
| NamePrefix | object | |
| InputProcessingConfiguration | object | |
| KinesisStreamsInput | object | |
| KinesisFirehoseInput | object | |
| InputParallelism | object | |
| InputSchema | object |
JSON Schema
{
"$schema": "https://json-schema.org/draft/2020-12/schema",
"$id": "#/components/schemas/Input",
"title": "Input",
"type": "object",
"required": [
"NamePrefix",
"InputSchema"
],
"properties": {
"NamePrefix": {
"allOf": [
{
"$ref": "#/components/schemas/InAppStreamName"
},
{
"description": "The name prefix to use when creating an in-application stream. Suppose that you specify a prefix \"<code>MyInApplicationStream</code>.\" Kinesis Data Analytics then creates one or more (as per the <code>InputParallelism</code> count you specified) in-application streams with the names \"<code>MyInApplicationStream_001</code>,\" \"<code>MyInApplicationStream_002</code>,\" and so on. "
}
]
},
"InputProcessingConfiguration": {
"allOf": [
{
"$ref": "#/components/schemas/InputProcessingConfiguration"
},
{
"description": "The <a>InputProcessingConfiguration</a> for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes. Currently, the only input processing configuration available is <a>InputLambdaProcessor</a>. "
}
]
},
"KinesisStreamsInput": {
"allOf": [
{
"$ref": "#/components/schemas/KinesisStreamsInput"
},
{
"description": "If the streaming source is an Amazon Kinesis data stream, identifies the stream's Amazon Resource Name (ARN). "
}
]
},
"KinesisFirehoseInput": {
"allOf": [
{
"$ref": "#/components/schemas/KinesisFirehoseInput"
},
{
"description": "If the streaming source is an Amazon Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN."
}
]
},
"InputParallelism": {
"allOf": [
{
"$ref": "#/components/schemas/InputParallelism"
},
{
"description": "Describes the number of in-application streams to create. "
}
]
},
"InputSchema": {
"allOf": [
{
"$ref": "#/components/schemas/SourceSchema"
},
{
"description": "<p>Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.</p> <p>Also used to describe the format of the reference data source.</p>"
}
]
}
},
"description": "When you configure the application input for a SQL-based Kinesis Data Analytics application, you specify the streaming source, the in-application stream name that is created, and the mapping between the two. "
}
Work with this as data
Every JSON Schema here is available over the APIs.io API and to AI agents over MCP.
MCP server
One button, every client — Claude, Cursor, VS Code and the rest.
https://apis.io/mcp
Tools for schemas
4 MCP tools reach this
find_json_schemasBrowse and filter every JSON Schema in the catalog.apis_io_searchSTART HERE — APIs, providers and tags for one query, each with its total.resolveTurn a domain, URL or GitHub org into the provider it belongs to.find_cohortsEvery scored population of providers in the catalog.
Call it yourself
curl for this page
This JSON Schema
curl "https://apis.io/api/v1/json-schemas/kinesis-input"
All schemas
curl "https://apis.io/api/v1/json-schemas?limit=25"
Discovery needs no key. Ratings and market analysis are Pro.
Get an API key
Free tier, no form to fill in. Signing in shares your email address with us — we store it to create your key and to recognise you if you sign in with another provider. See our Privacy Policy and Terms.
A second provider on the same verified email joins the account you already have.