Input - Amazon Managed Service per Apache Flink (precedentemente Amazon Kinesis Data Analytics per Apache Flink)

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Input

Quando si configura l'input di applicazione per un'applicazione Kinesis Data Analytics basata su SQL, è necessario specificare l'origine di streaming, il nome del flusso nell'applicazione che viene creata e la mappatura tra i due.

Indice

InputSchema

Descrive il formato dei dati nell'origine di streaming e come ciascun elemento dati viene mappato alle colonne corrispondenti del flusso nell'applicazione che viene creato.

Inoltre utilizzato per descrivere il formato dell'origine dati di riferimento.

Tipo: oggetto SourceSchema

Campo obbligatorio: sì

NamePrefix

Il prefisso del nome da utilizzare quando si crea un flusso nell'applicazione. Supponi di specificare il prefisso "MyInApplicationStream". Kinesis Data Analytics crea uno o più (in base al conteggio InputParallelism specificato) flussi nell'applicazione con nomi "MyInApplicationStream_001", "MyInApplicationStream_002" e così via.

▬Tipo: stringa

Limitazioni di lunghezza: lunghezza minima pari a 1. La lunghezza massima è 32 caratteri.

Modello: [^-\s<>&]*

Campo obbligatorio: sì

InputParallelism

Descrive il numero di flussi nell'applicazione da creare.

Tipo: oggetto InputParallelism

Campo obbligatorio: no

InputProcessingConfiguration

Il InputProcessingConfiguration per l'input. Un processore di input trasforma i record ricevuti dal flusso prima dell'esecuzione del codice SQL dell'applicazione. Al momento l'unica configurazione di elaborazione di input disponibile è InputLambdaProcessor.

Tipo: oggetto InputProcessingConfiguration

Campo obbligatorio: no

KinesisFirehoseInput

Se l'origine di streaming è un flusso di distribuzione di Amazon Kinesis Data Firehose, identifica l'ARN del flusso di consegna.

Tipo: oggetto KinesisFirehoseInput

Campo obbligatorio: no

KinesisStreamsInput

Se l'origine di streaming è un flusso di dati di Amazon Kinesis, identifica l'Amazon Resource Name (ARN) del flusso.

Tipo: oggetto KinesisStreamsInput

Campo obbligatorio: no

Vedi anche

Per ulteriori informazioni sull'utilizzo di questa API in uno degli AWS SDK specifici della lingua, consulta quanto segue: