public class SequenceFile extends cascading.scheme.Scheme<Configuration,RecordReader,OutputCollector,java.lang.Object[],java.lang.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(cascading.tuple.Fields fields)
Creates a new SequenceFile instance that stores the given field names.
|
Modifier and Type | Method and Description |
---|---|
void |
sink(cascading.flow.FlowProcess<? extends Configuration> flowProcess,
cascading.scheme.SinkCall<java.lang.Void,OutputCollector> sinkCall) |
void |
sinkConfInit(cascading.flow.FlowProcess<? extends Configuration> flowProcess,
cascading.tap.Tap<Configuration,RecordReader,OutputCollector> tap,
Configuration conf) |
boolean |
source(cascading.flow.FlowProcess<? extends Configuration> flowProcess,
cascading.scheme.SourceCall<java.lang.Object[],RecordReader> sourceCall) |
void |
sourceCleanup(cascading.flow.FlowProcess<? extends Configuration> flowProcess,
cascading.scheme.SourceCall<java.lang.Object[],RecordReader> sourceCall) |
void |
sourceConfInit(cascading.flow.FlowProcess<? extends Configuration> flowProcess,
cascading.tap.Tap<Configuration,RecordReader,OutputCollector> tap,
Configuration conf) |
void |
sourcePrepare(cascading.flow.FlowProcess<? extends Configuration> flowProcess,
cascading.scheme.SourceCall<java.lang.Object[],RecordReader> sourceCall) |
equals, getNumSinkParts, getSinkFields, getSourceFields, getTrace, hashCode, isSink, isSource, isSymmetrical, presentSinkFields, presentSinkFieldsInternal, presentSourceFields, presentSourceFieldsInternal, retrieveSinkFields, retrieveSourceFields, setNumSinkParts, setSinkFields, setSourceFields, sinkCleanup, sinkPrepare, sourceRePrepare, toString
protected SequenceFile()
@ConstructorProperties(value="fields") public SequenceFile(cascading.tuple.Fields fields)
fields
- public void sourceConfInit(cascading.flow.FlowProcess<? extends Configuration> flowProcess, cascading.tap.Tap<Configuration,RecordReader,OutputCollector> tap, Configuration conf)
sourceConfInit
in class cascading.scheme.Scheme<Configuration,RecordReader,OutputCollector,java.lang.Object[],java.lang.Void>
public void sinkConfInit(cascading.flow.FlowProcess<? extends Configuration> flowProcess, cascading.tap.Tap<Configuration,RecordReader,OutputCollector> tap, Configuration conf)
sinkConfInit
in class cascading.scheme.Scheme<Configuration,RecordReader,OutputCollector,java.lang.Object[],java.lang.Void>
public void sourcePrepare(cascading.flow.FlowProcess<? extends Configuration> flowProcess, cascading.scheme.SourceCall<java.lang.Object[],RecordReader> sourceCall)
sourcePrepare
in class cascading.scheme.Scheme<Configuration,RecordReader,OutputCollector,java.lang.Object[],java.lang.Void>
public boolean source(cascading.flow.FlowProcess<? extends Configuration> flowProcess, cascading.scheme.SourceCall<java.lang.Object[],RecordReader> sourceCall) throws java.io.IOException
source
in class cascading.scheme.Scheme<Configuration,RecordReader,OutputCollector,java.lang.Object[],java.lang.Void>
java.io.IOException
public void sourceCleanup(cascading.flow.FlowProcess<? extends Configuration> flowProcess, cascading.scheme.SourceCall<java.lang.Object[],RecordReader> sourceCall)
sourceCleanup
in class cascading.scheme.Scheme<Configuration,RecordReader,OutputCollector,java.lang.Object[],java.lang.Void>
public void sink(cascading.flow.FlowProcess<? extends Configuration> flowProcess, cascading.scheme.SinkCall<java.lang.Void,OutputCollector> sinkCall) throws java.io.IOException
sink
in class cascading.scheme.Scheme<Configuration,RecordReader,OutputCollector,java.lang.Object[],java.lang.Void>
java.io.IOException
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.