Estas son algunas de las consultas que tengo:

Tengo dos transmisiones diferentesstream1 ystream2 en el que los elementos están en orden.

1) Ahora cuando lo hagokeyBy en cada una de estas transmisiones, ¿se mantendrá el orden? (Dado que cada grupo aquí se enviará solo a un administrador de tareas). Entiendo que los registros estarán en orden para un grupo, corrígeme aquí.

2) Después delkeyBy en ambas transmisiones estoy haciendo un grupo para obtener los registros coincidentes y no coincidentes. ¿El pedido se mantendrá aquí también ?, ya que esto también funciona enKeyedStream. estoy usandoEventTimeyAscendingTimestampExtractor para generartimestamp ywatermark.

3) Ahora quiero realizar la verificación de secuencia en elmatching_nonMatchingStream Obtengo de 2) usando map / flatmap. ¿Necesito volver a realizar elkeyBy aquí, o si me mantengo encadenadomatching_nonMatchingStream correr en el mismoTaskManager? Aquí entiendo que la cadena funcionará aquí, corrígeme, confundiéndome.

4)slotSharingGroup - ¿podría describir más sobre esto de acuerdo con el documento? Establece el grupo de compartición de ranuras de esta operación. Las instancias paralelas de operaciones que están en el mismo grupo de compartición de slots se ubicarán en el mismoTaskManager ranura, si es posible.