Modifier and Type | Method and Description |
---|---|
static Object |
PythonBridgeUtils.getPickledBytesFromRow(Row row,
DataType[] dataTypes) |
Modifier and Type | Method and Description |
---|---|
static TypeInformation<Row> |
Types.ROW_NAMED(String[] fieldNames,
TypeInformation<?>... types)
Returns type information for
Row with fields of the given
types and with given names. |
static TypeInformation<Row> |
Types.ROW(TypeInformation<?>... types)
Returns type information for
Row with fields of the given
types. |
Modifier and Type | Method and Description |
---|---|
protected Row |
RowCsvInputFormat.fillRecord(Row reuse,
Object[] parsedValues) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Row> |
RowCsvInputFormat.getProducedType() |
Modifier and Type | Method and Description |
---|---|
protected Row |
RowCsvInputFormat.fillRecord(Row reuse,
Object[] parsedValues) |
Modifier and Type | Method and 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() |
Modifier and Type | Method and Description |
---|---|
Row |
RowSerializer.copy(Row from) |
Row |
RowSerializer.copy(Row from,
Row reuse) |
Row |
RowSerializer.createInstance() |
Row |
RowSerializer.deserialize(DataInputView source) |
Row |
RowSerializer.deserialize(Row reuse,
DataInputView source) |
Row |
RowComparator.readWithKeyDenormalization(Row reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeComparator<Row> |
RowComparator.duplicate() |
TypeSerializer<Row> |
RowSerializer.duplicate() |
TypeSerializerSchemaCompatibility<Row> |
RowSerializer.RowSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<Row> newSerializer)
Deprecated.
|
TypeSerializerSnapshot<Row> |
RowSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
int |
RowComparator.compare(Row first,
Row second) |
Row |
RowSerializer.copy(Row from) |
Row |
RowSerializer.copy(Row from,
Row reuse) |
Row |
RowSerializer.deserialize(Row reuse,
DataInputView source) |
boolean |
RowComparator.equalToReference(Row candidate) |
int |
RowComparator.hash(Row record) |
void |
RowComparator.putNormalizedKey(Row record,
MemorySegment target,
int offset,
int numBytes) |
Row |
RowComparator.readWithKeyDenormalization(Row reuse,
DataInputView source) |
void |
RowSerializer.serialize(Row record,
DataOutputView target) |
void |
RowComparator.setReference(Row toCompare) |
void |
RowComparator.writeWithKeyNormalization(Row record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
int |
RowComparator.compareToReference(TypeComparator<Row> referencedComparator) |
TypeSerializerSchemaCompatibility<Row> |
RowSerializer.RowSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<Row> newSerializer)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected Object[] |
CassandraRowOutputFormat.extractFields(Row record) |
Modifier and Type | Method and Description |
---|---|
Row |
RowPartitionComputer.projectColumnsToWrite(Row in) |
Modifier and Type | Method and Description |
---|---|
LinkedHashMap<String,String> |
RowPartitionComputer.generatePartValues(Row in) |
Row |
RowPartitionComputer.projectColumnsToWrite(Row in) |
Modifier and Type | Method and Description |
---|---|
Row |
JdbcInputFormat.nextRecord(Row reuse)
Stores the next resultSet row in a tuple.
|
Modifier and Type | Method and Description |
---|---|
Row |
JdbcInputFormat.nextRecord(Row reuse)
Stores the next resultSet row in a tuple.
|
Modifier and Type | Method and Description |
---|---|
JdbcOutputFormat<Tuple2<Boolean,Row>,Row,JdbcBatchStatementExecutor<Row>> |
JdbcOutputFormat.Builder.build()
Finalizes the configuration and checks validity.
|
JdbcOutputFormat<Tuple2<Boolean,Row>,Row,JdbcBatchStatementExecutor<Row>> |
JdbcOutputFormat.Builder.build()
Finalizes the configuration and checks validity.
|
JdbcOutputFormat<Tuple2<Boolean,Row>,Row,JdbcBatchStatementExecutor<Row>> |
JdbcOutputFormat.Builder.build()
Finalizes the configuration and checks validity.
|
Modifier and Type | Method and Description |
---|---|
static Row |
JdbcUtils.getPrimaryKey(Row row,
int[] pkFields) |
Modifier and Type | Method and Description |
---|---|
static Row |
JdbcUtils.getPrimaryKey(Row row,
int[] pkFields) |
static void |
JdbcUtils.setRecordToStatement(PreparedStatement upload,
int[] typesArray,
Row row)
Adds a record to the prepared statement.
|
Modifier and Type | Method and Description |
---|---|
LinkedHashMap<String,String> |
HiveRowPartitionComputer.generatePartValues(Row in) |
Modifier and Type | Method and Description |
---|---|
java.util.function.Function<Row,org.apache.hadoop.io.Writable> |
HiveWriterFactory.createRowConverter() |
Modifier and Type | Method and Description |
---|---|
Row |
AvroRowDeserializationSchema.deserialize(byte[] message)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<Row> |
AvroRowDeserializationSchema.getProducedType()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
byte[] |
AvroRowSerializationSchema.serialize(Row row)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static <T extends org.apache.avro.specific.SpecificRecord> |
AvroSchemaConverter.convertToTypeInfo(Class<T> avroClass)
Converts an Avro class into a nested row structure with deterministic field order and data
types that are compatible with Flink's Table & SQL API.
|
Modifier and Type | Method and Description |
---|---|
Row |
CsvRowDeserializationSchema.deserialize(byte[] message)
Deprecated.
|
Row |
RowCsvInputFormat.nextRecord(Row record) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Row> |
CsvRowDeserializationSchema.getProducedType()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
CsvRowDeserializationSchema.isEndOfStream(Row nextElement)
Deprecated.
|
Row |
RowCsvInputFormat.nextRecord(Row record) |
byte[] |
CsvRowSerializationSchema.serialize(Row row)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static RowCsvInputFormat.Builder |
RowCsvInputFormat.builder(TypeInformation<Row> typeInfo,
Path... filePaths)
Create a builder.
|
Constructor and Description |
---|
Builder(TypeInformation<Row> typeInfo)
Creates a
CsvRowSerializationSchema expecting the given TypeInformation . |
Builder(TypeInformation<Row> typeInfo)
Creates a CSV deserialization schema for the given
TypeInformation with optional
parameters. |
Modifier and Type | Method and Description |
---|---|
Row |
JsonRowDeserializationSchema.deserialize(byte[] message)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TypeInformation<Row> |
JsonRowDeserializationSchema.getProducedType()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
JsonRowDeserializationSchema.isEndOfStream(Row nextElement)
Deprecated.
|
byte[] |
JsonRowSerializationSchema.serialize(Row row)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonRowSerializationSchema.Builder |
JsonRowSerializationSchema.Builder.withTypeInfo(TypeInformation<Row> typeInfo)
Sets type information for JSON serialization schema.
|
Constructor and Description |
---|
Builder(TypeInformation<Row> typeInfo)
Deprecated.
Use
JsonRowSerializationSchema.builder() instead. |
Builder(TypeInformation<Row> typeInfo)
Creates a JSON deserialization schema for the given type information.
|
JsonRowDeserializationSchema(TypeInformation<Row> typeInfo)
Deprecated.
Use the provided
JsonRowDeserializationSchema.Builder instead. |
Modifier and Type | Method and Description |
---|---|
void |
PythonConnectorUtils.RowRowMapper.processElement(Row row,
ProcessFunction.Context ctx,
Collector<RowData> out) |
byte[] |
PythonConnectorUtils.SecondColumnSerializationSchema.serialize(Row row) |
Modifier and Type | Method and Description |
---|---|
Row |
StreamSQLTestProgram.KillMapper.map(Row value) |
Row |
BatchSQLTestProgram.DataGenerator.next() |
Modifier and Type | Method and Description |
---|---|
DataStream<Row> |
StreamSQLTestProgram.GeneratorTableSource.getDataStream(StreamExecutionEnvironment execEnv) |
InputFormat<Row,?> |
BatchSQLTestProgram.GeneratorTableSource.getInputFormat() |
TypeInformation<Row> |
StreamSQLTestProgram.Generator.getProducedType() |
TypeInformation<Row> |
StreamSQLTestProgram.GeneratorTableSource.getReturnType() |
Modifier and Type | Method and Description |
---|---|
String |
StreamSQLTestProgram.KeyBucketAssigner.getBucketId(Row element,
BucketAssigner.Context context) |
Row |
StreamSQLTestProgram.KillMapper.map(Row value) |
Modifier and Type | Method and Description |
---|---|
void |
StreamSQLTestProgram.Generator.run(SourceFunction.SourceContext<Row> ctx) |
Modifier and Type | Method and Description |
---|---|
Row |
KeyByKeySelector.getKey(Row value) |
Modifier and Type | Method and Description |
---|---|
Integer |
PartitionCustomKeySelector.getKey(Row value) |
Row |
KeyByKeySelector.getKey(Row value) |
Modifier and Type | Method and Description |
---|---|
protected TypeSerializer<Row> |
AbstractExternalDataStreamPythonFunctionOperator.getSideOutputTypeSerializerById(String id) |
Modifier and Type | Method and Description |
---|---|
void |
ExternalPythonKeyedProcessOperator.onEventTime(InternalTimer<Row,Object> timer) |
void |
ExternalPythonKeyedCoProcessOperator.onEventTime(InternalTimer<Row,VoidNamespace> timer) |
void |
ExternalPythonKeyedProcessOperator.onProcessingTime(InternalTimer<Row,Object> timer) |
void |
ExternalPythonKeyedCoProcessOperator.onProcessingTime(InternalTimer<Row,VoidNamespace> timer) |
void |
ExternalPythonKeyedProcessOperator.processElement(StreamRecord<Row> element) |
void |
ExternalPythonBatchKeyedCoBroadcastProcessOperator.processElement1(StreamRecord<Row> element) |
void |
ExternalPythonKeyedCoProcessOperator.processElement1(StreamRecord<Row> element) |
void |
ExternalPythonKeyedCoProcessOperator.processElement2(StreamRecord<Row> element) |
Modifier and Type | Method and Description |
---|---|
static TypeInformation<Row> |
RunnerOutputCollector.getRunnerOutputTypeInfo(TypeInformation<?> elementDataTypeInfo) |
Modifier and Type | Method and Description |
---|---|
<X> void |
RunnerOutputCollector.collect(OutputTag<X> outputTag,
Row runnerOutput) |
void |
RunnerOutputCollector.collect(Row runnerOutput) |
Modifier and Type | Method and Description |
---|---|
Row |
TimerHandler.buildTimerData(TimeDomain timeDomain,
long watermark,
long timestamp,
Row key,
byte[] encodedNamespace) |
Modifier and Type | Method and Description |
---|---|
static TypeInformation<Row> |
TimerUtils.createTimerDataTypeInfo(TypeInformation<Row> keyType) |
Modifier and Type | Method and Description |
---|---|
Row |
TimerHandler.buildTimerData(TimeDomain timeDomain,
long watermark,
long timestamp,
Row key,
byte[] encodedNamespace) |
Modifier and Type | Method and Description |
---|---|
static FlinkFnApi.CoderInfoDescriptor |
TimerUtils.createTimerDataCoderInfoDescriptorProto(TypeInformation<Row> timerDataType) |
static TypeInformation<Row> |
TimerUtils.createTimerDataTypeInfo(TypeInformation<Row> keyType) |
Constructor and Description |
---|
TimerRegistration(KeyedStateBackend<Row> keyedStateBackend,
InternalTimerService internalTimerService,
KeyContext keyContext,
TypeSerializer namespaceSerializer,
TypeSerializer<Row> timerDataSerializer) |
TimerRegistration(KeyedStateBackend<Row> keyedStateBackend,
InternalTimerService internalTimerService,
KeyContext keyContext,
TypeSerializer namespaceSerializer,
TypeSerializer<Row> timerDataSerializer) |
Modifier and Type | Method and Description |
---|---|
KeySelector<Row,Row> |
PythonKeyedBroadcastStateTransformation.getKeySelector() |
KeySelector<Row,Row> |
PythonKeyedBroadcastStateTransformation.getKeySelector() |
TypeInformation<Row> |
PythonKeyedBroadcastStateTransformation.getStateKeyType() |
Modifier and Type | Method and Description |
---|---|
Row |
PythonTypeUtils.RowDataConverter.toInternal(Object[] value) |
Modifier and Type | Method and Description |
---|---|
Object[] |
PythonTypeUtils.RowDataConverter.toExternal(Row value) |
Modifier and Type | Method and Description |
---|---|
protected CassandraSink<Row> |
CassandraSink.CassandraRowSinkBuilder.createSink() |
protected CassandraSink<Row> |
CassandraSink.CassandraRowSinkBuilder.createWriteAheadSink() |
TypeInformation<Row> |
CassandraAppendTableSink.getOutputType() |
Modifier and Type | Method and Description |
---|---|
protected Object[] |
CassandraRowSink.extract(Row record) |
Modifier and Type | Method and Description |
---|---|
DataStreamSink<?> |
CassandraAppendTableSink.consumeDataStream(DataStream<Row> dataStream) |
protected boolean |
CassandraRowWriteAheadSink.sendValues(Iterable<Row> values,
long checkpointId,
long timestamp) |
Constructor and Description |
---|
CassandraRowSinkBuilder(DataStream<Row> input,
TypeInformation<Row> typeInfo,
TypeSerializer<Row> serializer) |
CassandraRowSinkBuilder(DataStream<Row> input,
TypeInformation<Row> typeInfo,
TypeSerializer<Row> serializer) |
CassandraRowSinkBuilder(DataStream<Row> input,
TypeInformation<Row> typeInfo,
TypeSerializer<Row> serializer) |
CassandraRowWriteAheadSink(String insertQuery,
TypeSerializer<Row> serializer,
ClusterBuilder builder,
CheckpointCommitter committer) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Row> |
TableResult.collect()
Get the result contents as a closeable row iterator.
|
static TypeInformation<Row> |
Types.ROW(String[] fieldNames,
TypeInformation<?>[] types)
Deprecated.
Returns type information for
Row with fields of the given types and with given names. |
static TypeInformation<Row> |
Types.ROW(TypeInformation<?>... types)
Deprecated.
Returns type information for
Row with fields of the given types. |
TypeInformation<Row> |
TableSchema.toRowType()
Deprecated.
Use
TableSchema.toRowDataType() instead. |
Modifier and Type | Method and Description |
---|---|
DataStream<Row> |
StreamTableEnvironment.toChangelogStream(Table table)
Converts the given
Table into a DataStream of changelog entries. |
DataStream<Row> |
StreamTableEnvironment.toChangelogStream(Table table,
Schema targetSchema)
Converts the given
Table into a DataStream of changelog entries. |
DataStream<Row> |
StreamTableEnvironment.toChangelogStream(Table table,
Schema targetSchema,
ChangelogMode changelogMode)
Converts the given
Table into a DataStream of changelog entries. |
DataStream<Row> |
StreamTableEnvironment.toDataStream(Table table)
Converts the given
Table into a DataStream . |
Modifier and Type | Method and Description |
---|---|
Table |
StreamTableEnvironment.fromChangelogStream(DataStream<Row> dataStream)
Converts the given
DataStream of changelog entries into a Table . |
Table |
StreamTableEnvironment.fromChangelogStream(DataStream<Row> dataStream,
Schema schema)
Converts the given
DataStream of changelog entries into a Table . |
Table |
StreamTableEnvironment.fromChangelogStream(DataStream<Row> dataStream,
Schema schema,
ChangelogMode changelogMode)
Converts the given
DataStream of changelog entries into a Table . |
Modifier and Type | Method and Description |
---|---|
DataStream<Row> |
StreamTableEnvironmentImpl.toChangelogStream(Table table) |
DataStream<Row> |
StreamTableEnvironmentImpl.toChangelogStream(Table table,
Schema targetSchema) |
DataStream<Row> |
StreamTableEnvironmentImpl.toChangelogStream(Table table,
Schema targetSchema,
ChangelogMode changelogMode) |
DataStream<Row> |
StreamTableEnvironmentImpl.toDataStream(Table table) |
Modifier and Type | Method and Description |
---|---|
Table |
StreamTableEnvironmentImpl.fromChangelogStream(DataStream<Row> dataStream) |
Table |
StreamTableEnvironmentImpl.fromChangelogStream(DataStream<Row> dataStream,
Schema schema) |
Table |
StreamTableEnvironmentImpl.fromChangelogStream(DataStream<Row> dataStream,
Schema schema,
ChangelogMode changelogMode) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Row> |
TableResultImpl.collect() |
CloseableIterator<Row> |
ResultProvider.toExternalIterator()
Returns the select result as row iterator using external data types.
|
CloseableIterator<Row> |
StaticResultProvider.toExternalIterator() |
Modifier and Type | Method and Description |
---|---|
TableResultImpl.Builder |
TableResultImpl.Builder.data(List<Row> rowList)
Specifies an row list as the execution result.
|
Constructor and Description |
---|
StaticResultProvider(List<Row> rows) |
StaticResultProvider(List<Row> rows,
java.util.function.Function<Row,RowData> externalToInternalConverter) |
StaticResultProvider(List<Row> rows,
java.util.function.Function<Row,RowData> externalToInternalConverter) |
Modifier and Type | Method and Description |
---|---|
Row |
RowRowConverter.toExternal(RowData internal) |
Modifier and Type | Method and Description |
---|---|
RowData |
RowRowConverter.toInternal(Row external) |
Modifier and Type | Method and Description |
---|---|
Row |
LastDatedValueFunction.getValue(LastDatedValueFunction.Accumulator<T> acc) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Row> |
PythonTableFunction.getResultType() |
Modifier and Type | Method and Description |
---|---|
TableSink<Row> |
CsvTableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes)
Deprecated.
|
StreamTableSink<Row> |
CsvBatchTableSinkFactory.createStreamTableSink(Map<String,String> properties)
Deprecated.
|
StreamTableSink<Row> |
CsvAppendTableSinkFactory.createStreamTableSink(Map<String,String> properties)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
String |
CsvTableSink.CsvFormatter.map(Row row) |
Modifier and Type | Method and Description |
---|---|
DataStreamSink<?> |
CsvTableSink.consumeDataStream(DataStream<Row> dataStream)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
StreamTableSource<Row> |
CsvAppendTableSourceFactory.createStreamTableSource(Map<String,String> properties)
Deprecated.
|
StreamTableSource<Row> |
CsvBatchTableSourceFactory.createStreamTableSource(Map<String,String> properties)
Deprecated.
|
AsyncTableFunction<Row> |
CsvTableSource.getAsyncLookupFunction(String[] lookupKeys)
Deprecated.
|
DataStream<Row> |
CsvTableSource.getDataStream(StreamExecutionEnvironment execEnv)
Deprecated.
|
TableFunction<Row> |
CsvTableSource.getLookupFunction(String[] lookupKeys)
Deprecated.
|
TypeInformation<Row> |
CsvTableSource.CsvLookupFunction.getResultType() |
Modifier and Type | Method and Description |
---|---|
abstract Watermark |
PunctuatedWatermarkAssigner.getWatermark(Row row,
long timestamp)
Returns the watermark for the current row or null if no watermark should be generated.
|
Modifier and Type | Method and Description |
---|---|
static Row |
Row.copy(Row row)
Creates a new row which is copied from another row (including its
RowKind ). |
static Row |
RowUtils.createRowWithNamedPositions(RowKind kind,
Object[] fieldByPosition,
LinkedHashMap<String,Integer> positionByName)
Internal utility for creating a row in static named-position field mode.
|
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.
|
Modifier and Type | Method and 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.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. |
Modifier and Type | Method and Description |
---|---|
static boolean |
RowUtils.compareRows(List<Row> l1,
List<Row> l2)
|
static boolean |
RowUtils.compareRows(List<Row> l1,
List<Row> l2)
|
static boolean |
RowUtils.compareRows(List<Row> l1,
List<Row> l2,
boolean ignoreOrder)
|
static boolean |
RowUtils.compareRows(List<Row> l1,
List<Row> l2,
boolean ignoreOrder)
|
Modifier and Type | Method and Description |
---|---|
Row |
TransactionRowInputFormat.nextRecord(Row reuse) |
Modifier and Type | Method and Description |
---|---|
Row |
TransactionRowInputFormat.nextRecord(Row reuse) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.