org.apache.asterix.metadata.feeds

Class CollectTransformFeedFrameWriter

java.lang.Object

org.apache.asterix.metadata.feeds.CollectTransformFeedFrameWriter

All Implemented Interfaces:

IFeedOperatorOutputSideHandler, org.apache.hyracks.api.comm.IFrameWriter

public class CollectTransformFeedFrameWriter
extends Object
implements IFeedOperatorOutputSideHandler

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.asterix.common.feeds.api.IFeedOperatorOutputSideHandler

IFeedOperatorOutputSideHandler.Type

Constructor Summary

Constructors

Constructor and Description
CollectTransformFeedFrameWriter(org.apache.hyracks.api.context.IHyracksTaskContext ctx, org.apache.hyracks.api.comm.IFrameWriter downstreamWriter, ISubscribableRuntime sourceRuntime, org.apache.hyracks.api.dataflow.value.RecordDescriptor outputRecordDescriptor, FeedConnectionId connectionId)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	fail()
FeedConnectionId	getConnectionId()
org.apache.hyracks.api.comm.IFrameWriter	getDownstreamWriter()
FeedId	getFeedId()
IFeedOperatorOutputSideHandler.Type	getType()
void	nextFrame(ByteBuffer buffer)
void	open()
void	reset(org.apache.hyracks.api.comm.IFrameWriter writer)

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectTransformFeedFrameWriter

public CollectTransformFeedFrameWriter(org.apache.hyracks.api.context.IHyracksTaskContext ctx,
                               org.apache.hyracks.api.comm.IFrameWriter downstreamWriter,
                               ISubscribableRuntime sourceRuntime,
                               org.apache.hyracks.api.dataflow.value.RecordDescriptor outputRecordDescriptor,
                               FeedConnectionId connectionId)
                                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

Specified by:

open in interface org.apache.hyracks.api.comm.IFrameWriter

Throws:

org.apache.hyracks.api.exceptions.HyracksDataException

nextFrame

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

Specified by:

nextFrame in interface org.apache.hyracks.api.comm.IFrameWriter

Throws:

org.apache.hyracks.api.exceptions.HyracksDataException

fail

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

Specified by:

fail in interface org.apache.hyracks.api.comm.IFrameWriter

Throws:

org.apache.hyracks.api.exceptions.HyracksDataException

close

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

Specified by:

close in interface org.apache.hyracks.api.comm.IFrameWriter

Throws:

org.apache.hyracks.api.exceptions.HyracksDataException

getFeedId

public FeedId getFeedId()

Specified by:

getFeedId in interface IFeedOperatorOutputSideHandler

getType

public IFeedOperatorOutputSideHandler.Type getType()

Specified by:

getType in interface IFeedOperatorOutputSideHandler

getDownstreamWriter

public org.apache.hyracks.api.comm.IFrameWriter getDownstreamWriter()

getConnectionId

public FeedConnectionId getConnectionId()

reset

public void reset(org.apache.hyracks.api.comm.IFrameWriter writer)