Modos de ejecución de streams

[marianogenovese]

Streams permantentes (no temporales / durables):

• Se crean mediante create stream.
• El tiempo de vida de estos streams y su ejecución es permanente, hasta que el usuario decida destruirlo.
• Siempre dejan su salida en una fuente.
• Estos streams son continuos por diseño.
• El valor de repetición es 0 (sin repetición definida, se repite hasta que el usuario destruya el stream).
• El valor de la ventana es definida por el usuario.
• La duración del stream es '00:00:00' (sin duración definida, dura hasta que el usuario decida destruirlo).

Stream de sesión (temporales / no durables):

• No tienen create stream.
• El tiempo de vida de estos stream y su ejecución es temporal, hasta que termine la sesión o hasta donde el usuario defina el tiempo de duración.
• Son querys directos a fuentes o a otros streams.
• Su salida puede ser dirigida a la sesión que requirió la ejecución o a una fuente.
• Estos streams pueden ser continuos y no continuos.
  • Para que el stream sea continuo debe cumplir con:
    • Repetición = 0.
    • Ventana debe tener un valor válido definido por el usuario.
    • Duración = '00:00:00'.
  • Para que el stream no sea continuo debe cumplir con:
    • Repetición > 0 o Duración > '00:00:00'.
    • Ventana debe tener un valor válido definido por el usuario.

En el contexto de los streams temporales, se puede jugar con la repetición y la duración para tener escenarios donde:

• El query se repita una vez sin importar la duración.
• El query dure el tiempo que el usuario definió sin importar la repetición.
• La repetición tiene prioridad sobre la duración.

[OscarCanek]

Podría detallar un poco mas los puntos:

• El query se repita una vez sin importar la duración.
  • Se repite solo el primer evento que llega a la consulta?
• La repetición tiene prioridad sobre la duración.
  • Cual es la implicación de este argumento?

[marianogenovese]

Ok, vamos poniendo ejemplos:

Caso A. Quiero saber durante 5 minutos (apply) un conteo de registros en una fuente. Aquí el usuario no debe poner repeticiones (apply) porque semanticamente expresa que el query tiene una duración de 5 minutos. Si poner repetición el query se comportará como exprese en la repetición porque la repetición tiene prioridad (lo que se expresa en el propuesta, esto a lo mejor puede ser mejorado validando el orden en el que expresa el usuario el apply, si es apply repetition primero o apply duration primero).

Caso B. Quiero saber por 3 veces con ventanas de 5 segundos, un conteo de registros en una fuente. Aquí el usuario no debe poner duración (apply) sino debe poner repetición (apply) y aplicar una ventana de tiempo (apply), si el usuario pone duración el comportamiento cambia.

Caso C. Quiero saber durante 1 minuto y 1 veces el conteo de registros en una fuente. Aqui aplica repetición y duración.

Los parametros de duración y repetición son válidos en el contexto de stream temporales/sesion/no durables, puesto que se desea tener una finalización del query caso contrario el usuario debe crear un stream no temporal/permanente/durable

[OscarCanek]

Interpretación

Caso A. La consulta durará solo 5 minutos. En caso de especificar repetición la consulta tendrá una duración igual a:

duración total = duración de la consulta * repeticiones

Caso B. En el caso de especificar una duración se aplicaría la misma formula del caso A para la duración total.

Caso C. Para poder contar los eventos deben colocar una ventana de tiempo. Esto último me lleva al siguiente planteamiento:

• apply window: afecta al flujo de eventos.
• apply duration: afecta a la consulta.
• apply repetition: afecta a la consulta.

Notas: la duración siempre deberá ser mayor o igual a la ventana de tiempo.

[marianogenovese]

Es posible manejar el apply repetition y duration como una condición de finalización donde el primero que se cumpla haga que termine la ejecución de la consulta. Usando el ejemplo del caso C el usuario pone una duración de 1m y una repetición de 1, si no llega ningún evento el query debe terminar al minuto, por el contrario si llega algo el query toma lo que tiene y finaliza puesto que la repetición es de 1 el query puede durar menos de 1 minuto.

La formula que aplicas para calcular la duración total, no la tengo contemplada puesto que las condiciones son o por repeticion (expresa en el query solo apply repetition) o por duración (expresa en el query solo apply duration) o por cualquier que se cumpla primero (expresa en el query apply repetition y apply duration).