Modifier and Type | Class and Description |
---|---|
class |
BinaryRow
A special row which is backed by
MemorySegment instead of Object. |
class |
BoxedWrapperRow
A
ObjectArrayRow that wrap primitive type to boxed object to reuse. |
class |
ColumnarRow
Columnar row to support access to vector column data.
|
class |
GenericRow
A GenericRow can have arbitrary number of fields and contain a set of fields, which may all be
different types.
|
class |
JoinedRow
Join two row to one row.
|
class |
NestedRow
Its memory storage structure is exactly the same with
BinaryRow . |
class |
ObjectArrayRow
An row implementation that uses an array of objects as the underlying storage.
|
class |
UpdatableRow
Wrap row to a updatable Generic Row.
|
Modifier and Type | Method and Description |
---|---|
BaseRow |
UpdatableRow.getRow() |
BaseRow |
TypeGetterSetters.getRow(int ordinal,
int numFields)
Get row value, internal format is BaseRow.
|
BaseRow |
BinaryRow.getRow(int pos,
int numFields) |
BaseRow |
NestedRow.getRow(int pos,
int numFields) |
BaseRow |
BinaryArray.getRow(int pos,
int numFields) |
BaseRow |
UpdatableRow.getRow(int ordinal,
int numFields) |
BaseRow |
JoinedRow.getRow(int i,
int numFields) |
BaseRow |
ObjectArrayRow.getRow(int ordinal,
int numFields) |
BaseRow |
ColumnarRow.getRow(int ordinal,
int numFields) |
BaseRow |
GenericArray.getRow(int pos,
int numFields) |
Modifier and Type | Method and Description |
---|---|
NestedRow |
NestedRow.copy(BaseRow reuse) |
boolean |
BinaryRow.equalsWithoutHeader(BaseRow o) |
boolean |
ObjectArrayRow.equalsWithoutHeader(BaseRow o) |
JoinedRow |
JoinedRow.replace(BaseRow row1,
BaseRow row2) |
External |
DataFormatConverters.DataFormatConverter.toExternal(BaseRow row,
int column)
Given a internalType row, convert the value at column `column` to its external(Java) equivalent.
|
static String |
BinaryRow.toOriginString(BaseRow row,
LogicalType[] types) |
void |
AbstractBinaryWriter.writeRow(int pos,
BaseRow input,
BaseRowSerializer serializer) |
void |
BinaryWriter.writeRow(int pos,
BaseRow value,
BaseRowSerializer type) |
Constructor and Description |
---|
JoinedRow(BaseRow row1,
BaseRow row2) |
UpdatableRow(BaseRow row,
int arity) |
Modifier and Type | Method and Description |
---|---|
static BaseRow |
BaseRowUtil.setAccumulate(BaseRow baseRow) |
static BaseRow |
BaseRowUtil.setRetract(BaseRow baseRow) |
Modifier and Type | Method and Description |
---|---|
static boolean |
BaseRowUtil.isAccumulateMsg(BaseRow baseRow) |
static boolean |
BaseRowUtil.isRetractMsg(BaseRow baseRow) |
static BaseRow |
BaseRowUtil.setAccumulate(BaseRow baseRow) |
static BaseRow |
BaseRowUtil.setRetract(BaseRow baseRow) |
static GenericRow |
BaseRowUtil.toGenericRow(BaseRow baseRow,
LogicalType[] types) |
Modifier and Type | Method and Description |
---|---|
BaseRow |
ExecutionContextImpl.currentKey() |
BaseRow |
ExecutionContext.currentKey() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionContextImpl.setCurrentKey(BaseRow key) |
void |
ExecutionContext.setCurrentKey(BaseRow key)
Sets current key.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Projection<IN extends BaseRow,OUT extends BaseRow>
Interface for code generated projection, which will map a BaseRow to another one.
|
interface |
Projection<IN extends BaseRow,OUT extends BaseRow>
Interface for code generated projection, which will map a BaseRow to another one.
|
Modifier and Type | Method and Description |
---|---|
BaseRow |
NamespaceAggsHandleFunction.createAccumulators()
Initializes the accumulators and save them to a accumulators row.
|
BaseRow |
AggsHandleFunction.createAccumulators()
Initializes the accumulators and save them to a accumulators row.
|
BaseRow |
NamespaceAggsHandleFunction.getAccumulators()
Gets the current accumulators (saved in a row) which contains the current
aggregated results.
|
BaseRow |
AggsHandleFunction.getAccumulators()
Gets the current accumulators (saved in a row) which contains the current
aggregated results.
|
BaseRow |
AggsHandleFunction.getValue()
Gets the result of the aggregation from the current accumulators.
|
BaseRow |
NamespaceAggsHandleFunction.getValue(N namespace)
Gets the result of the aggregation from the current accumulators and
namespace properties (like window start).
|
Modifier and Type | Method and Description |
---|---|
void |
NamespaceAggsHandleFunction.accumulate(BaseRow inputRow)
Accumulates the input values to the accumulators.
|
void |
AggsHandleFunction.accumulate(BaseRow input)
Accumulates the input values to the accumulators.
|
boolean |
JoinCondition.apply(BaseRow in1,
BaseRow in2) |
int |
RecordComparator.compare(BaseRow o1,
BaseRow o2) |
boolean |
RecordEqualiser.equals(BaseRow row1,
BaseRow row2)
Returns
true if the rows are equal to each other
and false otherwise. |
boolean |
RecordEqualiser.equalsWithoutHeader(BaseRow row1,
BaseRow row2)
Returns
true if the rows are equal to each other without header compare
and false otherwise. |
int |
HashFunction.hashCode(BaseRow row) |
void |
AggsHandleFunction.merge(BaseRow accumulators)
Merges the other accumulators into current accumulators.
|
void |
NamespaceAggsHandleFunction.merge(N namespace,
BaseRow otherAcc)
Merges the other accumulators into current accumulators.
|
void |
NormalizedKeyComputer.putKey(BaseRow record,
MemorySegment target,
int offset)
Writes a normalized key for the given record into the target
MemorySegment . |
void |
NamespaceAggsHandleFunction.retract(BaseRow inputRow)
Retracts the input values from the accumulators.
|
void |
AggsHandleFunction.retract(BaseRow input)
Retracts the input values from the accumulators.
|
void |
AggsHandleFunction.setAccumulators(BaseRow accumulators)
Set the current accumulators (saved in a row) which contains the current aggregated results.
|
void |
NamespaceAggsHandleFunction.setAccumulators(N namespace,
BaseRow accumulators)
Set the current accumulators (saved in a row) which contains the current
aggregated results.
|
Modifier and Type | Class and Description |
---|---|
class |
WrappedRowIterator<T extends BaseRow>
Wrap
MutableObjectIterator to java RowIterator . |
Modifier and Type | Method and Description |
---|---|
BaseRow |
ProbeIterator.current() |
BaseRow |
BinaryHashTable.getCurrentProbeRow() |
BaseRow |
LongHybridHashTable.getCurrentProbeRow() |
Modifier and Type | Method and Description |
---|---|
abstract long |
LongHybridHashTable.getBuildLongKey(BaseRow row)
For code gen get build side long key.
|
abstract long |
LongHybridHashTable.getProbeLongKey(BaseRow row)
For code gen get probe side long key.
|
abstract BinaryRow |
LongHybridHashTable.probeToBinary(BaseRow row)
For code gen probe side to BinaryRow.
|
void |
BinaryHashTable.putBuildRow(BaseRow row)
Put a build side row to hash table.
|
void |
ProbeIterator.setInstance(BaseRow instance) |
boolean |
BinaryHashTable.tryProbe(BaseRow record)
Find matched build side rows for a probe row.
|
boolean |
LongHybridHashTable.tryProbe(BaseRow record) |
Constructor and Description |
---|
BinaryHashTable(Configuration conf,
Object owner,
AbstractRowSerializer buildSideSerializer,
AbstractRowSerializer probeSideSerializer,
Projection<BaseRow,BinaryRow> buildSideProjection,
Projection<BaseRow,BinaryRow> probeSideProjection,
MemoryManager memManager,
long reservedMemorySize,
IOManager ioManager,
int avgRecordLen,
int buildRowCount,
boolean useBloomFilters,
HashJoinType type,
JoinCondition condFunc,
boolean reverseJoin,
boolean[] filterNulls,
boolean tryDistinctBuildRow) |
BinaryHashTable(Configuration conf,
Object owner,
AbstractRowSerializer buildSideSerializer,
AbstractRowSerializer probeSideSerializer,
Projection<BaseRow,BinaryRow> buildSideProjection,
Projection<BaseRow,BinaryRow> probeSideProjection,
MemoryManager memManager,
long reservedMemorySize,
IOManager ioManager,
int avgRecordLen,
int buildRowCount,
boolean useBloomFilters,
HashJoinType type,
JoinCondition condFunc,
boolean reverseJoin,
boolean[] filterNulls,
boolean tryDistinctBuildRow) |
BinaryHashTable(Configuration conf,
Object owner,
AbstractRowSerializer buildSideSerializer,
AbstractRowSerializer probeSideSerializer,
Projection<BaseRow,BinaryRow> buildSideProjection,
Projection<BaseRow,BinaryRow> probeSideProjection,
MemoryManager memManager,
long reservedMemorySize,
long preferredMemorySize,
long perRequestMemorySize,
IOManager ioManager,
int avgRecordLen,
long buildRowCount,
boolean useBloomFilters,
HashJoinType type,
JoinCondition condFunc,
boolean reverseJoin,
boolean[] filterNulls,
boolean tryDistinctBuildRow) |
BinaryHashTable(Configuration conf,
Object owner,
AbstractRowSerializer buildSideSerializer,
AbstractRowSerializer probeSideSerializer,
Projection<BaseRow,BinaryRow> buildSideProjection,
Projection<BaseRow,BinaryRow> probeSideProjection,
MemoryManager memManager,
long reservedMemorySize,
long preferredMemorySize,
long perRequestMemorySize,
IOManager ioManager,
int avgRecordLen,
long buildRowCount,
boolean useBloomFilters,
HashJoinType type,
JoinCondition condFunc,
boolean reverseJoin,
boolean[] filterNulls,
boolean tryDistinctBuildRow) |
Modifier and Type | Method and Description |
---|---|
BaseRow |
BinaryRowKeySelector.getKey(BaseRow value) |
BaseRow |
NullBinaryRowKeySelector.getKey(BaseRow value) |
Modifier and Type | Method and Description |
---|---|
BaseRow |
BinaryRowKeySelector.getKey(BaseRow value) |
BaseRow |
NullBinaryRowKeySelector.getKey(BaseRow value) |
Modifier and Type | Method and Description |
---|---|
BaseRow |
MiniBatchGlobalGroupAggFunction.addInput(BaseRow previousAcc,
BaseRow input)
The
previousAcc is accumulator, but input is a row in <key, accumulator> schema,
the specific generated MiniBatchGlobalGroupAggFunction.localAgg will project the input to accumulator
in merge method. |
BaseRow |
MiniBatchIncrementalGroupAggFunction.addInput(BaseRow previousAcc,
BaseRow input) |
BaseRow |
MiniBatchLocalGroupAggFunction.addInput(BaseRow previousAcc,
BaseRow input) |
Modifier and Type | Method and Description |
---|---|
List<BaseRow> |
MiniBatchGroupAggFunction.addInput(List<BaseRow> value,
BaseRow input) |
Modifier and Type | Method and Description |
---|---|
BaseRow |
MiniBatchGlobalGroupAggFunction.addInput(BaseRow previousAcc,
BaseRow input)
The
previousAcc is accumulator, but input is a row in <key, accumulator> schema,
the specific generated MiniBatchGlobalGroupAggFunction.localAgg will project the input to accumulator
in merge method. |
BaseRow |
MiniBatchIncrementalGroupAggFunction.addInput(BaseRow previousAcc,
BaseRow input) |
BaseRow |
MiniBatchLocalGroupAggFunction.addInput(BaseRow previousAcc,
BaseRow input) |
List<BaseRow> |
MiniBatchGroupAggFunction.addInput(List<BaseRow> value,
BaseRow input) |
void |
GroupAggFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
Modifier and Type | Method and Description |
---|---|
List<BaseRow> |
MiniBatchGroupAggFunction.addInput(List<BaseRow> value,
BaseRow input) |
void |
MiniBatchGlobalGroupAggFunction.finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out) |
void |
MiniBatchGlobalGroupAggFunction.finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out) |
void |
MiniBatchGlobalGroupAggFunction.finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out) |
void |
MiniBatchIncrementalGroupAggFunction.finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out) |
void |
MiniBatchIncrementalGroupAggFunction.finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out) |
void |
MiniBatchIncrementalGroupAggFunction.finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out) |
void |
MiniBatchLocalGroupAggFunction.finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out) |
void |
MiniBatchLocalGroupAggFunction.finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out) |
void |
MiniBatchLocalGroupAggFunction.finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out) |
void |
MiniBatchGroupAggFunction.finishBundle(Map<BaseRow,List<BaseRow>> buffer,
Collector<BaseRow> out) |
void |
MiniBatchGroupAggFunction.finishBundle(Map<BaseRow,List<BaseRow>> buffer,
Collector<BaseRow> out) |
void |
MiniBatchGroupAggFunction.finishBundle(Map<BaseRow,List<BaseRow>> buffer,
Collector<BaseRow> out) |
void |
GroupAggFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<BaseRow> out) |
void |
GroupAggFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
Constructor and Description |
---|
MiniBatchIncrementalGroupAggFunction(GeneratedAggsHandleFunction genPartialAggsHandler,
GeneratedAggsHandleFunction genFinalAggsHandler,
KeySelector<BaseRow,BaseRow> finalKeySelector) |
MiniBatchIncrementalGroupAggFunction(GeneratedAggsHandleFunction genPartialAggsHandler,
GeneratedAggsHandleFunction genFinalAggsHandler,
KeySelector<BaseRow,BaseRow> finalKeySelector) |
Modifier and Type | Method and Description |
---|---|
BaseRow |
MiniBatchDeduplicateKeepFirstRowFunction.addInput(BaseRow value,
BaseRow input) |
BaseRow |
MiniBatchDeduplicateKeepLastRowFunction.addInput(BaseRow value,
BaseRow input) |
Modifier and Type | Method and Description |
---|---|
BaseRow |
MiniBatchDeduplicateKeepFirstRowFunction.addInput(BaseRow value,
BaseRow input) |
BaseRow |
MiniBatchDeduplicateKeepLastRowFunction.addInput(BaseRow value,
BaseRow input) |
void |
DeduplicateKeepFirstRowFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
void |
DeduplicateKeepLastRowFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
Modifier and Type | Method and Description |
---|---|
void |
MiniBatchDeduplicateKeepFirstRowFunction.finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out) |
void |
MiniBatchDeduplicateKeepFirstRowFunction.finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out) |
void |
MiniBatchDeduplicateKeepFirstRowFunction.finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out) |
void |
MiniBatchDeduplicateKeepLastRowFunction.finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out) |
void |
MiniBatchDeduplicateKeepLastRowFunction.finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out) |
void |
MiniBatchDeduplicateKeepLastRowFunction.finishBundle(Map<BaseRow,BaseRow> buffer,
Collector<BaseRow> out) |
void |
DeduplicateKeepFirstRowFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<BaseRow> out) |
void |
DeduplicateKeepLastRowFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<BaseRow> out) |
void |
DeduplicateKeepFirstRowFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
void |
DeduplicateKeepLastRowFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
Constructor and Description |
---|
MiniBatchDeduplicateKeepFirstRowFunction(TypeSerializer<BaseRow> typeSerializer) |
MiniBatchDeduplicateKeepLastRowFunction(BaseRowTypeInfo rowTypeInfo,
boolean generateRetraction,
TypeSerializer<BaseRow> typeSerializer) |
Modifier and Type | Method and Description |
---|---|
BaseRow |
SortMergeJoinIterator.getProbeRow() |
BaseRow |
OuterJoinPaddingUtil.padLeft(BaseRow leftRow)
Returns a padding result with the given left row.
|
BaseRow |
OuterJoinPaddingUtil.padRight(BaseRow rightRow)
Returns a padding result with the given right row.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
HashJoinOperator.join(RowIterator<BinaryRow> buildIter,
BaseRow probeRow) |
BaseRow |
OuterJoinPaddingUtil.padLeft(BaseRow leftRow)
Returns a padding result with the given left row.
|
BaseRow |
OuterJoinPaddingUtil.padRight(BaseRow rightRow)
Returns a padding result with the given right row.
|
Modifier and Type | Method and Description |
---|---|
void |
SortMergeJoinOperator.processElement1(StreamRecord<BaseRow> element) |
void |
HashJoinOperator.processElement1(StreamRecord<BaseRow> element) |
void |
SortMergeJoinOperator.processElement2(StreamRecord<BaseRow> element) |
void |
HashJoinOperator.processElement2(StreamRecord<BaseRow> element) |
Modifier and Type | Field and Description |
---|---|
protected TableFunctionCollector<BaseRow> |
LookupJoinRunner.collector |
Modifier and Type | Method and Description |
---|---|
TableFunctionResultFuture<BaseRow> |
AsyncLookupJoinWithCalcRunner.createFetcherResultFuture(Configuration parameters) |
TableFunctionResultFuture<BaseRow> |
AsyncLookupJoinRunner.createFetcherResultFuture(Configuration parameters) |
Collector<BaseRow> |
LookupJoinRunner.getFetcherCollector() |
Collector<BaseRow> |
LookupJoinWithCalcRunner.getFetcherCollector() |
Modifier and Type | Method and Description |
---|---|
void |
AsyncLookupJoinRunner.asyncInvoke(BaseRow input,
ResultFuture<BaseRow> resultFuture) |
void |
LookupJoinRunner.processElement(BaseRow in,
ProcessFunction.Context ctx,
Collector<BaseRow> out) |
Modifier and Type | Method and Description |
---|---|
void |
AsyncLookupJoinRunner.asyncInvoke(BaseRow input,
ResultFuture<BaseRow> resultFuture) |
void |
LookupJoinRunner.processElement(BaseRow in,
ProcessFunction.Context ctx,
Collector<BaseRow> out) |
Modifier and Type | Field and Description |
---|---|
BaseRow |
AbstractStreamingJoinOperator.OuterRecord.record |
Modifier and Type | Field and Description |
---|---|
protected TimestampedCollector<BaseRow> |
AbstractStreamingJoinOperator.collector |
Modifier and Type | Method and Description |
---|---|
Iterable<BaseRow> |
AbstractStreamingJoinOperator.AssociatedRecords.getRecords()
Gets the iterable of records.
|
Modifier and Type | Method and Description |
---|---|
static AbstractStreamingJoinOperator.AssociatedRecords |
AbstractStreamingJoinOperator.AssociatedRecords.of(BaseRow input,
boolean inputIsLeft,
JoinRecordStateView otherSideStateView,
JoinCondition condition)
Creates an
AbstractStreamingJoinOperator.AssociatedRecords which represents the records associated to the
input row. |
Modifier and Type | Method and Description |
---|---|
void |
StreamingSemiAntiJoinOperator.processElement1(StreamRecord<BaseRow> element)
Process an input element and output incremental joined records, retraction messages will
be sent in some scenarios.
|
void |
StreamingJoinOperator.processElement1(StreamRecord<BaseRow> element) |
void |
StreamingSemiAntiJoinOperator.processElement2(StreamRecord<BaseRow> element)
Process an input element and output incremental joined records, retraction messages will
be sent in some scenarios.
|
void |
StreamingJoinOperator.processElement2(StreamRecord<BaseRow> element) |
Modifier and Type | Method and Description |
---|---|
Iterable<BaseRow> |
JoinRecordStateView.getRecords()
Gets all the records under the current context (i.e.
|
Iterable<Tuple2<BaseRow,Integer>> |
OuterJoinRecordStateView.getRecordsAndNumOfAssociations()
Gets all the records and number of associations under the current context (i.e.
|
KeySelector<BaseRow,BaseRow> |
JoinInputSideSpec.getUniqueKeySelector()
Returns the
KeySelector to extract unique key from the input row. |
KeySelector<BaseRow,BaseRow> |
JoinInputSideSpec.getUniqueKeySelector()
Returns the
KeySelector to extract unique key from the input row. |
Modifier and Type | Method and Description |
---|---|
void |
JoinRecordStateView.addRecord(BaseRow record)
Add a new record to the state view.
|
void |
OuterJoinRecordStateView.addRecord(BaseRow record,
int numOfAssociations)
Adds a new record with the number of associations to the state view.
|
void |
JoinRecordStateView.retractRecord(BaseRow record)
Retract the record from the state view.
|
void |
OuterJoinRecordStateView.updateNumOfAssociations(BaseRow record,
int numOfAssociations)
Updates the number of associations belongs to the record.
|
Modifier and Type | Method and Description |
---|---|
static JoinInputSideSpec |
JoinInputSideSpec.withUniqueKey(BaseRowTypeInfo uniqueKeyType,
KeySelector<BaseRow,BaseRow> uniqueKeySelector)
Creates a
JoinInputSideSpec that the input has an unique key. |
static JoinInputSideSpec |
JoinInputSideSpec.withUniqueKey(BaseRowTypeInfo uniqueKeyType,
KeySelector<BaseRow,BaseRow> uniqueKeySelector)
Creates a
JoinInputSideSpec that the input has an unique key. |
static JoinInputSideSpec |
JoinInputSideSpec.withUniqueKeyContainedByJoinKey(BaseRowTypeInfo uniqueKeyType,
KeySelector<BaseRow,BaseRow> uniqueKeySelector)
Creates a
JoinInputSideSpec that input has an unique key and the unique key is
contained by the join key. |
static JoinInputSideSpec |
JoinInputSideSpec.withUniqueKeyContainedByJoinKey(BaseRowTypeInfo uniqueKeyType,
KeySelector<BaseRow,BaseRow> uniqueKeySelector)
Creates a
JoinInputSideSpec that input has an unique key and the unique key is
contained by the join key. |
Modifier and Type | Method and Description |
---|---|
void |
TemporalRowTimeJoinOperator.processElement1(StreamRecord<BaseRow> element) |
void |
TemporalProcessTimeJoinOperator.processElement1(StreamRecord<BaseRow> element) |
void |
TemporalRowTimeJoinOperator.processElement2(StreamRecord<BaseRow> element) |
void |
TemporalProcessTimeJoinOperator.processElement2(StreamRecord<BaseRow> element) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<BaseRow> |
RowtimeProcessFunction.getProducedType() |
Modifier and Type | Method and Description |
---|---|
int |
BaseRowEventComparator.compare(BaseRow row1,
BaseRow row2) |
boolean |
IterativeConditionRunner.filter(BaseRow value,
IterativeCondition.Context<BaseRow> ctx) |
void |
RowtimeProcessFunction.processElement(BaseRow value,
ProcessFunction.Context ctx,
Collector<BaseRow> out) |
Modifier and Type | Method and Description |
---|---|
boolean |
IterativeConditionRunner.filter(BaseRow value,
IterativeCondition.Context<BaseRow> ctx) |
void |
RowtimeProcessFunction.processElement(BaseRow value,
ProcessFunction.Context ctx,
Collector<BaseRow> out) |
void |
PatternProcessFunctionRunner.processMatch(Map<String,List<BaseRow>> match,
PatternProcessFunction.Context ctx,
Collector<BaseRow> out) |
void |
PatternProcessFunctionRunner.processMatch(Map<String,List<BaseRow>> match,
PatternProcessFunction.Context ctx,
Collector<BaseRow> out) |
Constructor and Description |
---|
IterativeConditionRunner(GeneratedFunction<RichIterativeCondition<BaseRow>> generatedFunction) |
PatternProcessFunctionRunner(GeneratedFunction<PatternProcessFunction<BaseRow,BaseRow>> generatedFunction) |
PatternProcessFunctionRunner(GeneratedFunction<PatternProcessFunction<BaseRow,BaseRow>> generatedFunction) |
RowtimeProcessFunction(int rowtimeIdx,
TypeInformation<BaseRow> returnType) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractRowTimeUnboundedPrecedingOver.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out)
Puts an element from the input stream into state if it is not late.
|
void |
ProcTimeRangeBoundedPrecedingFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
void |
ProcTimeRowsBoundedPrecedingFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
void |
RowTimeRangeBoundedPrecedingFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
void |
RowTimeRowsBoundedPrecedingFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
void |
ProcTimeUnboundedPrecedingFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractRowTimeUnboundedPrecedingOver.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<BaseRow> out) |
void |
ProcTimeRangeBoundedPrecedingFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<BaseRow> out) |
void |
ProcTimeRowsBoundedPrecedingFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<BaseRow> out) |
void |
RowTimeRangeBoundedPrecedingFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<BaseRow> out) |
void |
RowTimeRowsBoundedPrecedingFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<BaseRow> out) |
void |
ProcTimeUnboundedPrecedingFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<BaseRow> out) |
void |
AbstractRowTimeUnboundedPrecedingOver.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out)
Puts an element from the input stream into state if it is not late.
|
void |
ProcTimeRangeBoundedPrecedingFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
void |
ProcTimeRowsBoundedPrecedingFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
void |
RowTimeRangeBoundedPrecedingFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
void |
RowTimeRowsBoundedPrecedingFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
void |
ProcTimeUnboundedPrecedingFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
void |
NonBufferOverWindowOperator.processElement(StreamRecord<BaseRow> element) |
void |
BufferDataOverWindowOperator.processElement(StreamRecord<BaseRow> element) |
protected abstract void |
AbstractRowTimeUnboundedPrecedingOver.processElementsWithSameTimestamp(List<BaseRow> curRowList,
Collector<BaseRow> out)
Process the same timestamp datas, the mechanism is different between
rows and range window.
|
protected abstract void |
AbstractRowTimeUnboundedPrecedingOver.processElementsWithSameTimestamp(List<BaseRow> curRowList,
Collector<BaseRow> out)
Process the same timestamp datas, the mechanism is different between
rows and range window.
|
void |
RowTimeRowsUnboundedPrecedingFunction.processElementsWithSameTimestamp(List<BaseRow> curRowList,
Collector<BaseRow> out) |
void |
RowTimeRowsUnboundedPrecedingFunction.processElementsWithSameTimestamp(List<BaseRow> curRowList,
Collector<BaseRow> out) |
void |
RowTimeRangeUnboundedPrecedingFunction.processElementsWithSameTimestamp(List<BaseRow> curRowList,
Collector<BaseRow> out) |
void |
RowTimeRangeUnboundedPrecedingFunction.processElementsWithSameTimestamp(List<BaseRow> curRowList,
Collector<BaseRow> out) |
Modifier and Type | Method and Description |
---|---|
BaseRow |
RowSlidingOverFrame.process(int index,
BaseRow current) |
BaseRow |
RowUnboundedFollowingOverFrame.process(int index,
BaseRow current) |
BaseRow |
OverWindowFrame.process(int index,
BaseRow current)
return the ACC of the window frame.
|
BaseRow |
RangeUnboundedFollowingOverFrame.process(int index,
BaseRow current) |
BaseRow |
UnboundedOverWindowFrame.process(int index,
BaseRow current) |
BaseRow |
RowUnboundedPrecedingOverFrame.process(int index,
BaseRow current) |
BaseRow |
InsensitiveOverFrame.process(int index,
BaseRow current) |
BaseRow |
RangeUnboundedPrecedingOverFrame.process(int index,
BaseRow current) |
BaseRow |
OffsetOverFrame.process(int index,
BaseRow current) |
BaseRow |
RangeSlidingOverFrame.process(int index,
BaseRow current) |
Modifier and Type | Method and Description |
---|---|
long |
OffsetOverFrame.CalcOffsetFunc.calc(BaseRow row) |
BaseRow |
RowSlidingOverFrame.process(int index,
BaseRow current) |
BaseRow |
RowUnboundedFollowingOverFrame.process(int index,
BaseRow current) |
BaseRow |
OverWindowFrame.process(int index,
BaseRow current)
return the ACC of the window frame.
|
BaseRow |
RangeUnboundedFollowingOverFrame.process(int index,
BaseRow current) |
BaseRow |
UnboundedOverWindowFrame.process(int index,
BaseRow current) |
BaseRow |
RowUnboundedPrecedingOverFrame.process(int index,
BaseRow current) |
BaseRow |
InsensitiveOverFrame.process(int index,
BaseRow current) |
BaseRow |
RangeUnboundedPrecedingOverFrame.process(int index,
BaseRow current) |
BaseRow |
OffsetOverFrame.process(int index,
BaseRow current) |
BaseRow |
RangeSlidingOverFrame.process(int index,
BaseRow current) |
Modifier and Type | Field and Description |
---|---|
protected Comparator<BaseRow> |
AbstractTopNFunction.sortKeyComparator |
protected KeySelector<BaseRow,BaseRow> |
AbstractTopNFunction.sortKeySelector |
protected KeySelector<BaseRow,BaseRow> |
AbstractTopNFunction.sortKeySelector |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractTopNFunction.checkSortKeyInBufferRange(BaseRow sortKey,
org.apache.flink.table.runtime.operators.rank.TopNBuffer buffer)
Checks whether the record should be put into the buffer.
|
protected void |
AbstractTopNFunction.collect(Collector<BaseRow> out,
BaseRow inputRow) |
protected void |
AbstractTopNFunction.collect(Collector<BaseRow> out,
BaseRow inputRow,
long rank) |
protected void |
AbstractTopNFunction.delete(Collector<BaseRow> out,
BaseRow inputRow)
This is similar to [[retract()]] but always send retraction message regardless of generateRetraction is true or
not.
|
protected void |
AbstractTopNFunction.delete(Collector<BaseRow> out,
BaseRow inputRow,
long rank)
This is with-row-number version of above delete() method.
|
protected long |
AbstractTopNFunction.initRankEnd(BaseRow row)
Initialize rank end.
|
void |
AppendOnlyTopNFunction.processElement(BaseRow input,
KeyedProcessFunction.Context context,
Collector<BaseRow> out) |
void |
UpdatableTopNFunction.processElement(BaseRow input,
KeyedProcessFunction.Context context,
Collector<BaseRow> out) |
void |
RetractableTopNFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
protected void |
AbstractTopNFunction.retract(Collector<BaseRow> out,
BaseRow inputRow,
long rank) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractTopNFunction.collect(Collector<BaseRow> out,
BaseRow inputRow) |
protected void |
AbstractTopNFunction.collect(Collector<BaseRow> out,
BaseRow inputRow,
long rank) |
protected void |
AbstractTopNFunction.delete(Collector<BaseRow> out,
BaseRow inputRow)
This is similar to [[retract()]] but always send retraction message regardless of generateRetraction is true or
not.
|
protected void |
AbstractTopNFunction.delete(Collector<BaseRow> out,
BaseRow inputRow,
long rank)
This is with-row-number version of above delete() method.
|
void |
AppendOnlyTopNFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<BaseRow> out) |
void |
UpdatableTopNFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<BaseRow> out) |
void |
RetractableTopNFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<BaseRow> out) |
void |
AppendOnlyTopNFunction.processElement(BaseRow input,
KeyedProcessFunction.Context context,
Collector<BaseRow> out) |
void |
UpdatableTopNFunction.processElement(BaseRow input,
KeyedProcessFunction.Context context,
Collector<BaseRow> out) |
void |
RetractableTopNFunction.processElement(BaseRow input,
KeyedProcessFunction.Context ctx,
Collector<BaseRow> out) |
protected void |
AbstractTopNFunction.retract(Collector<BaseRow> out,
BaseRow inputRow,
long rank) |
Modifier and Type | Method and Description |
---|---|
void |
BinaryExternalSorter.write(BaseRow current) |
boolean |
BinaryInMemorySortBuffer.write(BaseRow record)
Writes a given record to this sort buffer.
|
protected void |
BinaryIndexedSortable.writeIndexAndNormalizedKey(BaseRow record,
long currOffset)
Write of index and normalizedKey.
|
Modifier and Type | Method and Description |
---|---|
static BinaryInMemorySortBuffer |
BinaryInMemorySortBuffer.createBuffer(NormalizedKeyComputer normalizedKeyComputer,
AbstractRowSerializer<BaseRow> inputSerializer,
BinaryRowSerializer serializer,
RecordComparator comparator,
List<MemorySegment> memory)
Create a memory sorter in `insert` way.
|
void |
ProcTimeSortOperator.onEventTime(InternalTimer<BaseRow,VoidNamespace> timer) |
void |
RowTimeSortOperator.onEventTime(InternalTimer<BaseRow,VoidNamespace> timer) |
void |
ProcTimeSortOperator.onProcessingTime(InternalTimer<BaseRow,VoidNamespace> timer) |
void |
RowTimeSortOperator.onProcessingTime(InternalTimer<BaseRow,VoidNamespace> timer) |
void |
LimitOperator.processElement(StreamRecord<BaseRow> element) |
void |
ProcTimeSortOperator.processElement(StreamRecord<BaseRow> element) |
void |
RankOperator.processElement(StreamRecord<BaseRow> element) |
void |
SortOperator.processElement(StreamRecord<BaseRow> element) |
void |
StreamSortOperator.processElement(StreamRecord<BaseRow> element) |
void |
SortLimitOperator.processElement(StreamRecord<BaseRow> element) |
void |
RowTimeSortOperator.processElement(StreamRecord<BaseRow> element) |
Constructor and Description |
---|
BinaryExternalSorter(Object owner,
MemoryManager memoryManager,
long reservedMemorySize,
IOManager ioManager,
AbstractRowSerializer<BaseRow> inputSerializer,
BinaryRowSerializer serializer,
NormalizedKeyComputer normalizedKeyComputer,
RecordComparator comparator,
Configuration conf) |
BinaryExternalSorter(Object owner,
MemoryManager memoryManager,
long reservedMemorySize,
IOManager ioManager,
AbstractRowSerializer<BaseRow> inputSerializer,
BinaryRowSerializer serializer,
NormalizedKeyComputer normalizedKeyComputer,
RecordComparator comparator,
Configuration conf,
float startSpillingFraction) |
Modifier and Type | Method and Description |
---|---|
BaseRow |
ValuesInputFormat.nextRecord(BaseRow reuse) |
Modifier and Type | Method and Description |
---|---|
BaseRow |
ValuesInputFormat.nextRecord(BaseRow reuse) |
Constructor and Description |
---|
ValuesInputFormat(GeneratedInput<GenericInputFormat<BaseRow>> generatedInput,
BaseRowTypeInfo returnType) |
Modifier and Type | Method and Description |
---|---|
void |
WindowOperator.processElement(StreamRecord<BaseRow> record) |
Modifier and Type | Method and Description |
---|---|
abstract Collection<W> |
WindowAssigner.assignWindows(BaseRow element,
long timestamp)
Given the timestamp and element, returns the set of windows into which it
should be placed.
|
Collection<CountWindow> |
CountSlidingWindowAssigner.assignWindows(BaseRow element,
long timestamp) |
Collection<TimeWindow> |
SessionWindowAssigner.assignWindows(BaseRow element,
long timestamp) |
Collection<CountWindow> |
CountTumblingWindowAssigner.assignWindows(BaseRow element,
long timestamp) |
Collection<TimeWindow> |
SlidingWindowAssigner.assignWindows(BaseRow element,
long timestamp) |
Collection<TimeWindow> |
TumblingWindowAssigner.assignWindows(BaseRow element,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
BaseRow |
InternalWindowProcessFunction.Context.getWindowAccumulators(W window)
Gets the accumulators of the given window.
|
BaseRow |
MergingWindowProcessFunction.getWindowAggregationResult(W window) |
BaseRow |
PanedWindowProcessFunction.getWindowAggregationResult(W window) |
abstract BaseRow |
InternalWindowProcessFunction.getWindowAggregationResult(W window)
Gets the aggregation result and window properties of the given window.
|
BaseRow |
GeneralWindowProcessFunction.getWindowAggregationResult(W window) |
Modifier and Type | Method and Description |
---|---|
Collection<W> |
MergingWindowProcessFunction.assignActualWindows(BaseRow inputRow,
long timestamp) |
Collection<W> |
PanedWindowProcessFunction.assignActualWindows(BaseRow inputRow,
long timestamp) |
abstract Collection<W> |
InternalWindowProcessFunction.assignActualWindows(BaseRow inputRow,
long timestamp)
Assigns the input element into the actual windows which the
Trigger should trigger
on. |
Collection<W> |
GeneralWindowProcessFunction.assignActualWindows(BaseRow inputRow,
long timestamp) |
Collection<W> |
MergingWindowProcessFunction.assignStateNamespace(BaseRow inputRow,
long timestamp) |
Collection<W> |
PanedWindowProcessFunction.assignStateNamespace(BaseRow inputRow,
long timestamp) |
abstract Collection<W> |
InternalWindowProcessFunction.assignStateNamespace(BaseRow inputRow,
long timestamp)
Assigns the input element into the state namespace which the input element should be
accumulated/retracted into.
|
Collection<W> |
GeneralWindowProcessFunction.assignStateNamespace(BaseRow inputRow,
long timestamp) |
void |
InternalWindowProcessFunction.Context.setWindowAccumulators(W window,
BaseRow acc)
Sets the accumulators of the given window.
|
Modifier and Type | Method and Description |
---|---|
void |
WatermarkAssignerOperator.processElement(StreamRecord<BaseRow> element) |
void |
MiniBatchAssignerOperator.processElement(StreamRecord<BaseRow> element) |
void |
MiniBatchedWatermarkAssignerOperator.processElement(StreamRecord<BaseRow> element) |
Modifier and Type | Method and Description |
---|---|
StreamPartitioner<BaseRow> |
BinaryHashPartitioner.copy() |
Modifier and Type | Method and Description |
---|---|
int |
BinaryHashPartitioner.selectChannel(SerializationDelegate<StreamRecord<BaseRow>> record) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRowSerializer<T extends BaseRow>
Row serializer, provided paged serialize paged method.
|
Modifier and Type | Method and Description |
---|---|
BaseRow |
BaseRowSerializer.copy(BaseRow from) |
BaseRow |
BaseRowSerializer.copy(BaseRow from,
BaseRow reuse) |
BaseRow |
BaseRowSerializer.createInstance() |
BaseRow |
BaseRowSerializer.deserialize(BaseRow reuse,
DataInputView source) |
BaseRow |
BaseRowSerializer.deserialize(DataInputView source) |
BaseRow |
BaseRowSerializer.deserializeFromPages(AbstractPagedInputView source) |
BaseRow |
BaseRowSerializer.deserializeFromPages(BaseRow reuse,
AbstractPagedInputView source) |
BaseRow |
BaseRowSerializer.mapFromPages(AbstractPagedInputView source) |
BaseRow |
BaseRowSerializer.mapFromPages(BaseRow reuse,
AbstractPagedInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeComparator<BaseRow> |
BaseRowTypeInfo.createComparator(int[] logicalKeyFields,
boolean[] orders,
int logicalFieldOffset,
ExecutionConfig config) |
CompositeType.TypeComparatorBuilder<BaseRow> |
BaseRowTypeInfo.createTypeComparatorBuilder() |
TypeSerializer<BaseRow> |
BaseRowSerializer.duplicate() |
TypeSerializerSchemaCompatibility<BaseRow> |
BaseRowSerializer.BaseRowSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<BaseRow> newSerializer) |
TypeSerializerSnapshot<BaseRow> |
BaseRowSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
BaseRow |
BaseRowSerializer.copy(BaseRow from) |
BaseRow |
BaseRowSerializer.copy(BaseRow from,
BaseRow reuse) |
BaseRow |
BaseRowSerializer.deserialize(BaseRow reuse,
DataInputView source) |
BaseRow |
BaseRowSerializer.deserializeFromPages(BaseRow reuse,
AbstractPagedInputView source) |
BaseRow |
BaseRowSerializer.mapFromPages(BaseRow reuse,
AbstractPagedInputView source) |
void |
BaseRowSerializer.serialize(BaseRow row,
DataOutputView target) |
int |
BaseRowSerializer.serializeToPages(BaseRow row,
AbstractPagedOutputView target) |
BinaryRow |
BaseRowSerializer.toBinaryRow(BaseRow row)
Convert base row to binary row.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<BaseRow> |
BaseRowSerializer.BaseRowSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<BaseRow> newSerializer) |
Modifier and Type | Interface and Description |
---|---|
interface |
RowIterator<T extends BaseRow>
An internal iterator interface which presents a more restrictive API than
Iterator . |
Modifier and Type | Method and Description |
---|---|
void |
ResettableExternalBuffer.add(BaseRow row) |
void |
ResettableRowBuffer.add(BaseRow row)
Appends the specified row to the end of this buffer.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.