org.talend.daikon.avro.AvroUtils._character()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(10.1k)|赞(0)|评价(0)|浏览(76)

本文整理了Java中org.talend.daikon.avro.AvroUtils._character()方法的一些代码示例,展示了AvroUtils._character()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AvroUtils._character()方法的具体详情如下:
包路径:org.talend.daikon.avro.AvroUtils
类名称:AvroUtils
方法名:_character

AvroUtils._character介绍

暂无

代码示例

代码示例来源:origin: Talend/components

/**
 * Checks {@link TalendType#convertFromAvro(Schema)} converts string avro type with java-class flag "java.lang.TalendType" to
 * "id_Character" di type
 */
@Test
public void testConvertFromAvroCharacter() {
  TalendType expectedType = TalendType.CHARACTER;
  Schema fieldSchema = AvroUtils._character();
  assertEquals(expectedType, TalendType.convertFromAvro(fieldSchema));
}

代码示例来源:origin: Talend/components

/**
 * Checks {@link AvroTypeConverter#convertToAvro(String, String)} returns String avro schema with
 * "java-class"=java.lang.Character in case TalendType.CHARACTER Talend type is passed
 */
@Test
public void testConvertToAvroCharacter() {
  Schema expectedSchema = AvroUtils._character();
  assertEquals(expectedSchema, AvroTypeConverter.convertToAvro(TalendType.CHARACTER, null));
}

代码示例来源:origin: Talend/components

} else if (AvroUtils.isSameType(basicSchema, AvroUtils._short())) {
    statement.setNull(index, java.sql.Types.SMALLINT);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._character())) {
    statement.setNull(index, java.sql.Types.CHAR);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._byte())) {
} else if (AvroUtils.isSameType(basicSchema, AvroUtils._short())) {
  statement.setShort(index, (Short) value);
} else if (AvroUtils.isSameType(basicSchema, AvroUtils._character())) {
  statement.setInt(index, (Character) value);
} else if (AvroUtils.isSameType(basicSchema, AvroUtils._byte())) {

代码示例来源:origin: org.talend.components/components-jdbc-runtime

} else if (AvroUtils.isSameType(basicSchema, AvroUtils._short())) {
    statement.setNull(index, java.sql.Types.SMALLINT);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._character())) {
    statement.setNull(index, java.sql.Types.CHAR);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._byte())) {
} else if (AvroUtils.isSameType(basicSchema, AvroUtils._short())) {
  statement.setShort(index, (Short) value);
} else if (AvroUtils.isSameType(basicSchema, AvroUtils._character())) {
  statement.setInt(index, (Character) value);
} else if (AvroUtils.isSameType(basicSchema, AvroUtils._byte())) {

代码示例来源:origin: org.talend.components/components-common

return AvroUtils._short();
case CHARACTER:
  return AvroUtils._character();
case BIG_DECIMAL:
  return AvroUtils._decimal();

代码示例来源:origin: Talend/components

return AvroUtils._short();
case CHARACTER:
  return AvroUtils._character();
case BIG_DECIMAL:
  return AvroUtils._decimal();

代码示例来源:origin: org.talend.components/components-jdbc-runtime

return AvroUtils._short();
case CHARACTER:
  return AvroUtils._character();
case BIG_DECIMAL:
  return AvroUtils._decimal();

代码示例来源:origin: Talend/components

return AvroUtils._short();
case CHARACTER:
  return AvroUtils._character();
case BIG_DECIMAL:
  return AvroUtils._decimal();

代码示例来源:origin: Talend/components

public AvroConverter<String, ?> getConverter(Schema.Field f, FileDelimitedProperties properties) {
  Schema fieldSchema = AvroUtils.unwrapIfNullable(f.schema());
  if (AvroUtils.isSameType(fieldSchema, AvroUtils._boolean())) {
    return new BooleanConverter(f);
  } else if (AvroUtils.isSameType(fieldSchema, AvroUtils._decimal())) {
    return new DecimalConverter(f, properties);
  } else if (AvroUtils.isSameType(fieldSchema, AvroUtils._double())) {
    return new DoubleConverter(f, properties);
  } else if (AvroUtils.isSameType(fieldSchema, AvroUtils._float())) {
    return new FloatConverter(f, properties);
  } else if (AvroUtils.isSameType(fieldSchema, AvroUtils._int())) {
    return new IntegerConverter(f, properties);
  } else if (AvroUtils.isSameType(fieldSchema, AvroUtils._date())) {
    return new DateConverter(f, properties);
  } else if (AvroUtils.isSameType(fieldSchema, AvroUtils._long())) {
    return new LongConverter(f, properties);
  } else if (AvroUtils.isSameType(fieldSchema, AvroUtils._bytes())) {
    return new BytesConverter(f, properties);
  } else if (AvroUtils.isSameType(fieldSchema, AvroUtils._byte())) {
    return new ByteConverter(f, properties);
  } else if (AvroUtils.isSameType(fieldSchema, AvroUtils._short())) {
    return new ShortConverter(f, properties);
  } else if (AvroUtils.isSameType(fieldSchema, AvroUtils._character())) {
    return new CharacterConverter(f);
  } else if (AvroUtils.isSameType(fieldSchema, AvroUtils._string())) {
    return super.getConverter(String.class);
  }
  throw new UnsupportedOperationException("The type " + fieldSchema.getType() + " is not supported."); //$NON-NLS-1$ //$NON-NLS-2$
}

代码示例来源:origin: org.talend.components/components-jdbc-runtime

} else if (AvroUtils.isSameType(basicSchema, AvroUtils._short())) {
  return Types.SMALLINT;
} else if (AvroUtils.isSameType(basicSchema, AvroUtils._character())) {
  return Types.CHAR;
} else if (AvroUtils.isSameType(basicSchema, AvroUtils._byte())) {

代码示例来源:origin: Talend/components

} else if (AvroUtils.isSameType(basicSchema, AvroUtils._short())) {
  return Types.SMALLINT;
} else if (AvroUtils.isSameType(basicSchema, AvroUtils._character())) {
  return Types.CHAR;
} else if (AvroUtils.isSameType(basicSchema, AvroUtils._byte())) {

代码示例来源:origin: org.talend.components/components-jdbc-runtime

} else if (AvroUtils.isSameType(basicSchema, AvroUtils._short())) {
  writer = new ShortTypeWriter(statement, statementIndex, inputValueLocation);
} else if (AvroUtils.isSameType(basicSchema, AvroUtils._character())) {
  writer = new CharacterTypeWriter(statement, statementIndex, inputValueLocation);
} else if (AvroUtils.isSameType(basicSchema, AvroUtils._byte())) {

代码示例来源:origin: Talend/components

} else if (AvroUtils.isSameType(basicSchema, AvroUtils._short())) {
  writer = new ShortTypeWriter(statement, statementIndex, inputValueLocation);
} else if (AvroUtils.isSameType(basicSchema, AvroUtils._character())) {
  writer = new CharacterTypeWriter(statement, statementIndex, inputValueLocation);
} else if (AvroUtils.isSameType(basicSchema, AvroUtils._byte())) {

代码示例来源:origin: Talend/components

public static DTEConverter createConverter(final Field f, final String mappedName) {
  Schema basicSchema = AvroUtils.unwrapIfNullable(f.schema());
  AzureStorageDTEConverters converters = new AzureStorageDTEConverters();
  DTEConverter dteConverter;
  if (AvroUtils.isSameType(basicSchema, AvroUtils._string()) || AvroUtils.isSameType(basicSchema, AvroUtils._character())) {
    dteConverter = converters.new StringDTEConverter(f, mappedName);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._int()) || AvroUtils.isSameType(basicSchema, AvroUtils._short())
      || AvroUtils.isSameType(basicSchema, AvroUtils._byte())) {
    dteConverter = converters.new IntegerDTEConverter(mappedName);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._date())) {
    dteConverter = converters.new DateDTEConverter(f, mappedName);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._decimal())
      || AvroUtils.isSameType(basicSchema, AvroUtils._double())
      || AvroUtils.isSameType(basicSchema, AvroUtils._float())) {
    dteConverter = converters.new DoubleDTEConverter(mappedName);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._long())) {
    dteConverter = converters.new LongDTEConverter(f, mappedName);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._boolean())) {
    dteConverter = converters.new BooleanDTEConverter(mappedName);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._bytes())) {
    dteConverter = converters.new ByteArrayDTEConverter(mappedName);
  } else {
    dteConverter = converters.new StringDTEConverter(f, mappedName);
  }
  return dteConverter;
}

代码示例来源:origin: org.talend.components/components-azurestorage

public static DTEConverter createConverter(final Field f, final String mappedName) {
  Schema basicSchema = AvroUtils.unwrapIfNullable(f.schema());
  AzureStorageDTEConverters converters = new AzureStorageDTEConverters();
  DTEConverter dteConverter;
  if (AvroUtils.isSameType(basicSchema, AvroUtils._string()) || AvroUtils.isSameType(basicSchema, AvroUtils._character())) {
    dteConverter = converters.new StringDTEConverter(f, mappedName);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._int()) || AvroUtils.isSameType(basicSchema, AvroUtils._short())
      || AvroUtils.isSameType(basicSchema, AvroUtils._byte())) {
    dteConverter = converters.new IntegerDTEConverter(mappedName);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._date())) {
    dteConverter = converters.new DateDTEConverter(f, mappedName);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._decimal())
      || AvroUtils.isSameType(basicSchema, AvroUtils._double())
      || AvroUtils.isSameType(basicSchema, AvroUtils._float())) {
    dteConverter = converters.new DoubleDTEConverter(mappedName);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._long())) {
    dteConverter = converters.new LongDTEConverter(f, mappedName);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._boolean())) {
    dteConverter = converters.new BooleanDTEConverter(mappedName);
  } else if (AvroUtils.isSameType(basicSchema, AvroUtils._bytes())) {
    dteConverter = converters.new ByteArrayDTEConverter(mappedName);
  } else {
    dteConverter = converters.new StringDTEConverter(f, mappedName);
  }
  return dteConverter;
}

代码示例来源:origin: org.talend.components/components-common

} else if (AvroUtils.isSameType(basicSchema, AvroUtils._character())) {
  return new JDBCSPConverter() {

代码示例来源:origin: Talend/components

} else if (AvroUtils.isSameType(basicSchema, AvroUtils._character())) {
  return new JDBCSPConverter() {

代码示例来源:origin: org.talend.components/components-common

} else if (AvroUtils.isSameType(basicSchema, AvroUtils._character())) {
  return new JDBCConverter() {

代码示例来源:origin: Talend/components

public static Schema getBasicSchema(String pattern) {
  return SchemaBuilder.builder().record("Schema").fields() //
      .name("TestBoolean").type().booleanType().noDefault() //
      .name("TestByte").type(AvroUtils._byte()).noDefault() //
      .name("TestBytes").type(AvroUtils._bytes()).noDefault() //
      .name("TestChar").type(AvroUtils._character()).noDefault() //
      .name("TestDate").prop(SchemaConstants.TALEND_COLUMN_PATTERN, pattern)//
      .type(AvroUtils._date()).noDefault() //
      .name("TestDouble").type().doubleType().noDefault() //
      .name("TestFloat").type().floatType().noDefault() //
      .name("TestBigDecimal").type(AvroUtils._decimal()).noDefault()//
      .name("TestInteger").type().intType().noDefault() //
      .name("TestLong").type().longType().noDefault() //
      .name("TestObject").type(AvroUtils._bytes()).noDefault().endRecord();
}

代码示例来源:origin: Talend/components

.noDefault()
.name("character_fld")
.type(AvroUtils._character())
.noDefault()
.name("decimal_fld")

相关文章