Package org.apache.flink.api.java.io

Class CollectionInputFormat<T>

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.CollectionInputFormat<T>

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.io.InputFormat<T,org.apache.flink.core.io.GenericInputSplit>, org.apache.flink.api.common.io.NonParallelInput, org.apache.flink.core.io.InputSplitSource<org.apache.flink.core.io.GenericInputSplit>

@Deprecated
@PublicEvolving
public class CollectionInputFormat<T>
extends org.apache.flink.api.common.io.GenericInputFormat<T>
implements org.apache.flink.api.common.io.NonParallelInput

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 returns objects from a collection.

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
CollectionInputFormat(Collection<T> dataSet, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer)	Deprecated.

Method Summary

Modifier and Type	Method	Description
static <X> void	checkCollection(Collection<X> elements, Class<X> viewedAs)	Deprecated.
T	nextRecord(T record)	Deprecated.
void	open(org.apache.flink.core.io.GenericInputSplit split)	Deprecated.
boolean	reachedEnd()	Deprecated.
String	toString()	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, wait, wait, wait

Constructor Detail

CollectionInputFormat

public CollectionInputFormat(Collection<T> dataSet,
                             org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer)

Deprecated.

Method Detail

reachedEnd

public boolean reachedEnd()
                   throws IOException

Deprecated.

Specified by:

reachedEnd in interface org.apache.flink.api.common.io.InputFormat<T,org.apache.flink.core.io.GenericInputSplit>

Throws:

IOException

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

nextRecord

public T nextRecord(T record)
             throws IOException

Deprecated.

Specified by:

nextRecord in interface org.apache.flink.api.common.io.InputFormat<T,org.apache.flink.core.io.GenericInputSplit>

Throws:

IOException

toString

public String toString()

Deprecated.

Overrides:

toString in class Object

checkCollection

public static <X> void checkCollection(Collection<X> elements,
                                       Class<X> viewedAs)

Deprecated.