public class ValidateSchemaOperator extends Object
validateSchema("mySchema").on([logs][log]).into([logs][error]);
List<Tuple> errors = validateSchema("mySchema").on([logs][log]).validate();
List<Tuple> errors = validateSchema("mySchema1", "mySchema2").on([logs][log]).validate();
Constructor and Description |
---|
ValidateSchemaOperator(String... mappingNames)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
List<Tuple> |
into(Tuple result)
Stores validation results in provided tuple.
|
ValidateSchemaOperator |
on(Tuple tuple)
Make the operator check if the provided tuple is conform with your schema.
|
List<Tuple> |
validate()
Fire the operator and effectively check if your tuple conforms to your schema.
|
public ValidateSchemaOperator(String... mappingNames)
mappingNames
- : Mapping names. It must identify registered sets of mapping files.public ValidateSchemaOperator on(Tuple tuple)
tuple
- : Tuple to check.public List<Tuple> validate()
public List<Tuple> into(Tuple result)
result
- : Destination tupleCopyright © 2022. All rights reserved.