Constructor and Description |
---|
AbstractDeserializationSchema(TypeHint<T> typeHint)
Creates an AbstractDeserializationSchema that returns the TypeInformation indicated by the
given type hint.
|
Modifier and Type | Method and Description |
---|---|
static <T> TypeInformation<T> |
TypeInformation.of(TypeHint<T> typeHint)
Creates a TypeInformation for a generic type via a utility "type hint".
|
Modifier and Type | Method and Description |
---|---|
O |
SingleInputUdfOperator.returns(TypeHint<OUT> typeHint)
Adds a type information hint about the return type of this operator.
|
O |
TwoInputUdfOperator.returns(TypeHint<OUT> typeHint)
Adds a type information hint about the return type of this operator.
|
Modifier and Type | Method and Description |
---|---|
<K,S extends State,V> |
QueryableStateClient.getKvState(JobID jobId,
String queryableStateName,
K key,
TypeHint<K> keyTypeHint,
StateDescriptor<S,V> stateDescriptor)
Returns a future holding the request result.
|
Modifier and Type | Method and Description |
---|---|
SingleOutputStreamOperator<T> |
SingleOutputStreamOperator.returns(TypeHint<T> typeHint)
Adds a type information hint about the return type of this operator.
|
<F> IterativeStream.ConnectedIterativeStreams<T,F> |
IterativeStream.withFeedbackType(TypeHint<F> feedbackTypeHint)
Changes the feedback type of the iteration and allows the user to apply co-transformations on
the input and feedback stream, as in a
ConnectedStreams . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.