| Package | Description |
|---|---|
| co.cask.cdap.messaging |
| Modifier and Type | Method and Description |
|---|---|
abstract co.cask.cdap.api.dataset.lib.CloseableIterator<RawMessage> |
MessageFetcher.fetch()
Returns a
CloseableIterator that iterates over messages fetched from the messaging system. |
Copyright © 2017 Cask Data, Inc. Licensed under the Apache License, Version 2.0.