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