public static class OverlappingTimeWindowFunction.Builder
extends java.lang.Object
Constructor and Description |
---|
Builder() |
Modifier and Type | Method and Description |
---|---|
OverlappingTimeWindowFunction.Builder |
addWindowEndTimeColumn(boolean addWindowEndTimeColumn) |
OverlappingTimeWindowFunction.Builder |
addWindowStartTimeColumn(boolean addWindowStartTimeColumn) |
OverlappingTimeWindowFunction |
build() |
OverlappingTimeWindowFunction.Builder |
excludeEmptyWindows(boolean excludeEmptyWindows) |
OverlappingTimeWindowFunction.Builder |
offset(long offsetAmount,
java.util.concurrent.TimeUnit offsetUnit) |
OverlappingTimeWindowFunction.Builder |
timeColumn(java.lang.String timeColumn) |
OverlappingTimeWindowFunction.Builder |
windowSeparation(long windowSeparation,
java.util.concurrent.TimeUnit windowSeparationUnit) |
OverlappingTimeWindowFunction.Builder |
windowSize(long windowSize,
java.util.concurrent.TimeUnit windowSizeUnit) |
public OverlappingTimeWindowFunction.Builder timeColumn(java.lang.String timeColumn)
public OverlappingTimeWindowFunction.Builder windowSize(long windowSize, java.util.concurrent.TimeUnit windowSizeUnit)
public OverlappingTimeWindowFunction.Builder windowSeparation(long windowSeparation, java.util.concurrent.TimeUnit windowSeparationUnit)
public OverlappingTimeWindowFunction.Builder offset(long offsetAmount, java.util.concurrent.TimeUnit offsetUnit)
public OverlappingTimeWindowFunction.Builder addWindowStartTimeColumn(boolean addWindowStartTimeColumn)
public OverlappingTimeWindowFunction.Builder addWindowEndTimeColumn(boolean addWindowEndTimeColumn)
public OverlappingTimeWindowFunction.Builder excludeEmptyWindows(boolean excludeEmptyWindows)
public OverlappingTimeWindowFunction build()