input Processing Configuration
suspend fun inputProcessingConfiguration(value: Output<ApplicationInputProcessingConfigurationArgs>)
Parameters
value
The InputProcessingConfiguration 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 InputLambdaProcessor.
suspend fun inputProcessingConfiguration(argument: suspend ApplicationInputProcessingConfigurationArgsBuilder.() -> Unit)
Parameters
argument
The InputProcessingConfiguration 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 InputLambdaProcessor.