Package cz.o2.proxima.flink.core
Interface ResultExtractor<T>
-
- Type Parameters:
T
- Type to extract.
- All Superinterfaces:
java.io.Serializable
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@Experimental("API can be changed.") @FunctionalInterface public interface ResultExtractor<T> extends java.io.Serializable
Simple function, that extractsStreamElement
into a desired type.
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description static ResultExtractor<StreamElement>
identity()
Create identity extractor, that just returns an input element.static <T> ResultExtractor<T>
parsed()
Create an extractor, that just extracts parsed value from a stream element.T
toResult(StreamElement element)
ConvertStreamElement
into a desired type.
-
-
-
Method Detail
-
identity
static ResultExtractor<StreamElement> identity()
Create identity extractor, that just returns an input element.- Returns:
- Identity extractor.
-
parsed
static <T> ResultExtractor<T> parsed()
Create an extractor, that just extracts parsed value from a stream element.- Type Parameters:
T
- Type of extracted element.- Returns:
- Parsed value.
-
toResult
T toResult(StreamElement element)
ConvertStreamElement
into a desired type.- Parameters:
element
- Element to convert.- Returns:
- Converted element.
-
-