org.apache.flink.streaming.util.typeutils

Class DefaultScalaProductFieldAccessorFactory

java.lang.Object

org.apache.flink.streaming.util.typeutils.DefaultScalaProductFieldAccessorFactory

All Implemented Interfaces:

ScalaProductFieldAccessorFactory

Deprecated.

All Flink Scala APIs are deprecated and will be removed in a future Flink major version. You can still build your application in Scala, but you should move to the Java version of either the DataStream and/or Table API.

@Deprecated
public class DefaultScalaProductFieldAccessorFactory
extends Object
implements ScalaProductFieldAccessorFactory

Scala variant of FieldAccessorFactory for Scala products.

There are two versions of ProductFieldAccessor, differing in whether there is another FieldAccessor nested inside. The no inner accessor version is probably a little faster.

See Also:

FLIP-265 Deprecate and remove Scala API support

Constructor Summary

Constructors

Constructor and Description
DefaultScalaProductFieldAccessorFactory() Deprecated.

Method Summary

Modifier and Type	Method and Description
<T,R,F> FieldAccessor<T,F>	createRecursiveProductFieldAccessor(int pos, TypeInformation<T> typeInfo, FieldAccessor<R,F> innerAccessor, ExecutionConfig config) Deprecated. Returns a product FieldAccessor that does support recursion.
<T,F> FieldAccessor<T,F>	createSimpleProductFieldAccessor(int pos, TypeInformation<T> typeInfo, ExecutionConfig config) Deprecated. Returns a product FieldAccessor that does not support recursion.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.streaming.util.typeutils.ScalaProductFieldAccessorFactory

load

Constructor Detail

DefaultScalaProductFieldAccessorFactory

public DefaultScalaProductFieldAccessorFactory()

Deprecated.

Method Detail

createSimpleProductFieldAccessor

public <T,F> FieldAccessor<T,F> createSimpleProductFieldAccessor(int pos,
                                                                 TypeInformation<T> typeInfo,
                                                                 ExecutionConfig config)

Deprecated.

Description copied from interface: ScalaProductFieldAccessorFactory

Returns a product FieldAccessor that does not support recursion.

Specified by:

createSimpleProductFieldAccessor in interface ScalaProductFieldAccessorFactory

createRecursiveProductFieldAccessor

public <T,R,F> FieldAccessor<T,F> createRecursiveProductFieldAccessor(int pos,
                                                                      TypeInformation<T> typeInfo,
                                                                      FieldAccessor<R,F> innerAccessor,
                                                                      ExecutionConfig config)

Deprecated.

Description copied from interface: ScalaProductFieldAccessorFactory

Returns a product FieldAccessor that does support recursion.

Specified by:

createRecursiveProductFieldAccessor in interface ScalaProductFieldAccessorFactory