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. |
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 |
MessageSourceTap
public MessageSourceTap(Scheme<Properties,InputStream,?,?,?> scheme,
MessageSource<byte[]> source)
- Constructs a new
MessageSourceTap
instance.
- Parameters:
scheme
- data schemesource
- 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 schemesource
- an arbitrary message sourcetransformer
- a transformer converting the given message source type to byte[]
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