hub / github.com/baidu/bigflow / FlumeIteratorDelegator

Class FlumeIteratorDelegator

bigflow_python/delegators/python_processor_delegator.h:55–76 · view source on GitHub ↗

FlumeIteratorDelegator is used to wrap flume::core::Iterator*. It act like a Python Iterator by: 1. Exposing next() method 2. Throwing an StopIteration when iteration is done.

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 1

BOOST_FOREACHFunction · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected