Package | Description |
---|---|
org.apache.flink.fnexecution.v1 |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.addAllNamedProperties(Iterable<? extends FlinkFnApi.GroupWindow.WindowProperty> values)
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.addAllNamedPropertiesValue(Iterable<Integer> values)
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.addNamedProperties(FlinkFnApi.GroupWindow.WindowProperty value)
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.addNamedPropertiesValue(int value)
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.clear() |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.clearAllowedLateness()
int64 allowedLateness = 8; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.clearIsRowTime()
bool is_row_time = 6; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.clearIsTimeWindow()
bool is_time_window = 2; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.clearNamedProperties()
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.clearShiftTimezone()
string shift_timezone = 10; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.clearTimeFieldIndex()
int32 time_field_index = 7; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.clearWindowGap()
int64 window_gap = 5; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.clearWindowSize()
int64 window_size = 4; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.clearWindowSlide()
int64 window_slide = 3; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.clearWindowType()
.org.apache.flink.fn_execution.v1.GroupWindow.WindowType window_type = 1; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.clone() |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.getGroupWindowBuilder()
Group Window.
|
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.mergeFrom(FlinkFnApi.GroupWindow other) |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.mergeFrom(com.google.protobuf.Message other) |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
static FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.newBuilder() |
static FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.newBuilder(FlinkFnApi.GroupWindow prototype) |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.newBuilderForType() |
protected FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setAllowedLateness(long value)
int64 allowedLateness = 8; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setIsRowTime(boolean value)
bool is_row_time = 6; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setIsTimeWindow(boolean value)
bool is_time_window = 2; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setNamedProperties(int index,
FlinkFnApi.GroupWindow.WindowProperty value)
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setNamedPropertiesValue(int index,
int value)
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
Object value) |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setShiftTimezone(String value)
string shift_timezone = 10; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setShiftTimezoneBytes(com.google.protobuf.ByteString value)
string shift_timezone = 10; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setTimeFieldIndex(int value)
int32 time_field_index = 7; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setWindowGap(long value)
int64 window_gap = 5; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setWindowSize(long value)
int64 window_size = 4; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setWindowSlide(long value)
int64 window_slide = 3; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setWindowType(FlinkFnApi.GroupWindow.WindowType value)
.org.apache.flink.fn_execution.v1.GroupWindow.WindowType window_type = 1; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.Builder.setWindowTypeValue(int value)
.org.apache.flink.fn_execution.v1.GroupWindow.WindowType window_type = 1; |
FlinkFnApi.GroupWindow.Builder |
FlinkFnApi.GroupWindow.toBuilder() |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setGroupWindow(FlinkFnApi.GroupWindow.Builder builderForValue)
Group Window.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.