CollectionSource (Apache Wayang (incubating) 0.7.1 API)

java.lang.Object
- org.apache.wayang.core.plan.wayangplan.OperatorBase
- - org.apache.wayang.core.plan.wayangplan.UnarySource<T>
  - - org.apache.wayang.basic.operators.CollectionSource<T>

All Implemented Interfaces:

java.io.Serializable, ActualOperator, ElementaryOperator, Operator

Direct Known Subclasses:

FlinkCollectionSource, JavaCollectionSource, SparkCollectionSource, TensorflowCollectionSource
```
public class CollectionSource<T>
extends UnarySource<T>
implements ElementaryOperator
```
This source takes as input a Java Collection.

See Also:

Serialized Form

Nested Class Summary
- Nested classes/interfaces inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase
  OperatorBase.GsonSerializer

Field Summary

Fields
Modifier and Type Field Description

protected java.util.Collection<T> collection
- Fields inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase
  inputSlots, outputSlots, STANDARD_OPERATOR_ARGS
- Fields inherited from interface org.apache.wayang.core.plan.wayangplan.Operator
  FIRST_EPOCH

Constructor Summary

Constructors
Constructor	Description
`CollectionSource(java.util.Collection<T> collection, java.lang.Class<T> typeClass)`
`CollectionSource(java.util.Collection<T> collection, DataSetType<T> type)`
`CollectionSource(CollectionSource that)`	Copies an instance (exclusive of broadcasts).

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`java.util.Optional<CardinalityEstimator>`	`createCardinalityEstimator(int outputIndex, Configuration configuration)`	Provide a `CardinalityEstimator` for the `OutputSlot` at `outputIndex`.
`static <T> CollectionSource<T>`	`empty(java.lang.Class<T> typeClass)`	Creates a new instance without any data quanta.
`java.util.Collection<T>`	`getCollection()`
`static <T> CollectionSource<T>`	`singleton(T value, java.lang.Class<T> typeClass)`	Creates a new instance without any data quanta.

Methods inherited from class org.apache.wayang.core.plan.wayangplan.UnarySource
getOutput, getType

Methods inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase
accept, addBroadcastInput, addTargetPlatform, at, collectMappedInputSlots, collectMappedOutputSlots, copy, createCopy, getAllInputs, getAllOutputs, getCardinalityEstimator, getContainer, getEpoch, getName, getOriginal, getSimpleClassName, getTargetPlatforms, isAuxiliary, isSupportingBroadcastInputs, propagateInputCardinality, propagateOutputCardinality, setAuxiliary, setCardinalityEstimator, setContainer, setEpoch, setName, toString

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

Methods inherited from interface org.apache.wayang.core.plan.wayangplan.ActualOperator
accept

Methods inherited from interface org.apache.wayang.core.plan.wayangplan.ElementaryOperator
getCardinalityEstimator, isAuxiliary, setAuxiliary, setCardinalityEstimator

Methods inherited from interface org.apache.wayang.core.plan.wayangplan.Operator
addBroadcastInput, addTargetPlatform, broadcastTo, broadcastTo, collectMappedInputSlots, collectMappedOutputSlots, connectTo, connectTo, getAllInputs, getAllOutputs, getCardinalityPusher, getContainer, getEffectiveOccupant, getEffectiveOccupant, getEpoch, getEstimationContextProperties, getForwards, getInnermostLoop, getInput, getInput, getLoopStack, getName, getNumBroadcastInputs, getNumInputs, getNumOutputs, getNumRegularInputs, getOuterInputSlot, getOutermostInputSlot, getOutermostOutputSlots, getOutput, getOutput, getParent, getTargetPlatforms, isAlternative, isElementary, isExecutionOperator, isFeedbackInput, isFeedforwardOutput, isLoopHead, isLoopSubplan, isOwnerOf, isReading, isSink, isSource, isSubplan, isSupportingBroadcastInputs, isUnconnected, propagateInputCardinality, propagateOutputCardinality, propagateOutputCardinality, setContainer, setEpoch, setInput, setName, setOutput

Field Detail

collection

protected final java.util.Collection<T> collection

Constructor Detail

CollectionSource

public CollectionSource(java.util.Collection<T> collection,
                        java.lang.Class<T> typeClass)

CollectionSource

public CollectionSource(java.util.Collection<T> collection,
                        DataSetType<T> type)

CollectionSource
```
public CollectionSource(CollectionSource that)
```
Copies an instance (exclusive of broadcasts).

Parameters:

that - that should be copied

Method Detail
- getCollection
```
public java.util.Collection<T> getCollection()
```
- createCardinalityEstimator
```
public java.util.Optional<CardinalityEstimator> createCardinalityEstimator(int outputIndex,
                                                                           Configuration configuration)
```
  Description copied from interface: ElementaryOperator
  
  Provide a CardinalityEstimator for the OutputSlot at outputIndex.
  
  Specified by:
  
  createCardinalityEstimator in interface ElementaryOperator
  
  Parameters:
  
  outputIndex - index of the OutputSlot for that the CardinalityEstimator is requested
  
  configuration - if the CardinalityEstimator depends on further ones, use this to obtain the latter
  
  Returns:
  
  an Optional that might provide the requested instance
- empty
```
public static <T> CollectionSource<T> empty(java.lang.Class<T> typeClass)
```
  Creates a new instance without any data quanta.
- singleton
```
public static <T> CollectionSource<T> singleton(T value,
                                                java.lang.Class<T> typeClass)
```
  Creates a new instance without any data quanta.