OUT
- The type of the data set produced by this operator.O
- The type of the operator, so that we can return it.@Deprecated @Public public abstract class Operator<OUT,O extends Operator<OUT,O>> extends DataSet<OUT>
Modifier and Type | Field and Description |
---|---|
protected ResourceSpec |
minResources
Deprecated.
|
protected String |
name
Deprecated.
|
protected int |
parallelism
Deprecated.
|
protected ResourceSpec |
preferredResources
Deprecated.
|
Modifier | Constructor and Description |
---|---|
protected |
Operator(ExecutionEnvironment context,
TypeInformation<OUT> resultType)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
ResourceSpec |
getMinResources()
Deprecated.
Returns the minimum resource of this operator.
|
String |
getName()
Deprecated.
Returns the name of the operator.
|
int |
getParallelism()
Deprecated.
Returns the parallelism of this operator.
|
ResourceSpec |
getPreferredResources()
Deprecated.
Returns the preferred resource of this operator.
|
TypeInformation<OUT> |
getResultType()
Deprecated.
Returns the type of the result of this operator.
|
O |
name(String newName)
Deprecated.
Sets the name of this operator.
|
O |
setParallelism(int parallelism)
Deprecated.
Sets the parallelism for this operator.
|
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
protected String name
protected int parallelism
protected ResourceSpec minResources
protected ResourceSpec preferredResources
protected Operator(ExecutionEnvironment context, TypeInformation<OUT> resultType)
public TypeInformation<OUT> getResultType()
public String getName()
public int getParallelism()
public ResourceSpec getMinResources()
public ResourceSpec getPreferredResources()
public O name(String newName)
newName
- The name for this operator.public O setParallelism(int parallelism)
parallelism
- The parallelism for this operator. A value equal to ExecutionConfig.PARALLELISM_DEFAULT
will use the system default.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.