| Interface | Description |
|---|---|
| IAdapterExecutor | |
| IFeedAdapterFactory | |
| IFeedMessage | |
| IPullBasedFeedAdapter | |
| ITypedAdapterFactory | |
| MessageListener.IMessageAnalyzer | |
| RemoteSocketMessageListener.IMessageAnalyzer |
| Class | Description |
|---|---|
| AbstractDatasourceAdapter |
Represents the base class that is required to be extended by every
implementation of the IDatasourceAdapter interface.
|
| AbstractFeedDatasourceAdapter | |
| AdapterExecutor | |
| AdapterIdentifier |
A unique identifier for a data source adapter.
|
| AdapterRuntimeManager | |
| BuiltinFeedPolicies | |
| CollectTransformFeedFrameWriter | |
| EndFeedMessage |
A feed control message indicating the need to end the feed.
|
| ExternalDataScanOperatorDescriptor | |
| FeedActivityIdFactory | |
| FeedCollectOperatorDescriptor |
FeedCollectOperatorDescriptor is responsible for ingesting data from an external source.
|
| FeedCollectOperatorNodePushable |
The runtime for @see{FeedIntakeOperationDescriptor}
|
| FeedConnectionManager |
An implementation of the IFeedManager interface.
|
| FeedFrameTupleDecorator | |
| FeedIntakeOperatorDescriptor |
An operator responsible for establishing connection with external data source and parsing,
translating the received content.It uses an instance of feed adaptor to perform these functions.
|
| FeedIntakeOperatorNodePushable |
The runtime for @see{FeedIntakeOperationDescriptor}.
|
| FeedLifecycleEventSubscriber | |
| FeedManagerElectMessage |
A feed control message containing the altered values for
adapter configuration parameters.
|
| FeedMessage |
A control message that can be sent to the runtime instance of a
feed's adapter.
|
| FeedMessageOperatorDescriptor |
Sends a control message to the registered message queue for feed specified by its feedId.
|
| FeedMessageOperatorNodePushable |
Runtime for the FeedMessageOpertorDescriptor.
|
| FeedMetaComputeNodePushable | |
| FeedMetaNodePushable | |
| FeedMetaOperatorDescriptor |
FeedMetaOperatorDescriptor is a wrapper operator that provides a sanboox like
environment for an hyracks operator that is part of a feed ingestion
pipeline.
|
| FeedMetaStoreNodePushable | |
| FeedPolicyEnforcer | |
| FeedSubscriptionManager | |
| FeedUtil |
A utility class for providing helper functions for feeds
|
| FeedWorkManager |
Handles asynchronous execution of feed management related tasks.
|
| MessageListener | |
| PrepareStallMessage |
A feed control message indicating the need to end the feed.
|
| RemoteSocketMessageListener | |
| SocketMessageListener |
Listens for messages at a configured port and redirects them to a
an instance of
IMessageReceiver. |
| TerminateDataFlowMessage | |
| XAQLFeedMessage |
A feed control message indicating the need to execute a give AQL.
|
| Enum | Description |
|---|---|
| IFeedMessage.MessageType |
Copyright © 2016 The Apache Software Foundation. All rights reserved.