org.apache.asterix.metadata.feeds

Class FeedUtil

java.lang.Object

org.apache.asterix.metadata.feeds.FeedUtil

public class FeedUtil
extends Object

A utility class for providing helper functions for feeds

Constructor Summary

Constructors

Constructor and Description
FeedUtil()

Method Summary

Methods

Modifier and Type	Method and Description
static org.apache.hyracks.api.job.JobSpecification	alterJobSpecificationForFeed(org.apache.hyracks.api.job.JobSpecification spec, FeedConnectionId feedConnectionId, Map<String,String> feedPolicyProperties)
static void	decreaseComputeCardinality(org.apache.hyracks.api.job.JobSpecification spec, IFeedRuntime.FeedRuntimeType compute, int requiredCardinality, List<String> currentLocations)
static String	getFeedPointKeyRep(Feed feed, List<String> appliedFunctions)
static org.apache.hyracks.algebricks.common.utils.Triple<IFeedAdapterFactory,ARecordType,DatasourceAdapter.AdapterType>	getPrimaryFeedFactoryAndOutput(PrimaryFeed feed, FeedPolicyAccessor policyAccessor, MetadataTransactionContext mdTxnCtx)
static String	getSecondaryFeedOutput(SecondaryFeed feed, FeedPolicyAccessor policyAccessor, MetadataTransactionContext mdTxnCtx)
static void	increaseCardinality(org.apache.hyracks.api.job.JobSpecification spec, IFeedRuntime.FeedRuntimeType compute, int requiredCardinality, List<String> newLocations)
static Dataset	validateIfDatasetExists(String dataverse, String datasetName, MetadataTransactionContext ctx)
static Feed	validateIfFeedExists(String dataverse, String feedName, MetadataTransactionContext ctx)
static FeedPolicy	validateIfPolicyExists(String dataverse, String policyName, MetadataTransactionContext ctx)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FeedUtil

public FeedUtil()

Method Detail

getFeedPointKeyRep

public static String getFeedPointKeyRep(Feed feed,
                        List<String> appliedFunctions)

validateIfDatasetExists

public static Dataset validateIfDatasetExists(String dataverse,
                              String datasetName,
                              MetadataTransactionContext ctx)
                                       throws AsterixException

Throws:

AsterixException

validateIfFeedExists

public static Feed validateIfFeedExists(String dataverse,
                        String feedName,
                        MetadataTransactionContext ctx)
                                 throws MetadataException,
                                        AsterixException

Throws:

MetadataException

AsterixException

validateIfPolicyExists

public static FeedPolicy validateIfPolicyExists(String dataverse,
                                String policyName,
                                MetadataTransactionContext ctx)
                                         throws AsterixException

Throws:

AsterixException

alterJobSpecificationForFeed

public static org.apache.hyracks.api.job.JobSpecification alterJobSpecificationForFeed(org.apache.hyracks.api.job.JobSpecification spec,
                                                                       FeedConnectionId feedConnectionId,
                                                                       Map<String,String> feedPolicyProperties)

increaseCardinality

public static void increaseCardinality(org.apache.hyracks.api.job.JobSpecification spec,
                       IFeedRuntime.FeedRuntimeType compute,
                       int requiredCardinality,
                       List<String> newLocations)
                                throws AsterixException

Throws:

AsterixException

decreaseComputeCardinality

public static void decreaseComputeCardinality(org.apache.hyracks.api.job.JobSpecification spec,
                              IFeedRuntime.FeedRuntimeType compute,
                              int requiredCardinality,
                              List<String> currentLocations)
                                       throws AsterixException

Throws:

AsterixException

getPrimaryFeedFactoryAndOutput

public static org.apache.hyracks.algebricks.common.utils.Triple<IFeedAdapterFactory,ARecordType,DatasourceAdapter.AdapterType> getPrimaryFeedFactoryAndOutput(PrimaryFeed feed,
                                                                                                                                              FeedPolicyAccessor policyAccessor,
                                                                                                                                              MetadataTransactionContext mdTxnCtx)
                                                                                                                                                       throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

getSecondaryFeedOutput

public static String getSecondaryFeedOutput(SecondaryFeed feed,
                            FeedPolicyAccessor policyAccessor,
                            MetadataTransactionContext mdTxnCtx)
                                     throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException,
                                            MetadataException

Throws:

org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

MetadataException