org.apache.flink.optimizer.postpass

Class AbstractSchema<X>

java.lang.Object

org.apache.flink.optimizer.postpass.AbstractSchema<X>

All Implemented Interfaces:

Iterable<Map.Entry<Integer,X>>

Direct Known Subclasses:

SparseKeySchema

public abstract class AbstractSchema<X>
extends Object
implements Iterable<Map.Entry<Integer,X>>

Constructor Summary

Constructors

Constructor and Description
AbstractSchema()

Method Summary

Modifier and Type	Method and Description
abstract void	addType(int pos, X type)
int	getNumConnectionsThatContributed()
abstract X	getType(int field)
void	increaseNumConnectionsThatContributed()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Constructor Detail

AbstractSchema

public AbstractSchema()

Method Detail

getNumConnectionsThatContributed

public int getNumConnectionsThatContributed()

increaseNumConnectionsThatContributed

public void increaseNumConnectionsThatContributed()

addType

public abstract void addType(int pos,
                             X type)
                      throws ConflictingFieldTypeInfoException

Throws:

ConflictingFieldTypeInfoException

getType

public abstract X getType(int field)