Empresas
Empleos
  • Sobre nosotros
  • Soluciones
    • Publicación de vacantes
      Publica tu vacante y recibe candidatos calificados en 48h.
    • Evaluación de candidatos
      500+ pruebas técnicas y psicológicas, más anti-fraude.
    • Headhunting
      Búsqueda ejecutiva a la medida de principio a fin.
    • Nómina + EOR
      Dispersión de nómina y EOR en más de 15 países de LATAM.
  • Precios
  • Empleos

0

342
Vistas
¿Tipo lógico de marca de tiempo de Avro Java API?

Con Avro Java API, puedo hacer un esquema de registro simple como:

 Schema schemaWithTimestamp = SchemaBuilder .record("MyRecord").namespace("org.demo") .fields() .name("timestamp").type().longType().noDefault() .endRecord();

¿Cómo etiqueto un campo de esquema con un tipo lógico, específicamente: https://avro.apache.org/docs/1.8.1/api/java/org/apache/avro/LogicalTypes.TimestampMillis.html

about 4 years ago · Santiago Trujillo
3 Respuestas
Responde la pregunta

0

Gracias a DontPanic:

 Schema timestampMilliType = LogicalTypes.timestampMillis().addToSchema(Schema.create(Schema.Type.LONG)); Schema schemaWithTimestamp = SchemaBuilder .record("MyRecord").namespace("org.demo") .fields() .name("timestamp_with_logical_type").type(timestampMilliType).noDefault() .name("timestamp_no_logical_type").type().longType().noDefault() .endRecord(); System.out.println(schemaWithTimestamp.toString(true));

Esto resulta en:

 { "type" : "record", "name" : "MyRecord", "namespace" : "org.demo", "fields" : [ { "name" : "timestamp_with_logical_type", "type" : { "type" : "long", "logicalType" : "timestamp-millis" } }, { "name" : "timestamp_no_logical_type", "type" : "long" } ] }
about 4 years ago · Santiago Trujillo Denunciar

0

Gracias por la primera solución, ahora por tipo lógico anulable como:

 { "name":"maturityDate", "type":["null", { "type":"long","logicalType":"timestamp-millis" }] },

Calculo lo siguiente:

 Schema timestampMilliType = LogicalTypes.timestampMillis().addToSchema(Schema.create(Schema.Type.LONG)); Schema clientIdentifier = SchemaBuilder.record("ClientIdentifier") .namespace("com.baeldung.avro") .fields() .requiredString("hostName") .requiredString("ipAddress") .name("maturityDate") .type() .unionOf() .nullType() .and() .type(timestampMilliType) .endUnion() .noDefault() .endRecord();
about 4 years ago · Santiago Trujillo Denunciar

0

Creo que puedes crear un esquema manualmente:

 List<Schema.Field> fields = new ArrayList<>(); Schema timeStampField = Schema.create(Schema.Type.LONG); fields.add(new Schema.Field("timestamp", LogicalTypes.timestampMillis().addToSchema(timeStampField), null, null)); Schema resultSchema = Schema.createRecord("MyRecord", null, "org.demo", false, fields); System.out.println(resultSchema);

tu esquema:

 {"type":"record","name":"MyRecord","namespace":"org.demo","fields":[{"name":"timestamp","type":"long"}]}

esquema de resultado con marca de tiempoMillis:

 {"type":"record","name":"MyRecodr","namespace":"org.demo","fields":[{"name":"timestamp","type":{"type":"long","logicalType":"timestamp-millis"}}]}
about 4 years ago · Santiago Trujillo Denunciar
Responde la pregunta
Encuentra empleos remotos

¡Descubre la nueva forma de encontrar empleo!

Top de empleos
Top categorías de empleo
Empresas
Publicar vacante Precios Comercial
Legal
Términos y condiciones Política de privacidad
© 2026 PeakU Inc. All Rights Reserved.
Andres GPT
Recomiéndame algunas ofertas
Necesito ayuda