DataflowBuiltInTransformationSettingsArgs

data class DataflowBuiltInTransformationSettingsArgs(val datasets: Output<List<DataflowBuiltInTransformationDatasetArgs>>? = null, val filter: Output<List<DataflowBuiltInTransformationFilterArgs>>? = null, val map: Output<List<DataflowBuiltInTransformationMapArgs>>? = null, val schemaRef: Output<String>? = null, val serializationFormat: Output<Either<String, TransformationSerializationFormat>>? = null) : ConvertibleToJava<DataflowBuiltInTransformationSettingsArgs>

Dataflow BuiltIn Transformation properties

Constructors

constructor(datasets: Output<List<DataflowBuiltInTransformationDatasetArgs>>? = null, filter: Output<List<DataflowBuiltInTransformationFilterArgs>>? = null, map: Output<List<DataflowBuiltInTransformationMapArgs>>? = null, schemaRef: Output<String>? = null, serializationFormat: Output<Either<String, TransformationSerializationFormat>>? = null)

Properties

Link copied to clipboard

Enrich data from Broker State Store. Dataset references a key in Broker State Store.

Link copied to clipboard

Filters input record or datapoints based on condition.

Link copied to clipboard

Maps input to output message.

Link copied to clipboard
val schemaRef: Output<String>? = null

Reference to the schema that describes the output of the transformation.

Link copied to clipboard

Serialization format. Optional; defaults to JSON. Allowed value JSON Schema/draft-7, Parquet. Default: Json

Functions

Link copied to clipboard
open override fun toJava(): DataflowBuiltInTransformationSettingsArgs