Uses of Class
org.apache.flink.table.runtime.functions.ProcessTableFunctionTestHarness.Builder
Packages that use ProcessTableFunctionTestHarness.Builder
-
Uses of ProcessTableFunctionTestHarness.Builder in org.apache.flink.table.runtime.functions
Methods in org.apache.flink.table.runtime.functions that return ProcessTableFunctionTestHarness.BuilderModifier and TypeMethodDescriptionstatic <OUT> ProcessTableFunctionTestHarness.Builder<OUT>ProcessTableFunctionTestHarness.ofClass(Class<? extends ProcessTableFunction<OUT>> functionClass) Creates a new harness builder for the given ProcessTableFunction class.ProcessTableFunctionTestHarness.Builder.withInitialStateForKey(String stateName, Row partitionKey, Object state) Sets initial state for a state parameter.ProcessTableFunctionTestHarness.Builder.withOnTimeColumn(String columnName) Configures the on-time column name for the function.ProcessTableFunctionTestHarness.Builder.withPartitionBy(String argumentName, String... columnNames) Specifies partition columns for a set semantic table.ProcessTableFunctionTestHarness.Builder.withScalarArgument(String argumentName, Object value) Configures a scalar (non-table) argument for the PTF's eval() method.ProcessTableFunctionTestHarness.Builder.withTableArgument(String argumentName) Configures a table argument without an explicit schema.ProcessTableFunctionTestHarness.Builder.withTableArgument(String argumentName, AbstractDataType<?> dataType) Configures a table argument with its schema (named argument).