Uses of Class
org.apache.flink.types.Row

Packages that use Row

Package	Description
io.confluent.flink.plugin
org.apache.flink.table.api
org.apache.flink.table.runtime.functions
org.apache.flink.types

Uses of Row in io.confluent.flink.plugin

Methods in io.confluent.flink.plugin that return types with arguments of type Row

Modifier and Type	Method	Description
static List<Row>	ConfluentTools.collectChangelog(Table table)	Executes the given table transformations on Confluent Cloud and returns the results locally as a list of changelog rows.
static List<Row>	ConfluentTools.collectChangelog(Table table, int stopAfter)	Executes the given table transformations on Confluent Cloud and returns the results locally as a list of changelog rows.
static List<Row>	ConfluentTools.collectChangelog(TableResult tableResult)	Returns the given table results locally as a list of changelog rows.
static List<Row>	ConfluentTools.collectChangelog(TableResult tableResult, int stopAfter)	Returns the given table results locally as a list of changelog rows.
static List<Row>	ConfluentTools.collectMaterialized(Table table)	Executes the given table transformations on Confluent Cloud and returns the results locally as a materialized changelog.
static List<Row>	ConfluentTools.collectMaterialized(Table table, int stopAfter)	Executes the given table transformations on Confluent Cloud and returns the results locally as a materialized changelog.
static List<Row>	ConfluentTools.collectMaterialized(TableResult tableResult)	Returns the given results locally as a materialized changelog.
static List<Row>	ConfluentTools.collectMaterialized(TableResult tableResult, int stopAfter)	Returns the given results locally as a materialized changelog.

Uses of Row in org.apache.flink.table.api

Methods in org.apache.flink.table.api that return types with arguments of type Row

Modifier and Type	Method	Description
CloseableIterator<Row>	TableResult.collect()	Get the result contents as a closeable row iterator.

Uses of Row in org.apache.flink.table.runtime.functions

Methods in org.apache.flink.table.runtime.functions that return Row

Modifier and Type	Method	Description
Row	Timer.getKey()

Methods in org.apache.flink.table.runtime.functions that return types with arguments of type Row

Modifier and Type	Method	Description
Set<Row>	ProcessTableFunctionTestHarness.getKeysForState(String stateName)	Get all partition keys that have a specific state entry.
List<Row>	ProcessTableFunctionTestHarness.getOutput()	Returns the collected output as full rows: atomic output wrapped into an EXPR$0 column or structured output flattened into its attributes, with additional columns (partition keys, rowtime, etc.) prepended or appended as configured.
<T> Map<Row,T>	ProcessTableFunctionTestHarness.getStateForAllKeys(String stateName)	Get all state values for a state name across all partition keys.

Methods in org.apache.flink.table.runtime.functions with parameters of type Row

Modifier and Type	Method	Description
void	ProcessTableFunctionTestHarness.clearAllStatesForKey(Row partitionKey)	Clear all state for a given partition key.
void	ProcessTableFunctionTestHarness.clearStateForKey(String stateName, Row partitionKey)	Clear specific state entry for a given partition key.
List<Timer>	ProcessTableFunctionTestHarness.getAllTimers(Row partitionKey)	Returns all timers (both pending and fired) for the given partition key.
List<Timer>	ProcessTableFunctionTestHarness.getFiredTimers(Row partitionKey)	Returns all fired timers for the given partition key.
List<Timer>	ProcessTableFunctionTestHarness.getPendingTimers(Row partitionKey)	Returns all pending timers for the given partition key.
<T> T	ProcessTableFunctionTestHarness.getStateForKey(String stateName, Row partitionKey)	Get state for a specific partition key.
void	ProcessTableFunctionTestHarness.processElement(Row row)	Process a single element for the default table argument.
void	ProcessTableFunctionTestHarness.processElementForTable(String tableArgument, Row row)	Process a single element for a specific table argument.
void	ProcessTableFunctionTestHarness.setStateForKey(String stateName, Row partitionKey, Object state)	Set state for a specific partition key.
ProcessTableFunctionTestHarness.Builder<OUT>	ProcessTableFunctionTestHarness.Builder.withInitialStateForKey(String stateName, Row partitionKey, Object state)	Sets initial state for a state parameter.

Uses of Row in org.apache.flink.types

Methods in org.apache.flink.types that return Row

Modifier and Type	Method	Description
static Row	Row.copy(Row row)	Creates a new row which is copied from another row (including its RowKind).
static Row	Row.join(Row first, Row... remainings)	Creates a new row with fields that are copied from the other rows and appended to the resulting row in the given order.
static Row	Row.of(Object... values)	Creates a fixed-length row in position-based field mode and assigns the given values to the row's fields.
static Row	Row.ofKind(RowKind kind, Object... values)	Creates a fixed-length row in position-based field mode with given kind and assigns the given values to the row's fields.
static Row	Row.project(Row row, int[] fieldPositions)	Creates a new row with projected fields and identical RowKind from another row.
static Row	Row.project(Row row, String[] fieldNames)	Creates a new row with projected fields and identical RowKind from another row.
static Row	Row.withNames()	Creates a variable-length row in name-based field mode.
static Row	Row.withNames(RowKind kind)	Creates a variable-length row in name-based field mode.
static Row	Row.withPositions(int arity)	Creates a fixed-length row in position-based field mode.
static Row	Row.withPositions(RowKind kind, int arity)	Creates a fixed-length row in position-based field mode.

Methods in org.apache.flink.types with parameters of type Row

Modifier and Type	Method	Description
static Row	Row.copy(Row row)	Creates a new row which is copied from another row (including its RowKind).
static Row	Row.join(Row first, Row... remainings)	Creates a new row with fields that are copied from the other rows and appended to the resulting row in the given order.
static Row	Row.project(Row row, int[] fieldPositions)	Creates a new row with projected fields and identical RowKind from another row.
static Row	Row.project(Row row, String[] fieldNames)	Creates a new row with projected fields and identical RowKind from another row.