public class TupleEntrySchemeIterator<Config,Input> extends TupleEntryIterator
Scheme
instance, calling
Scheme.source(cascading.flow.FlowProcess, cascading.scheme.SourceCall)
on every call to
next()
. The behavior can be controlled via properties defined in TupleEntrySchemeIteratorProps
.
Use this class inside a custom Tap
when overriding the
Tap.openForRead(cascading.flow.FlowProcess)
method.Constructor and Description |
---|
TupleEntrySchemeIterator(FlowProcess<? extends Config> flowProcess,
Scheme scheme,
CloseableIterator<Input> inputIterator) |
TupleEntrySchemeIterator(FlowProcess<? extends Config> flowProcess,
Scheme scheme,
CloseableIterator<Input> inputIterator,
java.lang.String identifier) |
TupleEntrySchemeIterator(FlowProcess<? extends Config> flowProcess,
Scheme scheme,
Input input) |
TupleEntrySchemeIterator(FlowProcess<? extends Config> flowProcess,
Scheme scheme,
Input input,
java.lang.String identifier) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected FlowProcess<? extends Config> |
getFlowProcess() |
boolean |
hasNext() |
TupleEntry |
next() |
void |
remove() |
protected Input |
wrapInput(Input input) |
getFields, getTupleEntry
public TupleEntrySchemeIterator(FlowProcess<? extends Config> flowProcess, Scheme scheme, Input input)
public TupleEntrySchemeIterator(FlowProcess<? extends Config> flowProcess, Scheme scheme, Input input, java.lang.String identifier)
public TupleEntrySchemeIterator(FlowProcess<? extends Config> flowProcess, Scheme scheme, CloseableIterator<Input> inputIterator)
public TupleEntrySchemeIterator(FlowProcess<? extends Config> flowProcess, Scheme scheme, CloseableIterator<Input> inputIterator, java.lang.String identifier)
protected FlowProcess<? extends Config> getFlowProcess()
public boolean hasNext()
public TupleEntry next()
public void remove()
public void close() throws java.io.IOException
java.io.IOException
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.