stevenzwu commented on PR #7494:
URL: https://github.com/apache/iceberg/pull/7494#issuecomment-1546444317
>
> One naive question, how do we plan to register the
DataStatisticsOrRecordSerializer? Do we plan to define TypeInfoFactory or use
env config to register it?
@yegangy0718 good question. we probably also need to implement a TypeInfo
class when adding the DataStatisticsOperator. that way, Flink would know which
type serializer to use.
Here is the DataStream API.
```
/**
* Method for passing user defined operators along with the type
information that will transform
* the DataStream.
*
* @param operatorName name of the operator, for logging purposes
* @param outTypeInfo the output type of the operator
* @param operator the object containing the transformation logic
* @param <R> type of the return stream
* @return the data stream constructed
* @see #transform(String, TypeInformation,
OneInputStreamOperatorFactory)
*/
@PublicEvolving
public <R> SingleOutputStreamOperator<R> transform(
String operatorName,
TypeInformation<R> outTypeInfo,
OneInputStreamOperator<T, R> operator) {
return doTransform(operatorName, outTypeInfo,
SimpleOperatorFactory.of(operator));
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
