Class ConcatenatedExtract<FROM,OVER,TO>
- java.lang.Object
-
- org.apache.flink.streaming.api.functions.windowing.delta.extractor.ConcatenatedExtract<FROM,OVER,TO>
-
- Type Parameters:
FROM
- The input type of the first extractor.OVER
- The output type of the first and the input type of the second extractor.TO
- The output type of the second extractor and the output type of the over all extraction.
- All Implemented Interfaces:
Serializable
,Extractor<FROM,TO>
@Internal public class ConcatenatedExtract<FROM,OVER,TO> extends Object implements Extractor<FROM,TO>
Combines two extractors which will be executed one after each other.- See Also:
- Serialized Form
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <OUT> ConcatenatedExtract<FROM,TO,OUT>
add(Extractor<TO,OUT> e3)
TO
extract(FROM in)
Extracts/Converts the given input to an object of the output type.
-
-
-
Constructor Detail
-
ConcatenatedExtract
public ConcatenatedExtract(Extractor<FROM,OVER> e1, Extractor<OVER,TO> e2)
Combines two extractors which will be executed one after each other.- Parameters:
e1
- First extractor: This extractor gets applied to the input data first. Its output as then passed as input to the second extractor.e2
- Second extractor: This extractor gets the output of the first extractor as input. Its output is then the result of the over all extraction.
-
-