OneForOneStreamManager

Caution
FIXME

registerStream Method

long registerStream(String appId, Iterator<ManagedBuffer> buffers)
Caution
FIXME

results matching ""

    No results matching ""