Package | Description |
---|---|
org.apache.flink.api.java.functions | |
org.apache.flink.python.api.functions | |
org.apache.flink.runtime.operators.udf |
Modifier and Type | Class and Description |
---|---|
class |
SampleInPartition<T>
SampleInPartition wraps the sample logic on the partition side (the first phase of distributed
sample algorithm).
|
class |
SampleWithFraction<T>
A map partition function wrapper for sampling algorithms with fraction, the sample algorithm
takes the partition iterator as input.
|
Modifier and Type | Class and Description |
---|---|
class |
PythonMapPartition<IN,OUT>
Multi-purpose class, usable by all operations using a python script with one input source and possibly differing
in-/output types.
|
Modifier and Type | Class and Description |
---|---|
class |
AssignRangeIndex<IN>
This mapPartition function require a DataSet with RangeBoundaries as broadcast input, it
generate Tuple2 which includes range index and record itself as output.
|
class |
RangeBoundaryBuilder<T>
Build RangeBoundaries with input records.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.