ResultPartitionWriter (flink 1.0-SNAPSHOT API)

Constructors
Constructor and Description
`ResultPartitionWriter(ResultPartition partition)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`BufferProvider`	`getBufferProvider()`
`int`	`getNumberOfOutputChannels()`
`ResultPartitionID`	`getPartitionId()`
`void`	`onEvent(TaskEvent event)`
`void`	`subscribeToEvent(EventListener<TaskEvent> eventListener, Class<? extends TaskEvent> eventType)`
`void`	`writeBuffer(Buffer buffer, int targetChannel)`
`void`	`writeEndOfSuperstep()`
`void`	`writeEvent(AbstractEvent event, int targetChannel)`
`void`	`writeEventToAllChannels(AbstractEvent event)`

public ResultPartitionWriter(ResultPartition partition)

public ResultPartitionID getPartitionId()

public BufferProvider getBufferProvider()

public int getNumberOfOutputChannels()

public void writeBuffer(Buffer buffer,
                        int targetChannel)
                 throws IOException

public void writeEvent(AbstractEvent event,
                       int targetChannel)
                throws IOException

public void writeEventToAllChannels(AbstractEvent event)
                             throws IOException

public void writeEndOfSuperstep()
                         throws IOException

public void subscribeToEvent(EventListener<TaskEvent> eventListener,
                             Class<? extends TaskEvent> eventType)

Back to Flink Website