Red de conocimiento informático - Aprendizaje de programación - flink abre la función de ventana

flink abre la función de ventana

FlinkSQL

Ventana:

TUMBLE(datos de TABLA, DESCRIPTOR(tiempocol), tamaño)

HOP(datos de TABLA, DESCRIPTOR(tiempocol), diapositiva, tamaño [ , desplazamiento ]

SESSION(lt; time-attrgt;, lt; gap-intervalgt;)

lt; gap-intervalgt;: INTERVALO 'cadena' unidad de tiempo

CUMULATE(TABLE data, DESCRIPTOR(timecol), slide, size [, offset])

Función de ventana acumulativa: CUMULATE(TABLE data, DESCRIPTOR(timecol), step, size)

Ventana de agrupación Agregación CONJUNTOS DE AGRUPACIÓN

sobre funciones

CUBO

Flink DataStream

Agregación incremental y agregación completa

Agregación incremental: la ventana no guarda los datos originales, solo los resultados intermedios, y cada vez se agrega en función de los resultados intermedios y los datos incrementales

Por ejemplo, ReduceFunction, AggregateFunction

Agregación completa: ventana. Todos los datos originales deben conservarse y la ventana activa la agregación completa, como ProcessWindowFunction

.

上篇: Comunicación serial y adquisición de imágenes en matlab. 下篇: ¿Cómo uso las macros del mouse para configurar el control de calidad con un clic de Riven, el toque ocular con un clic del monje ciego, etc.? ¿Cómo configuro Riven Q después de A?

Artículos populares