public class HadoopTupleEntrySchemeIterator extends TupleEntrySchemeIterator<Configuration,RecordReader>
Constructor and Description |
---|
HadoopTupleEntrySchemeIterator(FlowProcess<? extends Configuration> flowProcess,
Scheme scheme,
CloseableIterator<RecordReader> closeableIterator) |
HadoopTupleEntrySchemeIterator(FlowProcess<? extends Configuration> flowProcess,
Tap parentTap,
RecordReader recordReader) |
Modifier and Type | Method and Description |
---|---|
protected RecordReader |
wrapInput(RecordReader recordReader) |
close, getFlowProcess, hasNext, next, remove
getFields, getTupleEntry
public HadoopTupleEntrySchemeIterator(FlowProcess<? extends Configuration> flowProcess, Tap parentTap, RecordReader recordReader) throws IOException
IOException
public HadoopTupleEntrySchemeIterator(FlowProcess<? extends Configuration> flowProcess, Scheme scheme, CloseableIterator<RecordReader> closeableIterator)
protected RecordReader wrapInput(RecordReader recordReader)
wrapInput
in class TupleEntrySchemeIterator<Configuration,RecordReader>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.