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

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

All Implemented Interfaces:

cascading.flow.FlowElement, java.io.Serializable

public class MessageSourceTap
extends cascading.tap.SourceTap<java.util.Properties,java.io.InputStream>

SourceTap for Spring Integration MessageSource.

Author:

Costin Leau

See Also:

Serialized Form

Constructor Summary

MessageSourceTap(cascading.scheme.Scheme<java.util.Properties,java.io.InputStream,?,?,?> scheme, org.springframework.integration.core.MessageSource<?> source, org.springframework.integration.transformer.Transformer transformer)
Constructs a new MessageSourceTap instance.

MessageSourceTap(cascading.scheme.Scheme<java.util.Properties,java.io.InputStream,?,?,?> scheme, org.springframework.integration.core.MessageSource<byte[]> source)
Constructs a new MessageSourceTap instance.

Method Summary

java.lang.String	getIdentifier()
long	getModifiedTime(java.util.Properties conf)
cascading.tuple.TupleEntryIterator	openForRead(cascading.flow.FlowProcess<java.util.Properties> flowProcess, java.io.InputStream input)
boolean	resourceExists(java.util.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(cascading.scheme.Scheme<java.util.Properties,java.io.InputStream,?,?,?> scheme,
                        org.springframework.integration.core.MessageSource<byte[]> source)

Constructs a new MessageSourceTap instance.

Parameters:

scheme - data scheme

source - a byte[] based message source

MessageSourceTap

public MessageSourceTap(cascading.scheme.Scheme<java.util.Properties,java.io.InputStream,?,?,?> scheme,
                        org.springframework.integration.core.MessageSource<?> source,
                        org.springframework.integration.transformer.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 java.lang.String getIdentifier()

Specified by:

getIdentifier in class cascading.tap.Tap<java.util.Properties,java.io.InputStream,java.lang.Void>

openForRead

public cascading.tuple.TupleEntryIterator openForRead(cascading.flow.FlowProcess<java.util.Properties> flowProcess,
                                                      java.io.InputStream input)
                                               throws java.io.IOException

Specified by:

openForRead in class cascading.tap.Tap<java.util.Properties,java.io.InputStream,java.lang.Void>

Throws:

java.io.IOException

resourceExists

public boolean resourceExists(java.util.Properties conf)
                       throws java.io.IOException

Specified by:

resourceExists in class cascading.tap.Tap<java.util.Properties,java.io.InputStream,java.lang.Void>

Throws:

java.io.IOException

getModifiedTime

public long getModifiedTime(java.util.Properties conf)
                     throws java.io.IOException

Specified by:

getModifiedTime in class cascading.tap.Tap<java.util.Properties,java.io.InputStream,java.lang.Void>

Throws:

java.io.IOException