public static class EsFactory.EsScheme
extends cascading.scheme.Scheme
Modifier and Type | Method and Description |
---|---|
void |
sink(cascading.flow.FlowProcess flowProcess,
cascading.scheme.SinkCall sinkCall) |
void |
sinkConfInit(cascading.flow.FlowProcess flowProcess,
cascading.tap.Tap tap,
java.lang.Object conf) |
boolean |
source(cascading.flow.FlowProcess flowProcess,
cascading.scheme.SourceCall sourceCall) |
void |
sourceConfInit(cascading.flow.FlowProcess flowProcess,
cascading.tap.Tap tap,
java.lang.Object conf) |
equals, getNumSinkParts, getSinkFields, getSourceFields, getTrace, hashCode, isSink, isSource, isSymmetrical, presentSinkFields, presentSinkFieldsInternal, presentSourceFields, presentSourceFieldsInternal, retrieveSinkFields, retrieveSourceFields, setNumSinkParts, setSinkFields, setSourceFields, sinkCleanup, sinkPrepare, sourceCleanup, sourcePrepare, toString
public void sourceConfInit(cascading.flow.FlowProcess flowProcess, cascading.tap.Tap tap, java.lang.Object conf)
sourceConfInit
in class cascading.scheme.Scheme
public void sinkConfInit(cascading.flow.FlowProcess flowProcess, cascading.tap.Tap tap, java.lang.Object conf)
sinkConfInit
in class cascading.scheme.Scheme
public boolean source(cascading.flow.FlowProcess flowProcess, cascading.scheme.SourceCall sourceCall) throws java.io.IOException
source
in class cascading.scheme.Scheme
java.io.IOException
public void sink(cascading.flow.FlowProcess flowProcess, cascading.scheme.SinkCall sinkCall) throws java.io.IOException
sink
in class cascading.scheme.Scheme
java.io.IOException