Class | Description |
---|---|
AbstractRuntimeUDFContext |
A standalone implementation of the
RuntimeContext , created by runtime UDF operators. |
CopyingIterator<E> |
Wraps an iterator to return deep copies of the original iterator's elements.
|
CopyingListCollector<T> |
A
Collector that collects deep copies of its elements in a list. |
FunctionUtils |
Utility class that contains helper methods to work with Flink
Function class. |
ListCollector<T> |
A
Collector that puts the collected elements into a given list. |
NoOpFunction |
An
AbstractRichFunction that does nothing. |
PrintSinkOutputWriter<IN> |
Print sink output writer for DataStream and DataSet print API.
|
RuntimeUDFContext |
A standalone implementation of the
RuntimeContext , created by runtime UDF operators. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.