Package | Description |
---|---|
org.apache.flink.api.table.runtime | |
org.apache.flink.api.table.typeinfo |
Modifier and Type | Method and Description |
---|---|
void |
ExpressionAggregateFunction.combine(Iterable<Row> in,
Collector<Row> out) |
void |
ExpressionAggregateFunction.combine(Iterable<Row> in,
Collector<Row> out) |
void |
NoExpressionAggregateFunction.combine(Iterable<Row> in,
Collector<Row> out) |
void |
NoExpressionAggregateFunction.combine(Iterable<Row> in,
Collector<Row> out) |
void |
ExpressionAggregateFunction.reduce(Iterable<Row> in,
Collector<Row> out) |
void |
ExpressionAggregateFunction.reduce(Iterable<Row> in,
Collector<Row> out) |
void |
NoExpressionAggregateFunction.reduce(Iterable<Row> in,
Collector<Row> out) |
void |
NoExpressionAggregateFunction.reduce(Iterable<Row> in,
Collector<Row> out) |
Modifier and Type | Method and Description |
---|---|
Row |
RowSerializer.copy(Row from) |
Row |
RowSerializer.copy(Row from,
Row reuse) |
Row |
RowSerializer.createInstance() |
Row |
RowSerializer.deserialize(DataInputView source) |
Row |
RowSerializer.deserialize(Row reuse,
DataInputView source) |
Row |
RowComparator.readWithKeyDenormalization(Row reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeComparator<Row> |
RowTypeInfo.createComparator(int[] logicalKeyFields,
boolean[] orders,
int logicalFieldOffset,
ExecutionConfig config) |
TypeSerializer<Row> |
RowTypeInfo.createSerializer(ExecutionConfig executionConfig) |
CompositeType.TypeComparatorBuilder<Row> |
RowTypeInfo.createTypeComparatorBuilder() |
TypeComparator<Row> |
RowComparator.duplicate() |
Modifier and Type | Method and Description |
---|---|
int |
RowComparator.compare(Row first,
Row second) |
Row |
RowSerializer.copy(Row from) |
Row |
RowSerializer.copy(Row from,
Row reuse) |
Row |
RowSerializer.deserialize(Row reuse,
DataInputView source) |
boolean |
RowComparator.equalToReference(Row candidate) |
int |
RowComparator.hash(Row value) |
void |
RowComparator.putNormalizedKey(Row record,
MemorySegment target,
int offset,
int numBytes) |
Row |
RowComparator.readWithKeyDenormalization(Row reuse,
DataInputView source) |
void |
RowSerializer.serialize(Row value,
DataOutputView target) |
void |
RowComparator.setReference(Row toCompare) |
static void |
NullMaskUtils.writeNullMask(int len,
Row value,
DataOutputView target) |
void |
NullMaskUtils$.writeNullMask(int len,
Row value,
DataOutputView target) |
void |
RowComparator.writeWithKeyNormalization(Row record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
int |
RowComparator.compareToReference(TypeComparator<Row> referencedComparator) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.