inputProcessingConfiguration

@JvmName(name = "ocygsqtatgtqgofh")
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.


@JvmName(name = "tegqhnmjawijsygn")
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.