Uses of Class
org.apache.flink.types.Row
-
Packages that use Row Package Description org.apache.flink.api.common.typeinfo org.apache.flink.api.java.typeutils org.apache.flink.api.java.typeutils.runtime org.apache.flink.types -
-
Uses of Row in org.apache.flink.api.common.typeinfo
Methods in org.apache.flink.api.common.typeinfo that return types with arguments of type Row Modifier and Type Method Description static TypeInformation<Row>Types. ROW(TypeInformation<?>... types)Returns type information forRowwith fields of the given types.static TypeInformation<Row>Types. ROW_NAMED(String[] fieldNames, TypeInformation<?>... types)Returns type information forRowwith fields of the given types and with given names. -
Uses of Row in org.apache.flink.api.java.typeutils
Methods in org.apache.flink.api.java.typeutils that return types with arguments of type Row Modifier and Type Method Description TypeComparator<Row>RowTypeInfo. createComparator(int[] logicalKeyFields, boolean[] orders, int logicalFieldOffset, ExecutionConfig config)TypeSerializer<Row>RowTypeInfo. createLegacySerializer(ExecutionConfig config)Deprecated.TypeSerializer<Row>RowTypeInfo. createSerializer(ExecutionConfig config)protected CompositeType.TypeComparatorBuilder<Row>RowTypeInfo. createTypeComparatorBuilder() -
Uses of Row in org.apache.flink.api.java.typeutils.runtime
Methods in org.apache.flink.api.java.typeutils.runtime that return Row Modifier and Type Method Description RowRowSerializer. copy(Row from)RowRowSerializer. copy(Row from, Row reuse)RowRowSerializer. createInstance()RowRowSerializer. deserialize(DataInputView source)RowRowSerializer. deserialize(Row reuse, DataInputView source)RowRowComparator. readWithKeyDenormalization(Row reuse, DataInputView source)Methods in org.apache.flink.api.java.typeutils.runtime that return types with arguments of type Row Modifier and Type Method Description TypeComparator<Row>RowComparator. duplicate()TypeSerializer<Row>RowSerializer. duplicate()TypeSerializerSnapshot<Row>RowSerializer. snapshotConfiguration()Methods in org.apache.flink.api.java.typeutils.runtime with parameters of type Row Modifier and Type Method Description intRowComparator. compare(Row first, Row second)RowRowSerializer. copy(Row from)RowRowSerializer. copy(Row from, Row reuse)RowRowSerializer. deserialize(Row reuse, DataInputView source)booleanRowComparator. equalToReference(Row candidate)intRowComparator. hash(Row record)voidRowComparator. putNormalizedKey(Row record, MemorySegment target, int offset, int numBytes)RowRowComparator. readWithKeyDenormalization(Row reuse, DataInputView source)voidRowSerializer. serialize(Row record, DataOutputView target)voidRowComparator. setReference(Row toCompare)voidRowComparator. writeWithKeyNormalization(Row record, DataOutputView target)Method parameters in org.apache.flink.api.java.typeutils.runtime with type arguments of type Row Modifier and Type Method Description intRowComparator. compareToReference(TypeComparator<Row> referencedComparator) -
Uses of Row in org.apache.flink.types
Methods in org.apache.flink.types that return Row Modifier and Type Method Description static RowRow. copy(Row row)Creates a new row which is copied from another row (including itsRowKind).static RowRowUtils. createRowWithNamedPositions(RowKind kind, Object[] fieldByPosition, LinkedHashMap<String,Integer> positionByName)Internal utility for creating a row in static named-position field mode.static RowRow. 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 RowRow. of(Object... values)Creates a fixed-length row in position-based field mode and assigns the given values to the row's fields.static RowRow. 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 RowRow. project(Row row, int[] fieldPositions)Creates a new row with projected fields and identicalRowKindfrom another row.static RowRow. project(Row row, String[] fieldNames)Creates a new row with projected fields and identicalRowKindfrom another row.static RowRow. withNames()Creates a variable-length row in name-based field mode.static RowRow. withNames(RowKind kind)Creates a variable-length row in name-based field mode.static RowRow. withPositions(int arity)Creates a fixed-length row in position-based field mode.static RowRow. 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 RowRow. copy(Row row)Creates a new row which is copied from another row (including itsRowKind).static RowRow. 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 RowRow. project(Row row, int[] fieldPositions)Creates a new row with projected fields and identicalRowKindfrom another row.static RowRow. project(Row row, String[] fieldNames)Creates a new row with projected fields and identicalRowKindfrom another row.Method parameters in org.apache.flink.types with type arguments of type Row Modifier and Type Method Description static booleanRowUtils. compareRows(List<Row> l1, List<Row> l2)static booleanRowUtils. compareRows(List<Row> l1, List<Row> l2, boolean ignoreOrder)
-