public class HadoopTupleEntrySchemeIterator extends cascading.tuple.TupleEntrySchemeIterator<Configuration,RecordReader>
Constructor and Description |
---|
HadoopTupleEntrySchemeIterator(cascading.flow.FlowProcess<? extends Configuration> flowProcess,
cascading.scheme.Scheme scheme,
cascading.util.CloseableIterator<RecordReader> closeableIterator) |
HadoopTupleEntrySchemeIterator(cascading.flow.FlowProcess<? extends Configuration> flowProcess,
cascading.tap.Tap parentTap,
RecordReader recordReader) |
Modifier and Type | Method and Description |
---|---|
protected RecordReader |
wrapInput(RecordReader recordReader) |
public HadoopTupleEntrySchemeIterator(cascading.flow.FlowProcess<? extends Configuration> flowProcess, cascading.tap.Tap parentTap, RecordReader recordReader) throws java.io.IOException
java.io.IOException
public HadoopTupleEntrySchemeIterator(cascading.flow.FlowProcess<? extends Configuration> flowProcess, cascading.scheme.Scheme scheme, cascading.util.CloseableIterator<RecordReader> closeableIterator)
protected RecordReader wrapInput(RecordReader recordReader)
wrapInput
in class cascading.tuple.TupleEntrySchemeIterator<Configuration,RecordReader>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.