org.apache.asterix.metadata.declared

Class AqlCompiledMetadataDeclarations

java.lang.Object

org.apache.asterix.metadata.declared.AqlCompiledMetadataDeclarations

public class AqlCompiledMetadataDeclarations
extends Object

Constructor Summary

Constructors

Constructor and Description
AqlCompiledMetadataDeclarations(MetadataTransactionContext mdTxnCtx, String dataverseName, org.apache.hyracks.dataflow.std.file.FileSplit outputFile, Map<String,String> config, Map<String,String[]> stores, Map<String,IAType> types, Map<String,TypeDataGen> typeDataGenMap, org.apache.hyracks.algebricks.data.IAWriterFactory writerFactory, boolean online)

Method Summary

Methods

Modifier and Type	Method and Description
void	connectToDataverse(String dvName)
void	disconnectFromDataverse()
Dataset	findDataset(String datasetName)
List<String>	findNodeGroupNodeNames(String nodeGroupName)
IAType	findType(String typeName)
Map<String,String[]>	getAllStores()
List<Index>	getDatasetIndexes(String dataverseName, String datasetName)
Index	getDatasetPrimaryIndex(String dataverseName, String datasetName)
String	getDataverseName()
IDataFormat	getFormat()
Index	getIndex(String dataverseName, String datasetName, String indexName)
MetadataTransactionContext	getMetadataTransactionContext()
org.apache.hyracks.dataflow.std.file.FileSplit	getOutputFile()
String	getPropertyValue(String propertyName)
String	getRelativePath(String fileName)
Map<String,TypeDataGen>	getTypeDataGenMap()
Map<String,IAType>	getTypeDeclarations()
org.apache.hyracks.algebricks.data.IAWriterFactory	getWriterFactory()
boolean	isConnectedToDataverse()
void	setOutputFile(org.apache.hyracks.dataflow.std.file.FileSplit outputFile)
org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.dataflow.std.file.IFileSplitProvider,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint>	splitProviderAndPartitionConstraintsForInternalOrFeedDataset(String datasetName, String targetIdxName)

Methods inherited from class java.lang.Object

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

Constructor Detail

AqlCompiledMetadataDeclarations

public AqlCompiledMetadataDeclarations(MetadataTransactionContext mdTxnCtx,
                               String dataverseName,
                               org.apache.hyracks.dataflow.std.file.FileSplit outputFile,
                               Map<String,String> config,
                               Map<String,String[]> stores,
                               Map<String,IAType> types,
                               Map<String,TypeDataGen> typeDataGenMap,
                               org.apache.hyracks.algebricks.data.IAWriterFactory writerFactory,
                               boolean online)

Method Detail

connectToDataverse

public void connectToDataverse(String dvName)
                        throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException,
                               AsterixException

Throws:

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

AsterixException

disconnectFromDataverse

public void disconnectFromDataverse()
                             throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

isConnectedToDataverse

public boolean isConnectedToDataverse()

getDataverseName

public String getDataverseName()

getOutputFile

public org.apache.hyracks.dataflow.std.file.FileSplit getOutputFile()

getFormat

public IDataFormat getFormat()
                      throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

getPropertyValue

public String getPropertyValue(String propertyName)

findType

public IAType findType(String typeName)

findNodeGroupNodeNames

public List<String> findNodeGroupNodeNames(String nodeGroupName)
                                    throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

getAllStores

public Map<String,String[]> getAllStores()

findDataset

public Dataset findDataset(String datasetName)
                    throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

getDatasetIndexes

public List<Index> getDatasetIndexes(String dataverseName,
                            String datasetName)
                              throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

getDatasetPrimaryIndex

public Index getDatasetPrimaryIndex(String dataverseName,
                           String datasetName)
                             throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

getIndex

public Index getIndex(String dataverseName,
             String datasetName,
             String indexName)
               throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

setOutputFile

public void setOutputFile(org.apache.hyracks.dataflow.std.file.FileSplit outputFile)

splitProviderAndPartitionConstraintsForInternalOrFeedDataset

public org.apache.hyracks.algebricks.common.utils.Pair<org.apache.hyracks.dataflow.std.file.IFileSplitProvider,org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint> splitProviderAndPartitionConstraintsForInternalOrFeedDataset(String datasetName,
                                                                                                                                                                                                                                                   String targetIdxName)
                                                                                                                                                                                                                                                     throws org.apache.hyracks.algebricks.common.exceptions.AlgebricksException

Throws:

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

getRelativePath

public String getRelativePath(String fileName)

getTypeDataGenMap

public Map<String,TypeDataGen> getTypeDataGenMap()

getTypeDeclarations

public Map<String,IAType> getTypeDeclarations()

getWriterFactory

public org.apache.hyracks.algebricks.data.IAWriterFactory getWriterFactory()

getMetadataTransactionContext

public MetadataTransactionContext getMetadataTransactionContext()