Interface | Description |
---|---|
InternalWindowFunction<IN,OUT,KEY,W extends Window> |
Internal interface for functions that are evaluated over keyed (grouped) windows.
|
InternalWindowFunction.InternalWindowContext |
A context for
InternalWindowFunction , similar to
ProcessWindowFunction.Context but
for internal use. |
Class | Description |
---|---|
InternalAggregateProcessAllWindowFunction<T,ACC,V,R,W extends Window> |
Internal window function for wrapping a
ProcessAllWindowFunction that takes an
Iterable and an AggregateFunction . |
InternalAggregateProcessWindowFunction<T,ACC,V,R,K,W extends Window> |
Internal window function for wrapping a
ProcessWindowFunction that takes an
Iterable and an AggregateFunction . |
InternalIterableAllWindowFunction<IN,OUT,W extends Window> |
Internal window function for wrapping an
AllWindowFunction that takes an Iterable
when the window state also is an Iterable . |
InternalIterableProcessAllWindowFunction<IN,OUT,W extends Window> |
Internal window function for wrapping a
ProcessAllWindowFunction that takes an Iterable
when the window state also is an Iterable . |
InternalIterableProcessWindowFunction<IN,OUT,KEY,W extends Window> |
Internal window function for wrapping a
ProcessWindowFunction that takes an Iterable
when the window state also is an Iterable . |
InternalIterableWindowFunction<IN,OUT,KEY,W extends Window> |
Internal window function for wrapping a
WindowFunction that takes an Iterable
when the window state also is an Iterable . |
InternalProcessAllWindowContext<IN,OUT,W extends Window> |
Internal reusable context wrapper.
|
InternalProcessWindowContext<IN,OUT,KEY,W extends Window> |
Internal reusable context wrapper.
|
InternalSingleValueAllWindowFunction<IN,OUT,W extends Window> |
Internal window function for wrapping an
AllWindowFunction that takes an Iterable
when the window state is a single value. |
InternalSingleValueProcessAllWindowFunction<IN,OUT,W extends Window> |
Internal window function for wrapping a
ProcessAllWindowFunction that takes an Iterable
when the window state is a single value. |
InternalSingleValueProcessWindowFunction<IN,OUT,KEY,W extends Window> |
Internal window function for wrapping a
ProcessWindowFunction that takes an Iterable
when the window state is a single value. |
InternalSingleValueWindowFunction<IN,OUT,KEY,W extends Window> |
Internal window function for wrapping a
WindowFunction that takes an Iterable
when the window state is a single value. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.