public class FeedUtil extends Object
| Constructor and Description |
|---|
FeedUtil() |
| 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) |
public static String getFeedPointKeyRep(Feed feed, List<String> appliedFunctions)
public static Dataset validateIfDatasetExists(String dataverse, String datasetName, MetadataTransactionContext ctx) throws AsterixException
AsterixExceptionpublic static Feed validateIfFeedExists(String dataverse, String feedName, MetadataTransactionContext ctx) throws MetadataException, AsterixException
MetadataExceptionAsterixExceptionpublic static FeedPolicy validateIfPolicyExists(String dataverse, String policyName, MetadataTransactionContext ctx) throws AsterixException
AsterixExceptionpublic static org.apache.hyracks.api.job.JobSpecification alterJobSpecificationForFeed(org.apache.hyracks.api.job.JobSpecification spec,
FeedConnectionId feedConnectionId,
Map<String,String> feedPolicyProperties)
public static void increaseCardinality(org.apache.hyracks.api.job.JobSpecification spec,
IFeedRuntime.FeedRuntimeType compute,
int requiredCardinality,
List<String> newLocations)
throws AsterixException
AsterixExceptionpublic static void decreaseComputeCardinality(org.apache.hyracks.api.job.JobSpecification spec,
IFeedRuntime.FeedRuntimeType compute,
int requiredCardinality,
List<String> currentLocations)
throws AsterixException
AsterixExceptionpublic 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
org.apache.hyracks.algebricks.common.exceptions.AlgebricksExceptionpublic static String getSecondaryFeedOutput(SecondaryFeed feed, FeedPolicyAccessor policyAccessor, MetadataTransactionContext mdTxnCtx) throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException, MetadataException
org.apache.hyracks.algebricks.common.exceptions.AlgebricksExceptionMetadataExceptionCopyright © 2016 The Apache Software Foundation. All rights reserved.