Package | Description |
---|---|
org.apache.flink.table.runtime.operators.join.window |
Modifier and Type | Method and Description |
---|---|
static WindowJoinOperatorBuilder |
WindowJoinOperatorBuilder.builder() |
WindowJoinOperatorBuilder |
WindowJoinOperatorBuilder.filterNullKeys(boolean[] filterNullKeys) |
WindowJoinOperatorBuilder |
WindowJoinOperatorBuilder.generatedJoinCondition(GeneratedJoinCondition generatedJoinCondition) |
WindowJoinOperatorBuilder |
WindowJoinOperatorBuilder.joinType(FlinkJoinType joinType) |
WindowJoinOperatorBuilder |
WindowJoinOperatorBuilder.leftSerializer(TypeSerializer<RowData> leftSerializer) |
WindowJoinOperatorBuilder |
WindowJoinOperatorBuilder.leftWindowEndIndex(int leftWindowEndIndex) |
WindowJoinOperatorBuilder |
WindowJoinOperatorBuilder.rightSerializer(TypeSerializer<RowData> rightSerializer) |
WindowJoinOperatorBuilder |
WindowJoinOperatorBuilder.rightWindowEndIndex(int rightWindowEndIndex) |
WindowJoinOperatorBuilder |
WindowJoinOperatorBuilder.withShiftTimezone(java.time.ZoneId shiftTimeZone)
The shift timezone of the window, if the proctime or rowtime type is TIMESTAMP_LTZ, the shift
timezone is the timezone user configured in TableConfig, other cases the timezone is UTC
which means never shift when assigning windows.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.