| Package | Description |
|---|---|
| org.apache.asterix.metadata.declared | |
| org.apache.asterix.metadata.feeds |
| Modifier and Type | Method and Description |
|---|---|
org.apache.hyracks.algebricks.common.utils.Triple<org.apache.hyracks.api.dataflow.IOperatorDescriptor,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint,IFeedAdapterFactory> |
AqlMetadataProvider.buildFeedIntakeRuntime(org.apache.hyracks.api.job.JobSpecification jobSpec,
PrimaryFeed primaryFeed,
FeedPolicyAccessor policyAccessor) |
| Modifier and Type | Method and Description |
|---|---|
static org.apache.hyracks.algebricks.common.utils.Triple<IFeedAdapterFactory,ARecordType,DatasourceAdapter.AdapterType> |
FeedUtil.getPrimaryFeedFactoryAndOutput(PrimaryFeed feed,
FeedPolicyAccessor policyAccessor,
MetadataTransactionContext mdTxnCtx) |
| Constructor and Description |
|---|
FeedIntakeOperatorDescriptor(org.apache.hyracks.api.job.JobSpecification spec,
PrimaryFeed primaryFeed,
IFeedAdapterFactory adapterFactory,
ARecordType adapterOutputType,
FeedPolicyAccessor policyAccessor) |
FeedIntakeOperatorNodePushable(org.apache.hyracks.api.context.IHyracksTaskContext ctx,
FeedId feedId,
IFeedAdapterFactory adapterFactory,
int partition,
IngestionRuntime ingestionRuntime,
FeedPolicyAccessor policyAccessor) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.