Package | Description |
---|---|
org.apache.flink.streaming.util.typeutils |
Modifier and Type | Method and Description |
---|---|
<T,R,F> FieldAccessor<T,F> |
DefaultScalaProductFieldAccessorFactory.createRecursiveProductFieldAccessor(int pos,
TypeInformation<T> typeInfo,
FieldAccessor<R,F> innerAccessor,
ExecutionConfig config) |
<T,R,F> FieldAccessor<T,F> |
ScalaProductFieldAccessorFactory.createRecursiveProductFieldAccessor(int pos,
TypeInformation<T> typeInfo,
FieldAccessor<R,F> innerAccessor,
ExecutionConfig config)
Returns a product
FieldAccessor that does support recursion. |
<T,F> FieldAccessor<T,F> |
DefaultScalaProductFieldAccessorFactory.createSimpleProductFieldAccessor(int pos,
TypeInformation<T> typeInfo,
ExecutionConfig config) |
<T,F> FieldAccessor<T,F> |
ScalaProductFieldAccessorFactory.createSimpleProductFieldAccessor(int pos,
TypeInformation<T> typeInfo,
ExecutionConfig config)
Returns a product
FieldAccessor that does not support recursion. |
static <T,F> FieldAccessor<T,F> |
FieldAccessorFactory.getAccessor(TypeInformation<T> typeInfo,
int pos,
ExecutionConfig config)
Creates a
FieldAccessor for the given field position, which can be used to get and
set the specified field on instances of this type. |
static <T,F> FieldAccessor<T,F> |
FieldAccessorFactory.getAccessor(TypeInformation<T> typeInfo,
String field,
ExecutionConfig config)
Creates a
FieldAccessor for the field that is given by a field expression, which can
be used to get and set the specified field on instances of this type. |
Modifier and Type | Method and Description |
---|---|
<T,R,F> FieldAccessor<T,F> |
DefaultScalaProductFieldAccessorFactory.createRecursiveProductFieldAccessor(int pos,
TypeInformation<T> typeInfo,
FieldAccessor<R,F> innerAccessor,
ExecutionConfig config) |
<T,R,F> FieldAccessor<T,F> |
ScalaProductFieldAccessorFactory.createRecursiveProductFieldAccessor(int pos,
TypeInformation<T> typeInfo,
FieldAccessor<R,F> innerAccessor,
ExecutionConfig config)
Returns a product
FieldAccessor that does support recursion. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.