ProjectOperator (Flink : Java 1.18.1-cp2 API)

java.lang.Object
- org.apache.flink.api.java.DataSet<OUT>
- - org.apache.flink.api.java.operators.Operator<OUT,O>
  - - org.apache.flink.api.java.operators.SingleInputOperator<IN,OUT,ProjectOperator<IN,OUT>>
    - - org.apache.flink.api.java.operators.ProjectOperator<IN,OUT>

Type Parameters:

IN - The type of the data set projected by the operator.

OUT - The type of data set that is the result of the projection.
```
@Deprecated
@Public
public class ProjectOperator<IN,OUT extends org.apache.flink.api.java.tuple.Tuple>
extends SingleInputOperator<IN,OUT,ProjectOperator<IN,OUT>>
```
Deprecated.
All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.

This operator represents the application of a projection operation on a data set, and the result data set produced by the function.

See Also:

FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs (and deprecate the DataSet API

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class ProjectOperator.Projection<T>
Deprecated.

A projection of DataSet.

Field Summary

Fields
Modifier and Type Field Description

protected int[] fields
Deprecated.
- Fields inherited from class org.apache.flink.api.java.operators.Operator
  minResources, name, parallelism, preferredResources
- Fields inherited from class org.apache.flink.api.java.DataSet
  context

Constructor Summary

Constructors
Constructor	Description
`ProjectOperator(DataSet<IN> input, int[] fields, org.apache.flink.api.java.typeutils.TupleTypeInfo<OUT> returnType)`	Deprecated.

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method	Description
`protected org.apache.flink.api.common.operators.base.MapOperatorBase<IN,OUT,org.apache.flink.api.common.functions.MapFunction<IN,OUT>>`	`translateToDataFlow(org.apache.flink.api.common.operators.Operator<IN> input)`	Deprecated. Translates this operation to a data flow operator of the common data flow API.
`<R extends org.apache.flink.api.java.tuple.Tuple> ProjectOperator<IN,R>`	`types(Class<?>... types)`	Deprecated. Deprecated method only kept for compatibility.

Methods inherited from class org.apache.flink.api.java.operators.SingleInputOperator
getInput, getInputType

Methods inherited from class org.apache.flink.api.java.operators.Operator
getMinResources, getName, getParallelism, getPreferredResources, getResultType, name, setParallelism

Methods inherited from class org.apache.flink.api.java.DataSet
aggregate, checkSameExecutionContext, clean, coGroup, collect, combineGroup, count, cross, crossWithHuge, crossWithTiny, distinct, distinct, distinct, distinct, fillInType, filter, first, flatMap, fullOuterJoin, fullOuterJoin, getExecutionEnvironment, getType, groupBy, groupBy, groupBy, iterate, iterateDelta, join, join, joinWithHuge, joinWithTiny, leftOuterJoin, leftOuterJoin, map, mapPartition, max, maxBy, min, minBy, output, partitionByHash, partitionByHash, partitionByHash, partitionByRange, partitionByRange, partitionByRange, partitionCustom, partitionCustom, partitionCustom, print, print, printOnTaskManager, printToErr, printToErr, project, rebalance, reduce, reduceGroup, rightOuterJoin, rightOuterJoin, runOperation, sortPartition, sortPartition, sortPartition, sum, union, write, write, writeAsCsv, writeAsCsv, writeAsCsv, writeAsCsv, writeAsFormattedText, writeAsFormattedText, writeAsText, writeAsText

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - fields
```
protected final int[] fields
```
    Deprecated.
- Constructor Detail
  - ProjectOperator
```
public ProjectOperator(DataSet<IN> input,
                       int[] fields,
                       org.apache.flink.api.java.typeutils.TupleTypeInfo<OUT> returnType)
```
    Deprecated.
- Method Detail
  - translateToDataFlow
```
protected org.apache.flink.api.common.operators.base.MapOperatorBase<IN,OUT,org.apache.flink.api.common.functions.MapFunction<IN,OUT>> translateToDataFlow(org.apache.flink.api.common.operators.Operator<IN> input)
```
    Deprecated.
    
    Description copied from class: SingleInputOperator
    
    Translates this operation to a data flow operator of the common data flow API.
    
    Specified by:
    
    translateToDataFlow in class SingleInputOperator<IN,OUT extends org.apache.flink.api.java.tuple.Tuple,ProjectOperator<IN,OUT extends org.apache.flink.api.java.tuple.Tuple>>
    
    Parameters:
    
    input - The data flow operator that produces this operation's input data.
    
    Returns:
    
    The translated data flow operator.
  - types
```
@Deprecated
@PublicEvolving
public <R extends org.apache.flink.api.java.tuple.Tuple> ProjectOperator<IN,R> types(Class<?>... types)
```
    Deprecated.
    Deprecated method only kept for compatibility.