org.apache.asterix.metadata.declared

Class FieldExtractingAdapterFactory

java.lang.Object

org.apache.asterix.metadata.declared.FieldExtractingAdapterFactory

All Implemented Interfaces:

Serializable, IAdapterFactory

public class FieldExtractingAdapterFactory
extends Object
implements IAdapterFactory

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.asterix.metadata.external.IAdapterFactory

IAdapterFactory.SupportedOperation

Field Summary

Fields inherited from interface org.apache.asterix.metadata.external.IAdapterFactory

KEY_TYPE_NAME

Constructor Summary

Constructors

Constructor and Description
FieldExtractingAdapterFactory(IAdapterFactory wrappedAdapterFactory, org.apache.hyracks.api.dataflow.value.RecordDescriptor inRecDesc, org.apache.hyracks.api.dataflow.value.RecordDescriptor outRecDesc, int[][] extractFields, ARecordType rType)

Method Summary

Methods

Modifier and Type	Method and Description
void	configure(Map<String,String> configuration, ARecordType outputType)
IDatasourceAdapter	createAdapter(org.apache.hyracks.api.context.IHyracksTaskContext ctx, int partition) Creates an instance of IDatasourceAdapter.
ARecordType	getAdapterOutputType() Gets the record type associated with the output of the adapter
String	getName() Returns the display name corresponding to the Adapter type that is created by the factory.
org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint	getPartitionConstraint() Gets a list of partition constraints.
IAdapterFactory.SupportedOperation	getSupportedOperations() Returns the type of adapter indicating if the adapter can be used for reading from an external data source or writing to an external data source or can be used for both purposes.

Methods inherited from class java.lang.Object

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

Constructor Detail

FieldExtractingAdapterFactory

public FieldExtractingAdapterFactory(IAdapterFactory wrappedAdapterFactory,
                             org.apache.hyracks.api.dataflow.value.RecordDescriptor inRecDesc,
                             org.apache.hyracks.api.dataflow.value.RecordDescriptor outRecDesc,
                             int[][] extractFields,
                             ARecordType rType)

Method Detail

getSupportedOperations

public IAdapterFactory.SupportedOperation getSupportedOperations()

Description copied from interface: IAdapterFactory

Returns the type of adapter indicating if the adapter can be used for reading from an external data source or writing to an external data source or can be used for both purposes.

Specified by:

getSupportedOperations in interface IAdapterFactory

Returns:

See Also:

IAdapterFactory.SupportedOperation

getName

public String getName()

Description copied from interface: IAdapterFactory

Returns the display name corresponding to the Adapter type that is created by the factory.

Specified by:

getName in interface IAdapterFactory

Returns:

the display name

getPartitionConstraint

public org.apache.hyracks.algebricks.common.constraints.AlgebricksPartitionConstraint getPartitionConstraint()
                                                                                                      throws Exception

Description copied from interface: IAdapterFactory

Gets a list of partition constraints. A partition constraint can be a requirement to execute at a particular location or could be cardinality constraints indicating the number of instances that need to run in parallel. example, a IDatasourceAdapter implementation written for data residing on the local file system of a node cannot run on any other node and thus has a location partition constraint. The location partition constraint can be expressed as a node IP address or a node controller id. In the former case, the IP address is translated to a node controller id running on the node with the given IP address.

Specified by:

getPartitionConstraint in interface IAdapterFactory

Throws:

Exception

createAdapter

public IDatasourceAdapter createAdapter(org.apache.hyracks.api.context.IHyracksTaskContext ctx,
                               int partition)
                                 throws Exception

Description copied from interface: IAdapterFactory

Creates an instance of IDatasourceAdapter.

Specified by:

createAdapter in interface IAdapterFactory

Returns:

An instance of IDatasourceAdapter.

Throws:

Exception

configure

public void configure(Map<String,String> configuration,
             ARecordType outputType)
               throws Exception

Specified by:

configure in interface IAdapterFactory

Throws:

Exception

getAdapterOutputType

public ARecordType getAdapterOutputType()

Description copied from interface: IAdapterFactory

Gets the record type associated with the output of the adapter

Specified by:

getAdapterOutputType in interface IAdapterFactory

Returns: