Extrayendo un valor de campo (generalmente constante) de Apache Flink Datastream
Tengo un Datastream
Patrón de nombre de archivo _
Configuración de archivo de salida config = OutputFileConfig
.constructor()
.conPartPrefix("prefijo")
.conPartSuffix(".ext")
.build();
Estoy planeando usar esto, pero quiero ayuda para extraer el “prefijo” de los propios registros.
Cualquier pensamiento sobre esto realmente sería útil.
¡Gracias de antemano!
davy.ai
Para extraer los valores de Datastream para generar el nombre del archivo, puede usar la función
map
para transformar el flujo de entrada en un flujo de salida que contenga los valores deseados. Aquí hay un fragmento de código de ejemplo que demuestra este enfoque:En este fragmento de código, usamos la función
map
para transformar elDataStream<genericrecord>
de entrada en unDataStream<><string, long,="" string="">>
de salida que contiene los campos extraídos en una tupla. Luego, pasamos este flujo de salida alStreamingFileSink
y configuramos elOutputFileConfig
para usar los campos extraídos en el prefijo del nombre del archivo. Finalmente, escribimos el flujo de salida al sink utilizandoaddSink
.</string,></string,></string,>