org.apache.flink.util (Confluent Flink Table API for Java)

package org.apache.flink.util

Class

Description

CloseableIterator<T>

This interface represents an Iterator that is also AutoCloseable.

CloseableIterator.IteratorAdapter<E>

Adapter from Iterator to CloseableIterator.

Collector<T>

Collects a record and forwards it.