本文整理了Java中org.apache.kafka.connect.data.Struct.validate()
方法的一些代码示例,展示了Struct.validate()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Struct.validate()
方法的具体详情如下:
包路径:org.apache.kafka.connect.data.Struct
类名称:Struct
方法名:validate
[英]Validates that this struct has filled in all the necessary data with valid values. For required fields without defaults, this validates that a value has been set and has matching types/schemas. If any validation fails, throws a DataException.
[中]验证此结构是否已使用有效值填充所有必需的数据。对于没有默认值的必填字段,这将验证是否已设置值,以及是否具有匹配的类型/架构。如果任何验证失败,将抛出DataException。
代码示例来源:origin: confluentinc/ksql
@Override
public void serialize(
final Struct struct,
final JsonGenerator jsonGenerator,
final SerializerProvider serializerProvider
) throws IOException {
struct.validate();
jsonGenerator.writeObject(
objectMapper.readTree(jsonConverter.fromConnectData("", struct.schema(), struct)));
}
}
代码示例来源:origin: debezium/debezium
/**
* Assert that the supplied {@link Struct} is {@link Struct#validate() valid} and its {@link Struct#schema() schema}
* matches that of the supplied {@code schema}.
*
* @param struct the {@link Struct} to validate; may not be null
* @param schema the expected schema of the {@link Struct}; may not be null
*/
public static void schemaMatchesStruct(Struct struct, Schema schema) {
// First validate the struct itself ...
try {
struct.validate();
}
catch (DataException e) {
throw new AssertionError("The struct '" + struct + "' failed to validate", e);
}
Schema actualSchema = struct.schema();
assertThat(actualSchema).isEqualTo(schema);
fieldsInSchema(struct, schema);
}
代码示例来源:origin: com.github.jcustenborder.kafka.connect/connect-utils
public Struct build() {
log.trace("build() - Creating struct for {}", this.schema);
Struct struct = new Struct(this.schema);
for (KeyValue keyValue : this.fieldValues) {
log.trace("build() - Setting field value for '{}'", keyValue.name);
struct.put(keyValue.name, keyValue.value());
}
struct.validate();
return struct;
}
}
代码示例来源:origin: jcustenborder/kafka-connect-spooldir
public Pair<Struct, Struct> convert(LogEntry entry) {
final Struct key = null != this.keySchema ? new Struct(this.keySchema) : null;
final Struct value = new Struct(this.valueSchema);
if (null != key) {
for (LogFieldConverter converter : this.keyConverters) {
converter.convert(entry, key);
}
}
for (LogFieldConverter converter : this.valueConverters) {
converter.convert(entry, value);
}
if (null != key) {
key.validate();
}
value.validate();
return new ImmutablePair<>(key, value);
}
}
代码示例来源:origin: com.github.jcustenborder.kafka.connect/kafka-connect-cdc-test
public static Struct struct(JsonStruct storage) {
Struct struct = new Struct(storage.schema);
for (FieldValue fieldValue : storage.fieldValues) {
struct.put(fieldValue.name, fieldValue.value());
}
struct.validate();
return struct;
}
代码示例来源:origin: com.github.jcustenborder.kafka.connect/connect-utils
@Override
public void serialize(Struct struct, JsonGenerator jsonGenerator, SerializerProvider serializerProvider) throws IOException, JsonProcessingException {
struct.validate();
Storage result = new Storage();
result.schema = struct.schema();
result.fieldValues = new ArrayList<>();
for (Field field : struct.schema().fields()) {
log.trace("serialize() - Processing field '{}'", field.name());
KeyValue keyValue = new KeyValue();
keyValue.name = field.name();
keyValue.schema = field.schema();
keyValue.value(struct.get(field));
result.fieldValues.add(keyValue);
}
jsonGenerator.writeObject(result);
}
}
代码示例来源:origin: com.github.jcustenborder.kafka.connect/kafka-connect-cdc-test
@Override
public void serialize(Struct struct, JsonGenerator jsonGenerator, SerializerProvider serializerProvider) throws IOException, JsonProcessingException {
struct.validate();
JsonStruct result = new JsonStruct();
result.schema = struct.schema();
result.fieldValues = new ArrayList<>();
for (Field field : struct.schema().fields()) {
FieldValue fieldValue = new FieldValue();
fieldValue.name = field.name();
fieldValue.schema = field.schema();
fieldValue.value(struct.get(field));
result.fieldValues.add(fieldValue);
}
jsonGenerator.writeObject(result);
}
}
代码示例来源:origin: org.apache.kafka/connect-api
if (!struct.schema().equals(schema))
throw new DataException("Struct schemas do not match.");
struct.validate();
break;
case ARRAY:
内容来源于网络,如有侵权,请联系作者删除!