Package | Description |
---|---|
org.apache.flink.api.java.functions | |
org.apache.flink.runtime.operators.udf | |
org.apache.flink.state.api.output |
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 |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
BoundedOneInputStreamTaskRunner<IN>
A
RichMapPartitionFunction that serves as the runtime for a BoundedStreamTask . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.