У меня есть конвейер луча, который принимает данные json, анализирует их, а затем записывает в виде файлов паркета в корзину GCS. Я не знаю, как обрабатывать даты и временные метки при определении схемы Avro в Java. Это не дает возможности для дат или чего-то подобного. Только примитивы. Сейчас все работает, но моя дата остается в виде строки. Есть ли у кого-нибудь какие-либо предложения по определению дат/временных меток в объекте схемы Avro, а также объектах Java для передачи в качестве?
static final Schema SCHEMA = SchemaBuilder.record("Record")
.namespace("com.foo").fields().requiredString("val1")
.requiredString("val2").requiredString("timestamp").endRecord();
Пример временной метки:
String timestamp = "2018-12-06T21:22:35.700Z";