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

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

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

AvroUtils._logicalTimestamp介绍

[英]Returns schema for Avro Timestamp-millis logical type. It's Avro type is Long
[中]返回Avro时间戳毫秒逻辑类型的架构。它是Avro型的，很长

代码示例

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

@Override
public Schema getSchema() {
  return AvroUtils._logicalTimestamp();
}

代码示例来源：origin: org.talend.daikon/daikon

return AvroUtils._logicalTimestamp();

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

/**
 * Checks {@link AvroTypeConverter#convertToAvro(String, String)} returns Long avro schema with "java-class"=java.util.Date
 * in case TalendType.DATE Talend type is passed
 */
@Test
public void testConvertToAvroDate() {
  Schema expectedSchema = AvroUtils._logicalTimestamp();
  assertEquals(expectedSchema, AvroTypeConverter.convertToAvro(TalendType.DATE, null));
}

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

/**
   * Checks {@link AvroTypeConverter#convertToAvro(String, String)} returns logical timestamp-millis avro schema with in case
   * "timestamp-millis" logical type is passed
   */
  @Test
  public void testConvertToAvroLogicalTimestamp() {
    Schema expectedSchema = AvroUtils._logicalTimestamp();
    assertEquals(expectedSchema, AvroTypeConverter.convertToAvro(null, "timestamp-millis"));
  }
}

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

/**
 * Checks {@link TalendType#convertFromAvro(Schema)} converts logical timestamp-millis avro type to "id_Date" di type
 */
@Test
public void testConvertFromAvroLogicalTimestampMillis() {
  TalendType expectedType = TalendType.DATE;
  Schema fieldSchema = AvroUtils._logicalTimestamp();
  assertEquals(expectedType, TalendType.convertFromAvro(fieldSchema));
}

代码示例来源：origin: org.talend.components/components-salesforce-definition

@Override
public void setupProperties() {
  super.setupProperties();
  Schema s = SchemaBuilder.record("Main").fields().name("ServerTimeStamp")
      .prop(SchemaConstants.TALEND_COLUMN_PATTERN, "yyyy-MM-dd'T'HH:mm:ss'.000Z'")
      .prop(SchemaConstants.TALEND_COLUMN_DB_LENGTH, "20")//$NON-NLS-1$
      .type(AvroUtils._logicalTimestamp()).noDefault().endRecord();
  s.addProp(TALEND_IS_LOCKED, "true");
  schema.schema.setValue(s);
}

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

@Override
public void setupProperties() {
  super.setupProperties();
  Schema s = SchemaBuilder.record("Main").fields().name("ServerTimeStamp")
      .prop(SchemaConstants.TALEND_COLUMN_PATTERN, "yyyy-MM-dd'T'HH:mm:ss'.000Z'")
      .prop(SchemaConstants.TALEND_COLUMN_DB_LENGTH, "20")//$NON-NLS-1$
      .type(AvroUtils._logicalTimestamp()).noDefault().endRecord();
  s.addProp(TALEND_IS_LOCKED, "true");
  schema.schema.setValue(s);
}

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

return AvroUtils._decimal();
case DATE:
  return AvroUtils._logicalTimestamp();
default:
  throw new UnsupportedOperationException("Unrecognized type " + talendType);

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

base = AvroUtils._double();
} else if (customFieldRefType == CustomFieldRefType.DATE) {
  base = AvroUtils._logicalTimestamp();
} else if (customFieldRefType == CustomFieldRefType.STRING) {
  base = AvroUtils._string();
  base = AvroUtils._double();
} else if (fieldType == XMLGregorianCalendar.class) {
  base = AvroUtils._logicalTimestamp();
} else if (fieldType == String.class) {
  base = AvroUtils._string();

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

return AvroUtils._decimal();
case DATE:
  return AvroUtils._logicalTimestamp();
default:
  throw new UnsupportedOperationException("Unrecognized type " + talendType);

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

assertEquals(AvroUtils._logicalTimestamp(), converter1.getSchema());
assertEquals(XMLGregorianCalendar.class, converter1.getDatumClass());
assertEquals(controlValue1,

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

.withDefault("0")
.name("updated")
.type(AvroUtils._logicalTimestamp())
.noDefault()
.name("myvariant")

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

.withDefault("0")
.name("updated")
.type(Schema.createUnion(AvroUtils._logicalTimestamp(), Schema.create(Schema.Type.NULL)))
.noDefault()
.name("myvariant")

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

.prop(SchemaConstants.JAVA_CLASS_FLAG, Date.class.getCanonicalName()) //
.prop(SchemaConstants.TALEND_COLUMN_DB_LENGTH, "255")//
.type(AvroUtils._logicalTimestamp()).noDefault() //
.name(GoogleDriveListDefinition.RETURN_SIZE).prop(SchemaConstants.TALEND_IS_LOCKED, "true").type().nullable()

代码示例来源：origin: org.talend.components/components-googledrive-definition

.prop(SchemaConstants.JAVA_CLASS_FLAG, Date.class.getCanonicalName()) //
.prop(SchemaConstants.TALEND_COLUMN_DB_LENGTH, "255")//
.type(AvroUtils._logicalTimestamp()).noDefault() //
.name(GoogleDriveListDefinition.RETURN_SIZE).prop(SchemaConstants.TALEND_IS_LOCKED, "true").type().nullable()

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

.prop(SchemaConstants.JAVA_CLASS_FLAG, Date.class.getCanonicalName()) //
.prop(SchemaConstants.TALEND_COLUMN_DB_LENGTH, "255")//
.type(AvroUtils._logicalTimestamp()).noDefault() //
.name(GoogleDriveListDefinition.RETURN_SIZE).prop(SchemaConstants.TALEND_IS_LOCKED, "true").type().nullable()

代码示例来源：origin: org.talend.components/components-googledrive-definition

.prop(SchemaConstants.JAVA_CLASS_FLAG, Date.class.getCanonicalName()) //
.prop(SchemaConstants.TALEND_COLUMN_DB_LENGTH, "255")//
.type(AvroUtils._logicalTimestamp()).noDefault() //
.name(GoogleDriveListDefinition.RETURN_SIZE).prop(SchemaConstants.TALEND_IS_LOCKED, "true").type().nullable()

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

@Before
public void createSchema(){
  schema = SchemaBuilder.builder()
      .record("main")
      .fields()
      .name("id")
      .prop(SchemaConstants.TALEND_COLUMN_IS_KEY, "true")
      .type(AvroUtils._int())
      .withDefault(1)
      .name("name")
      .prop(SchemaConstants.TALEND_COLUMN_IS_KEY, "true")
      .prop(SchemaConstants.TALEND_COLUMN_DB_LENGTH, "255")
      .prop(SchemaConstants.TALEND_COLUMN_DEFAULT, "\"ok\"")
      .type(AvroUtils._string())
      .noDefault()
      .name("date")
      .type(AvroUtils._logicalDate())
      .noDefault()
      .name("salary")
      .prop(SchemaConstants.TALEND_COLUMN_DB_TYPE, "MY_DOUBLE")
      .prop(SchemaConstants.TALEND_COLUMN_PRECISION, "38")
      .prop(SchemaConstants.TALEND_COLUMN_SCALE, "4")
      .type(AvroUtils._double())
      .withDefault("0")
      .name("updated")
      .type(AvroUtils._logicalTimestamp())
      .noDefault()
      .endRecord();
}

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

@Before
public void createSchema() {
  schema = SchemaBuilder.builder()
      .record("main")
      .fields()
      .name("id")
      .prop(SchemaConstants.TALEND_COLUMN_IS_KEY, "true")
      .type(AvroUtils._int())
      .withDefault(1)
      .name("name")
      .prop(SchemaConstants.TALEND_COLUMN_IS_KEY, "true")
      .prop(SchemaConstants.TALEND_COLUMN_DB_LENGTH, "255")
      .prop(SchemaConstants.TALEND_COLUMN_DEFAULT, "\"ok\"")
      .type(AvroUtils._string())
      .noDefault()
      .name("date")
      .type(AvroUtils._logicalDate())
      .noDefault()
      .name("salary")
      .prop(SchemaConstants.TALEND_COLUMN_DB_TYPE, "MY_DOUBLE")
      .prop(SchemaConstants.TALEND_COLUMN_PRECISION, "38")
      .prop(SchemaConstants.TALEND_COLUMN_SCALE, "4")
      .type(AvroUtils._double())
      .withDefault("0")
      .name("updated")
      .type(AvroUtils._logicalTimestamp())
      .noDefault()
      .endRecord();
}

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

@Before
public void createSchema() {
  schema = SchemaBuilder.builder()
      .record("main")
      .fields()
      .name("id")
      .prop(SchemaConstants.TALEND_COLUMN_IS_KEY, "true")
      .type(Schema.createUnion(AvroUtils._int(), Schema.create(Schema.Type.NULL)))
      .withDefault(1)
      .name("name")
      .prop(SchemaConstants.TALEND_COLUMN_IS_KEY, "true")
      .prop(SchemaConstants.TALEND_COLUMN_DB_LENGTH, "255")
      .prop(SchemaConstants.TALEND_COLUMN_DEFAULT, "\"ok\"")
      .type(Schema.createUnion(AvroUtils._string(), Schema.create(Schema.Type.NULL)))
      .noDefault()
      .name("date")
      .type(Schema.createUnion(AvroUtils._logicalDate(), Schema.create(Schema.Type.NULL)))
      .noDefault()
      .name("salary")
      .prop(SchemaConstants.TALEND_COLUMN_DB_TYPE, "MY_DOUBLE")
      .prop(SchemaConstants.TALEND_COLUMN_DB_LENGTH, "38")
      .prop(SchemaConstants.TALEND_COLUMN_PRECISION, "4")
      .type(Schema.createUnion(AvroUtils._double(), Schema.create(Schema.Type.NULL)))
      .withDefault("0")
      .name("updated")
      .type(Schema.createUnion(AvroUtils._logicalTimestamp(), Schema.create(Schema.Type.NULL)))
      .noDefault()
      .endRecord();
}

内容来源于网络，如有侵权，请联系作者删除！

AvroUtils

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com