org.apache.flink.util

Interface Disposable

All Known Subinterfaces:

InMemorySorter<T>, KeyedStateBackend<K>, OneInputStreamOperator<IN,OUT>, OperatorStateBackend, Savepoint, StreamOperator<OUT>, TwoInputStreamOperator<IN1,IN2,OUT>

All Known Implementing Classes:

AbstractKeyedStateBackend, AbstractStreamOperator, AbstractUdfStreamOperator, AsyncWaitOperator, CassandraRowWriteAheadSink, CassandraTupleWriteAheadSink, CepOperator, CoBroadcastWithKeyedOperator, CoBroadcastWithNonKeyedOperator, ContinuousFileReaderOperator, CoProcessOperator, CoStreamFlatMap, CoStreamMap, DefaultOperatorStateBackend, EvictingWindowOperator, ExtractTimestampsOperator, FixedLengthRecordSorter, GenericWriteAheadSink, HeapKeyedStateBackend, IntervalJoinOperator, KeyedCoProcessOperator, KeyedProcessOperator, LegacyKeyedProcessOperator, NormalizedKeySorter, ProcessOperator, QueryableAppendingStateOperator, QueryableValueStateOperator, RocksDBKeyedStateBackend, SavepointV1, SavepointV2, StoppableStreamSource, StreamFilter, StreamFlatMap, StreamGroupedFold, StreamGroupedReduce, StreamMap, StreamProject, StreamSink, StreamSource, TimestampsAndPeriodicWatermarksOperator, TimestampsAndPunctuatedWatermarksOperator, WindowOperator

public interface Disposable

Interface for classes that can be disposed, i.e. that have a dedicated lifecycle step to "destroy" the object. On reason for this is for example to release native resources. From this point, the interface fulfills a similar purpose as the Closeable interface, but sometimes both should be represented as isolated, independent lifecycle steps.

Method Summary

Modifier and Type	Method and Description
void	dispose() Disposes the object and releases all resources.

Method Detail

dispose

void dispose()
      throws Exception

Disposes the object and releases all resources. After calling this method, calling any methods on the object may result in undefined behavior.

Throws:

Exception - if something goes wrong during disposal.