Package | Description |
---|---|
org.apache.flink.api.common.distributions | |
org.apache.flink.api.common.operators | |
org.apache.flink.optimizer.postpass | |
org.apache.flink.types |
Modifier and Type | Field and Description |
---|---|
protected Key<?>[][] |
SimpleDistribution.boundaries |
Modifier and Type | Method and Description |
---|---|
Key<?>[] |
SimpleDistribution.getBucketBoundary(int bucketNum,
int totalNumBuckets) |
Constructor and Description |
---|
SimpleDistribution(Key<?>[] bucketBoundaries) |
SimpleDistribution(Key<?>[][] bucketBoundaries) |
Modifier and Type | Field and Description |
---|---|
protected ArrayList<Class<? extends Key<?>>> |
Ordering.types |
Modifier and Type | Method and Description |
---|---|
Class<? extends Key<?>> |
Ordering.getType(int index) |
Modifier and Type | Method and Description |
---|---|
Ordering |
Ordering.appendOrdering(Integer index,
Class<? extends Key<?>> type,
Order order)
Extends this ordering by appending an additional order requirement.
|
Constructor and Description |
---|
Ordering(int index,
Class<? extends Key<?>> type,
Order order) |
Modifier and Type | Method and Description |
---|---|
Class<? extends Key<?>> |
SparseKeySchema.getType(int field) |
Iterator<Map.Entry<Integer,Class<? extends Key<?>>>> |
SparseKeySchema.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
SparseKeySchema.addType(int key,
Class<? extends Key<?>> type) |
Modifier and Type | Class and Description |
---|---|
class |
Pair<U extends Key<U>,V extends Key<V>>
Generic pair base type.
|
class |
Pair<U extends Key<U>,V extends Key<V>>
Generic pair base type.
|
Modifier and Type | Interface and Description |
---|---|
interface |
NormalizableKey<T>
The base interface for normalizable keys.
|
Modifier and Type | Class and Description |
---|---|
class |
BooleanValue
Boxed serializable and comparable boolean type, representing the primitive
type
boolean . |
class |
ByteValue
Boxed serializable and comparable byte type, representing the primitive
type
byte (signed 8 bit integer). |
class |
CharValue
Boxed serializable and comparable character type, representing the primitive
type
char . |
class |
DoubleValue
Boxed serializable and comparable double precision floating point type, representing the primitive
type
double . |
class |
FloatValue
Boxed serializable and comparable single precision floating point type, representing the primitive
type
float . |
class |
IntValue
Boxed serializable and comparable integer type, representing the primitive
type
int . |
class |
LongValue
Boxed serializable and comparable long integer type, representing the primitive
type
long . |
class |
NullValue
Null base type for programs that implements the Key interface.
|
class |
Pair<U extends Key<U>,V extends Key<V>>
Generic pair base type.
|
class |
ShortValue
Boxed serializable and comparable short integer type, representing the primitive
type
short . |
class |
StringValue
Mutable string data type that implements the Key interface.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.