org.springframework.data.hadoop.cascading.tap.local
Class MessageSourceTap

java.lang.Object
  cascading.tap.Tap<Config,Input,Void>
      cascading.tap.SourceTap<Properties,InputStream>
          org.springframework.data.hadoop.cascading.tap.local.MessageSourceTap

All Implemented Interfaces:

FlowElement, Serializable

public class MessageSourceTap
extends SourceTap<Properties,InputStream>

SourceTap for Spring Integration MessageSource.

Author:

Costin Leau

See Also:

Serialized Form

Constructor Summary

MessageSourceTap(Scheme<Properties,InputStream,?,?,?> scheme, MessageSource<?> source, Transformer transformer)
Constructs a new MessageSourceTap instance.

MessageSourceTap(Scheme<Properties,InputStream,?,?,?> scheme, MessageSource<byte[]> source)
Constructs a new MessageSourceTap instance.

Method Summary

String	getIdentifier()
long	getModifiedTime(Properties conf)
TupleEntryIterator	openForRead(FlowProcess<Properties> flowProcess, InputStream input)
boolean	resourceExists(Properties conf)

Methods inherited from class cascading.tap.SourceTap

commitResource, createResource, deleteResource, getSinkFields, isSink, openForWrite, rollbackResource, sinkConfInit

Methods inherited from class cascading.tap.Tap

equals, flowConfInit, getConfigDef, getFullIdentifier, getScheme, getSinkMode, getSourceFields, getStepConfigDef, getTrace, hasConfigDef, hashCode, hasStepConfigDef, id, isEquivalentTo, isKeep, isReplace, isSource, isTemporary, isUpdate, openForRead, openForWrite, outgoingScopeFor, presentSinkFields, presentSourceFields, resolveIncomingOperationArgumentFields, resolveIncomingOperationPassThroughFields, retrieveSinkFields, retrieveSourceFields, setScheme, sourceConfInit, taps, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

MessageSourceTap

public MessageSourceTap(Scheme<Properties,InputStream,?,?,?> scheme,
                        MessageSource<byte[]> source)

Constructs a new MessageSourceTap instance.

Parameters:

scheme - data scheme

source - a byte[] based message source

MessageSourceTap

public MessageSourceTap(Scheme<Properties,InputStream,?,?,?> scheme,
                        MessageSource<?> source,
                        Transformer transformer)

Constructs a new MessageSourceTap instance. Allows arbitrary message sources to be passed in along-side a transformer acting as a serializer.

Parameters:

scheme - data scheme

source - an arbitrary message source

transformer - a transformer converting the given message source type to byte[]

Method Detail

getIdentifier

public String getIdentifier()

Specified by:

getIdentifier in class Tap<Properties,InputStream,Void>

openForRead

public TupleEntryIterator openForRead(FlowProcess<Properties> flowProcess,
                                      InputStream input)
                               throws IOException

Specified by:

openForRead in class Tap<Properties,InputStream,Void>

Throws:

IOException

resourceExists

public boolean resourceExists(Properties conf)
                       throws IOException

Specified by:

resourceExists in class Tap<Properties,InputStream,Void>

Throws:

IOException

getModifiedTime

public long getModifiedTime(Properties conf)
                     throws IOException

Specified by:

getModifiedTime in class Tap<Properties,InputStream,Void>

Throws:

IOException