AbstractDataStream (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.datastream.impl.stream.AbstractDataStream<T>

All Implemented Interfaces:

DataStream

Direct Known Subclasses:

BroadcastStreamImpl, GlobalStreamImpl, KeyedPartitionStreamImpl, NonKeyedPartitionStreamImpl
```
public abstract class AbstractDataStream<T>
extends Object
implements DataStream
```
Base class for all streams.
Note: This is only used for internal implementation. It must not leak to user face api.

Field Summary

Fields
Modifier and Type	Field	Description
`protected ExecutionEnvironmentImpl`	`environment`
`protected Map<OutputTag<?>,TypeInformation<?>>`	`requestedSideOutputs`	We keep track of the side outputs that were already requested and their types.
`protected Transformation<T>`	`transformation`

Constructor Summary

Constructors
Constructor Description

AbstractDataStream(ExecutionEnvironmentImpl environment, Transformation<T> transformation)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`ExecutionEnvironmentImpl`	`getEnvironment()`
`<X> Transformation<X>`	`getSideOutputTransform(OutputTag<X> outputTag)`
`Transformation<T>`	`getTransformation()`	This is only used for internal implementation.
`TypeInformation<T>`	`getType()`

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

Field Detail
- environment
```
protected final ExecutionEnvironmentImpl environment
```
- transformation
```
protected final Transformation<T> transformation
```
- requestedSideOutputs
```
protected final Map<OutputTag<?>,TypeInformation<?>> requestedSideOutputs
```
  We keep track of the side outputs that were already requested and their types. With this, we can catch the case when a side output with a matching id is requested for a different type because this would lead to problems at runtime.

Constructor Detail

AbstractDataStream

public AbstractDataStream(ExecutionEnvironmentImpl environment,
                          Transformation<T> transformation)

Method Detail

getType
```
public TypeInformation<T> getType()
```

getTransformation
```
public Transformation<T> getTransformation()
```
This is only used for internal implementation. It must not leak to user face api.

getEnvironment

public ExecutionEnvironmentImpl getEnvironment()

getSideOutputTransform

public <X> Transformation<X> getSideOutputTransform(OutputTag<X> outputTag)