InputGate (flink-runtime 0.9.0 API)

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`BufferOrEvent`	`getNextBufferOrEvent()`
`int`	`getNumberOfInputChannels()`
`boolean`	`isFinished()`
`void`	`registerListener(EventListener<InputGate> listener)`
`void`	`requestPartitions()`
`void`	`sendTaskEvent(TaskEvent event)`

void requestPartitions()
                throws IOException,
                       InterruptedException

BufferOrEvent getNextBufferOrEvent()
                            throws IOException,
                                   InterruptedException

void sendTaskEvent(TaskEvent event)
            throws IOException

void registerListener(EventListener<InputGate> listener)

Interface InputGate