ParallelIteratorInputFormat (Flink : Java 1.18.1-cp2 API)

java.lang.Object
- org.apache.flink.api.common.io.RichInputFormat<OT,org.apache.flink.core.io.GenericInputSplit>
- - org.apache.flink.api.common.io.GenericInputFormat<T>
  - - org.apache.flink.api.java.io.ParallelIteratorInputFormat<T>

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.io.InputFormat<T,org.apache.flink.core.io.GenericInputSplit>, org.apache.flink.core.io.InputSplitSource<org.apache.flink.core.io.GenericInputSplit>
```
@Deprecated
@PublicEvolving
public class ParallelIteratorInputFormat<T>
extends org.apache.flink.api.common.io.GenericInputFormat<T>
```
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.

An input format that generates data in parallel through a SplittableIterator.

See Also:

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

Field Summary
- Fields inherited from class org.apache.flink.api.common.io.GenericInputFormat
  partitionNumber

Constructor Summary

Constructors
Constructor Description

ParallelIteratorInputFormat(org.apache.flink.util.SplittableIterator<T> iterator)
Deprecated.

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method	Description
`T`	`nextRecord(T reuse)`	Deprecated.
`void`	`open(org.apache.flink.core.io.GenericInputSplit split)`	Deprecated.
`boolean`	`reachedEnd()`	Deprecated.

Methods inherited from class org.apache.flink.api.common.io.GenericInputFormat
close, configure, createInputSplits, getInputSplitAssigner, getStatistics

Methods inherited from class org.apache.flink.api.common.io.RichInputFormat
closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext

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

- Constructor Detail
  - ParallelIteratorInputFormat
```
public ParallelIteratorInputFormat(org.apache.flink.util.SplittableIterator<T> iterator)
```
    Deprecated.
- Method Detail
  - open
```
public void open(org.apache.flink.core.io.GenericInputSplit split)
          throws IOException
```
    Deprecated.
    
    Specified by:
    
    open in interface org.apache.flink.api.common.io.InputFormat<T,org.apache.flink.core.io.GenericInputSplit>
    
    Overrides:
    
    open in class org.apache.flink.api.common.io.GenericInputFormat<T>
    
    Throws:
    
    IOException
  - reachedEnd
```
public boolean reachedEnd()
```
    Deprecated.
  - nextRecord
```
public T nextRecord(T reuse)
```
    Deprecated.