public class SequenceFile extends Scheme<Configuration,RecordReader,OutputCollector,Object[],Void>
Scheme
, which is a flat file consisting of
binary key/value pairs. This is a space and time efficient means to store data.Modifier | Constructor and Description |
---|---|
protected |
SequenceFile()
Protected for use by TempDfs and other subclasses.
|
|
SequenceFile(Fields fields)
Creates a new SequenceFile instance that stores the given field names.
|
Modifier and Type | Method and Description |
---|---|
void |
sink(FlowProcess<? extends Configuration> flowProcess,
SinkCall<Void,OutputCollector> sinkCall) |
void |
sinkConfInit(FlowProcess<? extends Configuration> flowProcess,
Tap<Configuration,RecordReader,OutputCollector> tap,
Configuration conf) |
boolean |
source(FlowProcess<? extends Configuration> flowProcess,
SourceCall<Object[],RecordReader> sourceCall) |
void |
sourceCleanup(FlowProcess<? extends Configuration> flowProcess,
SourceCall<Object[],RecordReader> sourceCall) |
void |
sourceConfInit(FlowProcess<? extends Configuration> flowProcess,
Tap<Configuration,RecordReader,OutputCollector> tap,
Configuration conf) |
void |
sourcePrepare(FlowProcess<? extends Configuration> flowProcess,
SourceCall<Object[],RecordReader> sourceCall) |
equals, getNumSinkParts, getSinkFields, getSourceFields, getTrace, hashCode, isSink, isSource, isSymmetrical, presentSinkFields, presentSinkFieldsInternal, presentSourceFields, presentSourceFieldsInternal, retrieveSinkFields, retrieveSourceFields, setNumSinkParts, setSinkFields, setSourceFields, sinkCleanup, sinkPrepare, toString
protected SequenceFile()
@ConstructorProperties(value="fields") public SequenceFile(Fields fields)
fields
- public void sourceConfInit(FlowProcess<? extends Configuration> flowProcess, Tap<Configuration,RecordReader,OutputCollector> tap, Configuration conf)
sourceConfInit
in class Scheme<Configuration,RecordReader,OutputCollector,Object[],Void>
public void sinkConfInit(FlowProcess<? extends Configuration> flowProcess, Tap<Configuration,RecordReader,OutputCollector> tap, Configuration conf)
sinkConfInit
in class Scheme<Configuration,RecordReader,OutputCollector,Object[],Void>
public void sourcePrepare(FlowProcess<? extends Configuration> flowProcess, SourceCall<Object[],RecordReader> sourceCall)
sourcePrepare
in class Scheme<Configuration,RecordReader,OutputCollector,Object[],Void>
public boolean source(FlowProcess<? extends Configuration> flowProcess, SourceCall<Object[],RecordReader> sourceCall) throws IOException
source
in class Scheme<Configuration,RecordReader,OutputCollector,Object[],Void>
IOException
public void sourceCleanup(FlowProcess<? extends Configuration> flowProcess, SourceCall<Object[],RecordReader> sourceCall)
sourceCleanup
in class Scheme<Configuration,RecordReader,OutputCollector,Object[],Void>
public void sink(FlowProcess<? extends Configuration> flowProcess, SinkCall<Void,OutputCollector> sinkCall) throws IOException
sink
in class Scheme<Configuration,RecordReader,OutputCollector,Object[],Void>
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.