Package | Description |
---|---|
org.apache.flink.streaming.api.functions.windowing.delta | |
org.apache.flink.streaming.api.functions.windowing.delta.extractor |
Constructor and Description |
---|
CosineDistance(Extractor<DATA,double[]> converter) |
EuclideanDistance(Extractor<DATA,double[]> converter) |
ExtractionAwareDeltaFunction(Extractor<DATA,TO> converter) |
Modifier and Type | Class and Description |
---|---|
class |
ArrayFromTuple
Converts a Tuple to an Object-Array.
|
class |
ConcatenatedExtract<FROM,OVER,TO>
Combines two extractors which will be executed one after each other.
|
class |
FieldFromArray<OUT>
Extracts a single field out of an array.
|
class |
FieldFromTuple<OUT>
Extracts a single field out of a tuple.
|
class |
FieldsFromArray<OUT>
Extracts multiple fields from an array and puts them into a new array of the specified type.
|
class |
FieldsFromTuple
Extracts one or more fields of the type Double from a tuple and puts them into a new double[].
|
Modifier and Type | Method and Description |
---|---|
<OUT> ConcatenatedExtract<FROM,TO,OUT> |
ConcatenatedExtract.add(Extractor<TO,OUT> e3) |
Constructor and Description |
---|
ConcatenatedExtract(Extractor<FROM,OVER> e1,
Extractor<OVER,TO> e2)
Combines two extractors which will be executed one after each other.
|
ConcatenatedExtract(Extractor<FROM,OVER> e1,
Extractor<OVER,TO> e2)
Combines two extractors which will be executed one after each other.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.