SingleInputOperator (Flink : Java 1.19.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,O>

Type Parameters:

IN - The data type of the input data set.

OUT - The data type of the returned data set.

Direct Known Subclasses:

AggregateOperator, DistinctOperator, IterativeDataSet, PartitionOperator, ProjectOperator, SingleInputUdfOperator, SortPartitionOperator
```
@Deprecated
@Public
public abstract class SingleInputOperator<IN,OUT,O extends SingleInputOperator<IN,OUT,O>>
extends Operator<OUT,O>
```
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.

Base class for operations that operates on a single input data set.

See Also:

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

Field Summary
- 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
Modifier	Constructor	Description
`protected`	`SingleInputOperator(DataSet<IN> input, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> resultType)`	Deprecated.

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods Deprecated Methods
Modifier and Type	Method	Description
`DataSet<IN>`	`getInput()`	Deprecated. Gets the data set that this operation uses as its input.
`org.apache.flink.api.common.typeinfo.TypeInformation<IN>`	`getInputType()`	Deprecated. Gets the type information of the data type of the input data set.
`protected abstract org.apache.flink.api.common.operators.Operator<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.

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

- Constructor Detail
  - SingleInputOperator
```
protected SingleInputOperator(DataSet<IN> input,
                              org.apache.flink.api.common.typeinfo.TypeInformation<OUT> resultType)
```
    Deprecated.
- Method Detail
  - getInput
```
public DataSet<IN> getInput()
```
    Deprecated.
    
    Gets the data set that this operation uses as its input.
    
    Returns:
    
    The data set that this operation uses as its input.
  - getInputType
```
public org.apache.flink.api.common.typeinfo.TypeInformation<IN> getInputType()
```
    Deprecated.
    
    Gets the type information of the data type of the input data set. This method returns equivalent information as getInput().getType().
    
    Returns:
    
    The input data type.
  - translateToDataFlow
```
protected abstract org.apache.flink.api.common.operators.Operator<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.
    
    Parameters:
    
    input - The data flow operator that produces this operation's input data.
    
    Returns:
    
    The translated data flow operator.