org.apache.asterix.metadata.feeds

Class FeedMetaComputeNodePushable

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.FeedMetaComputeNodePushable

All Implemented Interfaces:

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

public class FeedMetaComputeNodePushable
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
FeedMetaComputeNodePushable(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

FeedMetaComputeNodePushable

public FeedMetaComputeNodePushable(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