org.apache.asterix.metadata.feeds

Class FeedMetaNodePushable

java.lang.Object

org.apache.hyracks.dataflow.std.base.AbstractOperatorNodePushable

org.apache.hyracks.dataflow.std.base.AbstractUnaryOutputOperatorNodePushable

org.apache.hyracks.dataflow.std.base.AbstractUnaryInputUnaryOutputOperatorNodePushable

org.apache.asterix.metadata.feeds.FeedMetaNodePushable

All Implemented Interfaces:

org.apache.hyracks.api.comm.IFrameWriter, org.apache.hyracks.api.dataflow.IOperatorNodePushable

public class FeedMetaNodePushable
extends org.apache.hyracks.dataflow.std.base.AbstractUnaryInputUnaryOutputOperatorNodePushable

Field Summary

Fields inherited from class org.apache.hyracks.dataflow.std.base.AbstractUnaryOutputOperatorNodePushable

recordDesc, writer

Constructor Summary

Constructors

Constructor and Description
FeedMetaNodePushable(org.apache.hyracks.api.context.IHyracksTaskContext ctx, org.apache.hyracks.api.dataflow.value.IRecordDescriptorProvider recordDescProvider, int partition, int nPartitions, org.apache.hyracks.api.dataflow.IOperatorDescriptor coreOperator, FeedConnectionId feedConnectionId, Map<String,String> feedPolicyProperties, String operationId)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	fail()
void	nextFrame(ByteBuffer buffer)
void	open()

Methods inherited from class org.apache.hyracks.dataflow.std.base.AbstractUnaryInputUnaryOutputOperatorNodePushable

getInputArity, getInputFrameWriter

Methods inherited from class org.apache.hyracks.dataflow.std.base.AbstractUnaryOutputOperatorNodePushable

deinitialize, initialize, setOutputFrameWriter

Methods inherited from class org.apache.hyracks.dataflow.std.base.AbstractOperatorNodePushable

getDisplayName

Methods inherited from class java.lang.Object

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

Constructor Detail

FeedMetaNodePushable

public FeedMetaNodePushable(org.apache.hyracks.api.context.IHyracksTaskContext ctx,
                    org.apache.hyracks.api.dataflow.value.IRecordDescriptorProvider recordDescProvider,
                    int partition,
                    int nPartitions,
                    org.apache.hyracks.api.dataflow.IOperatorDescriptor coreOperator,
                    FeedConnectionId feedConnectionId,
                    Map<String,String> feedPolicyProperties,
                    String operationId)
                     throws org.apache.hyracks.api.exceptions.HyracksDataException

Throws:

org.apache.hyracks.api.exceptions.HyracksDataException

Method Detail

open

public void open()
          throws org.apache.hyracks.api.exceptions.HyracksDataException

Throws:

org.apache.hyracks.api.exceptions.HyracksDataException

nextFrame

public void nextFrame(ByteBuffer buffer)
               throws org.apache.hyracks.api.exceptions.HyracksDataException

Throws:

org.apache.hyracks.api.exceptions.HyracksDataException

fail

public void fail()
          throws org.apache.hyracks.api.exceptions.HyracksDataException

Throws:

org.apache.hyracks.api.exceptions.HyracksDataException

close

public void close()
           throws org.apache.hyracks.api.exceptions.HyracksDataException

Throws:

org.apache.hyracks.api.exceptions.HyracksDataException