cascading.tuple
Class TupleEntrySchemeIterator<Config,Input>
java.lang.Object
cascading.tuple.TupleEntryIterator
cascading.tuple.TupleEntrySchemeIterator<Config,Input>
- All Implemented Interfaces:
- Closeable, Iterator<TupleEntry>
- Direct Known Subclasses:
- HadoopTupleEntrySchemeIterator
public class TupleEntrySchemeIterator<Config,Input>
- extends TupleEntryIterator
Class TupleEntrySchemeIterator is a helper class for wrapping a Scheme
instance, calling
Scheme.source(cascading.flow.FlowProcess, cascading.scheme.SourceCall)
on every call to
next()
.
Use this class inside a custom Tap
when overriding the
Tap.openForRead(cascading.flow.FlowProcess)
method.
Constructor Summary |
TupleEntrySchemeIterator(FlowProcess<Config> flowProcess,
Scheme scheme,
cascading.util.CloseableIterator<Input> inputIterator)
|
TupleEntrySchemeIterator(FlowProcess<Config> flowProcess,
Scheme scheme,
cascading.util.CloseableIterator<Input> inputIterator,
String identifier)
|
TupleEntrySchemeIterator(FlowProcess<Config> flowProcess,
Scheme scheme,
Input input)
|
TupleEntrySchemeIterator(FlowProcess<Config> flowProcess,
Scheme scheme,
Input input,
String identifier)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TupleEntrySchemeIterator
public TupleEntrySchemeIterator(FlowProcess<Config> flowProcess,
Scheme scheme,
Input input)
TupleEntrySchemeIterator
public TupleEntrySchemeIterator(FlowProcess<Config> flowProcess,
Scheme scheme,
Input input,
String identifier)
TupleEntrySchemeIterator
public TupleEntrySchemeIterator(FlowProcess<Config> flowProcess,
Scheme scheme,
cascading.util.CloseableIterator<Input> inputIterator)
TupleEntrySchemeIterator
public TupleEntrySchemeIterator(FlowProcess<Config> flowProcess,
Scheme scheme,
cascading.util.CloseableIterator<Input> inputIterator,
String identifier)
getFlowProcess
protected FlowProcess<Config> getFlowProcess()
wrapInput
protected Input wrapInput(Input input)
hasNext
public boolean hasNext()
next
public TupleEntry next()
remove
public void remove()
close
public void close()
throws IOException
- Throws:
IOException
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.