public static interface FlinkFnApi.GroupWindowOrBuilder
extends com.google.protobuf.MessageOrBuilder
Modifier and Type | Method and Description |
---|---|
long |
getAllowedLateness()
int64 allowedLateness = 8; |
boolean |
getIsRowTime()
bool is_row_time = 6; |
boolean |
getIsTimeWindow()
bool is_time_window = 2; |
FlinkFnApi.GroupWindow.WindowProperty |
getNamedProperties(int index)
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9; |
int |
getNamedPropertiesCount()
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9; |
List<FlinkFnApi.GroupWindow.WindowProperty> |
getNamedPropertiesList()
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9; |
int |
getNamedPropertiesValue(int index)
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9; |
List<Integer> |
getNamedPropertiesValueList()
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9; |
String |
getShiftTimezone()
string shift_timezone = 10; |
com.google.protobuf.ByteString |
getShiftTimezoneBytes()
string shift_timezone = 10; |
int |
getTimeFieldIndex()
int32 time_field_index = 7; |
long |
getWindowGap()
int64 window_gap = 5; |
long |
getWindowSize()
int64 window_size = 4; |
long |
getWindowSlide()
int64 window_slide = 3; |
FlinkFnApi.GroupWindow.WindowType |
getWindowType()
.org.apache.flink.fn_execution.v1.GroupWindow.WindowType window_type = 1; |
int |
getWindowTypeValue()
.org.apache.flink.fn_execution.v1.GroupWindow.WindowType window_type = 1; |
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
int getWindowTypeValue()
.org.apache.flink.fn_execution.v1.GroupWindow.WindowType window_type = 1;
FlinkFnApi.GroupWindow.WindowType getWindowType()
.org.apache.flink.fn_execution.v1.GroupWindow.WindowType window_type = 1;
boolean getIsTimeWindow()
bool is_time_window = 2;
long getWindowSlide()
int64 window_slide = 3;
long getWindowSize()
int64 window_size = 4;
long getWindowGap()
int64 window_gap = 5;
boolean getIsRowTime()
bool is_row_time = 6;
int getTimeFieldIndex()
int32 time_field_index = 7;
long getAllowedLateness()
int64 allowedLateness = 8;
List<FlinkFnApi.GroupWindow.WindowProperty> getNamedPropertiesList()
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9;
int getNamedPropertiesCount()
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9;
FlinkFnApi.GroupWindow.WindowProperty getNamedProperties(int index)
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9;
index
- The index of the element to return.List<Integer> getNamedPropertiesValueList()
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9;
int getNamedPropertiesValue(int index)
repeated .org.apache.flink.fn_execution.v1.GroupWindow.WindowProperty namedProperties = 9;
index
- The index of the value to return.String getShiftTimezone()
string shift_timezone = 10;
com.google.protobuf.ByteString getShiftTimezoneBytes()
string shift_timezone = 10;
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.